spsc-ring 0.1.0

Lock-free SPSC ring buffer — sequence-number protocol, cache-line padded, zero dependencies
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

use spsc_ring::{WaitStrategy, ring};
use std::thread;
use std::time::Duration;

fn run(name: &str, strategy: WaitStrategy) {
    let (tx, rx) = ring::<u64>(64).unwrap();
    let count = 10_000u64;

    let producer = thread::spawn(move || {
        for i in 0..count {
            if tx.push(i, &strategy).is_err() {
                break;
            }
        }
    });

    let consumer = thread::spawn(move || {
        let mut last = 0u64;
        for _ in 0..count {
            match rx.pop(&strategy) {
                Ok(v) => last = v,
                Err(_) => break,
            }
        }
        last
    });

    producer.join().unwrap();
    let last = consumer.join().unwrap();
    println!("{}: received {} items, last={}", name, count, last);
}

fn main() {
    run("SpinLoop", WaitStrategy::SpinLoop);
    run("Yield", WaitStrategy::Yield);
    run("Sleep(1µs)", WaitStrategy::Sleep(Duration::from_micros(1)));
}