Crate scatto

Source

Expand description

low-latency inter-thread communication inspired by lmax disruptor.

this crate provides zero-copy, lock-free channels for high-performance applications.

§features

pre-allocated ring buffers (no allocation in hot path)
sequence-based coordination (no locks)
multiple wait strategies for latency/CPU trade-offs
zero-copy in-place mutation support
cache-line padding to prevent false sharing

§channel types

spsc: single producer single consumer - lowest latency
mpsc: multi producer single consumer - multiple senders

§example

use scatto::spsc;

// create channel with 1024-slot buffer
let (mut producer, mut consumer) = spsc::channel::<u64>(1024);

// producer thread
std::thread::spawn(move || {
    for i in 0..1000 {
        producer.send(i).unwrap();
    }
});

// consumer
for _ in 0..1000 {
    let value = consumer.recv().unwrap();
}