Rust编程中的通道
通道是一种允许在两个或更多线程之间进行通信的介质。Rust提供了启用线程之间通信的异步通道。
Rust中的通道允许两个端点之间的单向通信流。这两个端点是发送方和接收方。
示例
考虑下面显示的示例-
use std::sync::mpsc::{Sender, Receiver};
use std::sync::mpsc;
use std::thread;
static NTHREADS: i32 = 3;
fn main() {
let (tx, rx): (Sender, Receiver) = mpsc::channel();
let mut children = Vec::new();
for id in 0..NTHREADS {
let thread_tx = tx.clone();
let child = thread::spawn(move || {
thread_tx.send(id).unwrap();
println!("thread {} done", id);
});
children.push(child);
}
let mut ids = Vec::with_capacity(NTHREADS as usize);
for _ in 0..NTHREADS {
ids.push(rx.recv());
}
for child in children {
child.join().expect("哦!子线程停止工作");
}
println!("{:?}", ids);
}在上面的代码中，我们试图通过一个通道将线程的ID传递给另一个线程。
输出结果
当我们运行上面的代码时，我们将看到以下输出：
thread 0 done thread 1 done thread 2 done [Ok(0), Ok(1), Ok(2)]
输出表明所有线程均工作正常，并且已通过通道启用了它们之间的通信。