Trait RPQueue 

pub trait RPQueue<'a, T> {
    // Required methods
    fn capacity(&self) -> usize;
    fn available(&self) -> usize;
    fn take(&self) -> Option<&'a mut T>;
    fn take_wait(&self, timeout: Duration) -> Option<&'a mut T>;
    fn offer(&self, item: &'a T) -> usize;
}

RPQueue trait for pool queues

Required Methods

fn capacity(&self) -> usize

Returns the size of the queue in total number objects originally allocated

fn available(&self) -> usize

Returns the number of available items in the buffer

fn take(&self) -> Option<&'a mut T>

Returns an object from the queue or None if the pool is empty available. This method is preferred over take_wait when empty or near empty pools are common.

fn take_wait(&self, timeout: Duration) -> Option<&'a mut T>

Returns an object from the queue or block until one is available

fn offer(&self, item: &'a T) -> usize

Returns an object to the pool.

Implementors

impl<'a, T> RPQueue<'a, T> for AtomicQueue<'a, T>

impl<'a, T> RPQueue<'a, T> for BlockingQueue<'a, T>