• 通道

    通道

    Rust 针对线程之间的通信提供了异步的通道（channel）。通道允许两个端点之间信息的单向流动：Sender（发送端） 和 Receiver（接收端）。

    1. use std::sync::mpsc::{Sender, Receiver};
    2. use std::sync::mpsc;
    3. use std::thread;
    5. static NTHREADS: i32 = 3;
    7. fn main() {
    8.     // 通道有两个端点：`Sender<T>` 和 `Receiver<T>`，其中 `T` 是要发送
    9.     // 消息的类型（类型标注是可有可无的）
    10.     let (tx, rx): (Sender<i32>, Receiver<i32>) = mpsc::channel();
    12.     for id in 0..NTHREADS {
    13.         // sender 发送端可被复制
    14.         let thread_tx = tx.clone();
    16.         // 每个线程都将通过通道来发送它的 id
    17.         thread::spawn(move || {
    18.             // 此线程取得 `thread_tx` 所有权
    19.             // 每个线程都在通道中排队列出消息
    20.             // （原文：The thread takes ownership over `thread_tx`
    21.             // Each thread queues a message in the channel）
    22.             thread_tx.send(id).unwrap();
    24.             // 发送是一个非阻塞操作，线程将在发送完消息后继续进行
    25.             println!("thread {} finished", id);
    26.         });
    27.     }
    29.     // 所有消息都在此处被收集
    30.     let mut ids = Vec::with_capacity(NTHREADS as usize);
    31.     for _ in 0..NTHREADS {
    32.         // `recv` 方法从通道中拿到一个消息
    33.         // 若无可用消息的话，`recv` 将阻止当前线程
    34.         ids.push(rx.recv());
    35.     }
    37.     // 显示已发送消息的次序
    38.     println!("{:?}", ids);
    39. }