Struct FutexQueue

pub struct FutexQueue<T, const N: usize> { /* private fields */ }

A fixed size MPSC queue with timer capability based on Linux futex. Suitable for real-time applications. Size N must be a power of 2.

Implementations

impl<T, const N: usize> FutexQueue<T, N>

pub fn new() -> (Sender<T, N>, Receiver<T, N>)

Examples found in repository

examples/simple.rs (line 8)

fn main() {
    let (tx, mut rx) = FutexQueue::<u32, 4>::new();
    let now = Instant::now();

    let thread = thread::spawn(move || loop {
        let item = rx.recv();
        println!(
            "{} ms: Received: {}",
            now.elapsed().as_millis(),
            item.value()
        );
    });

    tx.send(1).unwrap();
    tx.send_scheduled(2, now + Duration::from_secs(1)).unwrap();
    tx.send(3).unwrap();
    tx.send_scheduled(4, now + Duration::from_secs(2)).unwrap();

    thread.join().unwrap();
}