Question

以 通道 （channel）在不同线程间传递消息。

注意，值所有权从 send 转移到 recv 端。

无锁（free lock）队列设计，性能优化。

use std::thread::scope;
use std::sync::mpsc::channel;

fn main() {
  let data = vec![1, 2, 3, 4];
  let (tx, rx) = channel();

  scope(|s| {
    s.spawn(move || {
      for d in data {
        tx.send(d).unwrap();
      }
    });

    s.spawn(move || {
      for v in rx {
        println!("{}", v);
      }
    });
  });
}

标准库 mpsc 是多生产者、单消费者的 FIFO 队列，通过 clone 创建多个生产者。

当所有生产者结束（ drop ），通道关闭。

use std::thread::scope;
use std::sync::mpsc::channel;

fn main() {
  let (tx, rx) = channel();

  scope(|s| {

    // 多个生产者。
    for i in 1..=10 {
      let t = tx.clone();
      s.spawn(move || {
        t.send(i).unwrap();
      });
    }

    // 销毁多余的生产者。
    drop(tx);

    // 接收数据。
    rx.into_iter().for_each(|v| println!("{}", v));
  });
}

默认 channel 创建异步（asynchronous）通道，其内部采取 “无限缓冲区”（infinite buffer）设计。也就是说，发送端不会等待接收操作，可能因发送过快导致内存等资源过多消耗。解决办法是用 sync_channel 创建固定（fixed size）缓冲区的同步（synchronous）通道。