spmc

Rust的单生产者、多消费者通道。

文档

许可

许可以下任一

• Apache许可证，版本2.0
• MIT许可证

任选其一。

贡献

除非你明确声明，否则任何有意提交给作品以包含在内的贡献，如Apache-2.0许可证中定义的，应作为上述双许可，没有任何附加条款或条件。

lib.rs:

SPMC

单生产者、多消费者。通常用于实现工作窃取。

示例

let (mut tx, rx) = spmc::channel();

let mut handles = Vec::new();
for n in 0..5 {
    let rx = rx.clone();
    handles.push(thread::spawn(move || {
        let msg = rx.recv().unwrap();
        println!("worker {} recvd: {}", n, msg);
    }));
}

for i in 0..5 {
    tx.send(i * 2).unwrap();
}

for handle in handles {
  handle.join().unwrap();
}