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("oops! the child thread stopped working");
   }
   println!("{:?}", ids);
}

在上方的代码中,我们试图通过一个通道将线程的 id 传递到另一个线程。

输出

当我们运行上述代码时,我们会看到以下输出

thread 0 done
thread 1 done
thread 2 done
[Ok(0), Ok(1), Ok(2)]

该输出表明所有线程都完美工作,并且能够通过通道在它们之间实现通信。

更新于: 2021 年 4 月 3 日

628 次浏览

职业生涯起步

完成本课程后获得认证

立即开始
广告