cyclotrace 0.2.0

A high-performance, wait-free ring buffer in Rust. Supports SPMC with peek-based semantics instead of destructive consumption.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use core::hint::black_box;
use std::thread;

use cyclotrace::*;

#[derive(Clone, Copy)]
struct BigData {
    _big: [u64; 16],
}

fn main() {
    let (writer, reader) = create_buffer::<BigData, 64>();

    let h1 = thread::spawn(move || {
        writer.write(BigData { _big: [0; 16] });
    });

    let h2 = thread::spawn(move || {
        black_box(reader.get(0));
    });
    h1.join().unwrap();
    h2.join().unwrap();
}