fn main() {
    let (tx, rx) = loole::unbounded();

    std::thread::spawn(move || {
        for i in 0..10 {
            tx.send(i).unwrap();
        }
    });

    let mut sum = 0;
    while let Ok(i) = rx.recv() {
        sum += i;
    }

    assert_eq!(sum, (0..10).sum());
}

loole = "0.3.0"

cargo run --release -p benchmark

Contributors

Stargazers

Forkers

yssource pinkforest asonix gmh5225

fn test_loole() {
    let (tx, rx) = loole::bounded::<Vec<[usize; 10000]>>(10);
    {
        let rx = rx.clone();
        let max_wait_timeout = std::time::Duration::from_nanos(5);
        let _ = std::thread::spawn(move || {
            loop {
                let t = match rx.recv_timeout(max_wait_timeout) {
                    Ok(a) => { a }
                    Err(RecvTimeoutError::Timeout) => {
                        continue;
                    }
                    Err(RecvTimeoutError::Disconnected) => {
                        break;
                    }
                };
            }
        }).join();
    }
}