gil 0.8.0

A collection of high-performance, lock-free concurrent queues (SPSC, MPSC, MPMC, SPMC) with sync and 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

use gil::mpsc::channel;
use std::{hint::black_box, num::NonZeroUsize, thread::spawn, time::SystemTime};

fn main() {
    let (tx, mut rx) = channel(NonZeroUsize::new(4096).unwrap());

    const SENDERS: usize = 4;
    const MESSAGES: usize = 5_000_000;

    let start = SystemTime::now();

    for _ in 0..SENDERS {
        let mut tx = tx.clone();
        spawn(move || {
            for i in 0..MESSAGES {
                while tx.try_send(black_box(i)).is_err() {}
            }
        });
    }

    // Drop the original sender since we've cloned it for all threads
    drop(tx);

    for _ in 0..(SENDERS * MESSAGES) {
        loop {
            let Some(x) = rx.try_recv() else {
                continue;
            };
            black_box(x);
            break;
        }
    }

    let time = start.elapsed().unwrap();
    println!(
        "time={time:?}\nmil/s={throughput:.2}",
        throughput = MESSAGES as f64 / 1_000_000.0 / time.as_secs_f64()
    );
}