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)]

输出表明所有线程均工作正常，并且已通过通道启用了它们之间的通信。