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

use spsc_ring::ring;
use std::thread;

fn main() {
    let (tx, rx) = ring::<u32>(256).unwrap();
    let data: Vec<u32> = (0..1024).collect();
    let data_clone = data.clone();

    let producer = thread::spawn(move || {
        let mut sent = 0;
        while sent < data_clone.len() {
            sent += tx.push_slice(&data_clone[sent..]);
            std::hint::spin_loop();
        }
        println!("pushed {} items in bulk", sent);
    });

    let consumer = thread::spawn(move || {
        let mut received: Vec<u32> = Vec::with_capacity(1024);
        let mut buf = [0u32; 32];
        while received.len() < 1024 {
            let n = rx.pop_into_slice(&mut buf);
            received.extend_from_slice(&buf[..n]);
            std::hint::spin_loop();
        }
        assert_eq!(received, data);
        println!("received {} items in bulk, all correct", received.len());
    });

    producer.join().unwrap();
    consumer.join().unwrap();
}