nexus-queue 1.3.0

High-performance lock-free SPSC and MPSC queues for 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

use std::hint::black_box;

#[repr(C)]
struct Order {
    id: u64,
    price: f64,
    qty: f64,
}

fn main() {
    let (producer, consumer) = nexus_queue::spsc::ring_buffer::<Order>(1024);

    for _ in 0..1000 {
        let _ = black_box(&producer).push(Order {
            id: 1,
            price: 100.5,
            qty: 10.0,
        });
        if let Some(val) = black_box(&consumer).pop() {
            black_box(&val);
        }
    }
}