glommio 0.9.0

Glommio is a thread-per-core crate that makes writing highly parallel asynchronous applications in a thread-per-core architecture easier for rustaceans.
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

use glommio::channels::spsc_queue;
use std::time::Instant;

fn test_spsc(capacity: usize) {
    const RUNS: u32 = 10 * 1000 * 1000;
    let (sender, receiver) = spsc_queue::make::<u64>(1024);
    let consumer = std::thread::spawn(move || {
        let t = Instant::now();
        for _ in 0..RUNS {
            while receiver.try_pop().is_none() {}
        }
        println!(
            "cost of receiving {:#?}, capacity {}",
            t.elapsed() / RUNS,
            capacity,
        );
    });
    let t = Instant::now();
    for i in 0..RUNS {
        while sender.try_push(i as u64).is_some() {}
    }
    println!(
        "cost of sending {:#?}, capacity {}",
        t.elapsed() / RUNS,
        capacity
    );
    consumer.join().unwrap();
}

fn main() {
    test_spsc(1024);
}