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

//! Minimal SeqLock demo: a writer thread updates a u64 in a loop, a reader
//! thread observes consistent (non-torn) snapshots and prints a few of them.

use std::thread;

use low_latency_data_structures::seqlock;

fn main() {
    let (writer, reader) = seqlock::new(0u64);

    let writer_h = thread::spawn(move || {
        for i in 1..=1000 {
            writer.write(i);
        }
    });

    let reader_h = thread::spawn(move || {
        let mut samples = Vec::new();
        for _ in 0..5 {
            samples.push(reader.read());
            std::thread::sleep(std::time::Duration::from_micros(100));
        }
        samples
    });

    writer_h.join().unwrap();
    let samples = reader_h.join().unwrap();
    println!("reader sampled: {samples:?}");
}