Struct futex_queue::Receiver

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

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.