Enum BlockingQueueAdapter

pub enum BlockingQueueAdapter<E>
where
    E: Send + Sync,
{
    BlockingQueue {
        blocking_queue: BlockingQueue<E>,
    },
    CrossbeamBlockingQueue {
        crossbeam_blocking_queue: CrossbeamBlockingQueue<E>,
    },
}

Wrapper over available queue types.

Variants

BlockingQueue

Fields

blocking_queue: BlockingQueue<E>

CrossbeamBlockingQueue

Fields

crossbeam_blocking_queue: CrossbeamBlockingQueue<E>

Implementations

impl<E> BlockingQueueAdapter<E>

where E: Send + Sync,

pub fn new(queue_type: QueueType, size: usize) -> BlockingQueueAdapter<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>