doublecross

基于 crossbeam-channel 的线程间通信的双向通道。

示例

let (left, right) = unbounded::<bool, i32>();
thread::spawn(move || {
    loop {
        let val = right.recv().unwrap();
        right.send(val % 2 == 0);
    }
});

for i in 0..10 {
    left.send(i);
    if left.recv().unwrap() {
        println!("{} is even", i);
    }
}

用法

[dependencies]
doublecross = "0.2"

许可证

许可协议为 MPL-2.0。