pub struct Queue<T> { /* private fields */ }
Expand description
A simple, threadsafe, queue of items of type T
This is a sort of channel where any thread can push to a queue and any thread can pop from a queue.
This supports both bounded and unbounded operations. push
will never block,
and allows the queue to grow without bounds. push_bounded
will block if
the queue is over capacity, and will resume once there is enough capacity.
Implementations§
source§impl<T> Queue<T>
impl<T> Queue<T>
sourcepub fn push(&self, item: T)
pub fn push(&self, item: T)
Pushes an item onto the queue, regardless of the capacity of the queue.
sourcepub fn push_bounded(&self, item: T)
pub fn push_bounded(&self, item: T)
Pushes an item onto the queue, blocking if the queue is full.
sourcepub fn pop(&self, timeout: Duration) -> Option<T>
pub fn pop(&self, timeout: Duration) -> Option<T>
Pops an item from the queue, blocking if the queue is empty.
sourcepub fn try_pop_all(&self) -> Vec<T>
pub fn try_pop_all(&self) -> Vec<T>
Pops all items from the queue without blocking.