hyperbridge 0.2.5

Fast multi-producer multi-consumer channel with async support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

extern crate hyperbridge;
use std::thread;

fn main() {
    let (sender, receiver) = hyperbridge::channel::new();
    let threads = 10;
    let values = 10000;

    let mut handles = vec![];

    for i in 0..threads {
        let ch = sender.clone();
        let jh = thread::spawn(move || {
            for _ in 0..values {
                ch.send(i).unwrap();
            }
        });
        handles.push(jh);
    }

    let mut iters = threads * values;

    while iters > 0 {
        match receiver.try_recv() {
            Ok(Some(_v)) => {
                iters -= 1;
            }
            _ => {}
        }
    }

    let total: usize = (0..threads).map(|i| i * values).sum();

    for jh in handles.drain(..) {
        let _ = jh.join();
    }

    println!("Send and received: {} items", total);
}