low-latency-data-structures 0.0.7

Experimental lock-free SPSC, SPMC broadcast, and SeqLock primitives tuned for ultra-low-latency systems
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

//! Minimal SPSC demo: a producer thread pushes a few integers, a consumer
//! thread pops them and prints what it saw.

use std::thread;

use low_latency_data_structures::mem::global::GlobalAllocator;
use low_latency_data_structures::spsc;

fn main() {
    let (mut producer, mut consumer) =
        spsc::new::<u64, 16, GlobalAllocator>(spsc::Options::global_mlocked());

    let producer_h = thread::spawn(move || {
        for i in 0..8 {
            while producer.push(i).is_some() {
                std::hint::spin_loop();
            }
        }
    });

    let consumer_h = thread::spawn(move || {
        let mut seen = Vec::with_capacity(8);
        while seen.len() < 8 {
            if let Some(v) = consumer.pop() {
                seen.push(v);
            } else {
                std::hint::spin_loop();
            }
        }
        seen
    });

    producer_h.join().unwrap();
    let seen = consumer_h.join().unwrap();
    println!("consumer observed: {seen:?}");
}