Struct Receiver

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

Receiver half of the queue.

Implementations

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

pub fn try_recv(&mut self) -> Result<Item<T>, Option<Instant>>

Tries to receive from the queue without blocking. Immediate items are returned first, then scheduled items in the order of earliest deadline first. Error contains an optional Instant of the earliest (not ready) deadline in the queue.

pub fn recv(&mut self) -> Item<T>

Tries to receive from the queue and blocks the current thread if queue is empty. Immediate items are returned first, then scheduled items in the order of earliest deadline first.

Examples found in repository

examples/simple.rs (line 12)

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();
}