#排序 #通道 #通信通道 #mpmc

sorted-channel

基于消息的有序通信通道

2 个版本

0.1.1 2023年3月31日
0.1.0 2023年3月31日

并发 中排名 968

每月下载量 22

MIT/Apache

9KB
146

sorted-channel

codecov

一个多生产者、多消费者通道,输出有序消息。每个消息只由一个接收通道接收。

示例

use sorted_channel::sorted_channel;
use std::thread;

let (tx, rx) = sorted_channel();

let handle = thread::spawn(move || {
    for i in [0, 9, 1, 8, 2, 7, 3, 6, 4, 5] {
        tx.send(i).unwrap();
    }
});

handle.join().unwrap();

for i in (0..10).rev() {
    assert_eq!(rx.recv(), Ok(i));
}

许可协议

许可协议为以下之一

任选其一。

贡献

除非您明确说明,否则根据 Apache-2.0 许可证定义,您提交的任何旨在包含在作品中的有意贡献,将按照上述方式双重许可,不附加任何额外的条款或条件。

依赖项

~0.4–5MB
~11K SLoC