Struct CrossbeamBlockingQueue

pub struct CrossbeamBlockingQueue<E>
where
    E: Send + Sync,
{ /* private fields */ }

Implementations

impl<E> CrossbeamBlockingQueue<E>

where E: Send + Sync,

pub fn new(size: usize) -> CrossbeamBlockingQueue<E>

pub fn len(&self) -> usize

pub fn capacity(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn is_full(&self) -> bool

pub fn wait_empty(&self, timeout: Duration) -> bool

pub fn enqueue(&self, element: E)

pub fn try_enqueue(&self, element: E, timeout: Duration) -> Option<E>

pub fn dequeue(&self) -> Option<E>

pub fn try_dequeue(&self, timeout: Duration) -> Option<E>