Struct PooledDynamicQueue 

pub struct PooledDynamicQueue<T, S = Auto>
where
    S: SlotType<ItemHandle<T>>,
{ /* private fields */ }

A dynamically growable, pooled MPMCQueue.

Unlike DynamicQueue, this queue may store any type, at the cost of higher runtime and higher memory.

Only available on feature dynamic + pool

Implementations

impl<T> PooledDynamicQueue<T, Auto>

pub fn new(size: usize) -> Self

Constructs a new PooledDynamicQueue with capacity size and slot type Auto.

pub fn with_slot<S>(size: usize) -> PooledDynamicQueue<T, S>

where S: SlotType<ItemHandle<T>>,

Constructs a new Queue with capacity size and slot type S.

Trait Implementations

impl<T, S> Growable for PooledDynamicQueue<T, S>

where S: SlotType<ItemHandle<T>>, GrowableQueueCore<T, Pooled<T, QueueCore<BoxedBuffer<S::Slot>>, BoxedBuffer<UnsafeCell<Option<T>>>, QueueCore<BoxedBuffer<<Auto as SlotType<ItemHandle<()>>>::Slot>>>, S>: Growable,

fn grow_by(&self, by: usize) -> bool

Attempts to grow the capacity of the queue by by slots.

impl<T, S> MPMCQueue for PooledDynamicQueue<T, S>

where S: SlotType<ItemHandle<T>>,

type Item = T

The item stored in the queue

fn push(&self, item: Self::Item) -> Result<(), Self::Item>

Attempts to push an item into the queue. Returns the item as an error if the queue is full.

fn pop(&self) -> Option<Self::Item>

Attempts to pop an item from the queue. Returns None if the queue was empty.

fn len(&self) -> usize

Returns the current len of the queue. The returned value may be stale under concurrent access and should not be used for synchronization.

fn capacity(&self) -> usize

Returns the total capacity of the queue.

fn is_empty(&self) -> bool

Indicates whether the queue is empty. The returned value may be stale under concurrent access and should not be used for synchronization.

fn is_full(&self) -> bool

Indicates whether the queue is full. The returned value may be stale under concurrent access and should not be used for synchronization.

fn force_push(&self, item: Self::Item) -> Option<Self::Item>

Pushes an item into the queue, removing an existing item if the queue is full.

fn force_push_and_do<F>(&self, item: Self::Item, f: F)

where F: FnMut(Self::Item),

Pushes an item into the queue, removing an existing item if the queue is full.