Struct Queue

pub struct Queue<T> { /* private fields */ }

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

impl<T> Queue<T>

pub fn new(bound: usize) -> Queue<T>

pub fn push(&self, item: T)

pub fn push_bounded(&self, item: T)

Pushes an item onto the queue, blocking if the queue is full.

pub fn pop(&self, timeout: Duration) -> Option<T>

pub fn try_pop_all(&self) -> Vec<T>