Struct CachePaddedSPMCConsumer 

pub struct CachePaddedSPMCConsumer<T: Send, const CAPACITY: usize> { /* private fields */ }

The consumer of the SPMCBoundedQueue.

Trait Implementations

impl<T: Send, const CAPACITY: usize> Clone for CachePaddedSPMCConsumer<T, CAPACITY>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Send, const CAPACITY: usize> Consumer<T> for CachePaddedSPMCConsumer<T, CAPACITY>

fn capacity(&self) -> usize

Returns the capacity of the queue.

fn len(&self) -> usize

Returns the length of the queue.

fn pop_many(&self, dst: &mut [MaybeUninit<T>]) -> usize

Pops many values from the queue and returns the number of read values.

fn steal_into(&self, dst: &impl SingleProducer<T>) -> usize

Steals some values from the consumer and places them into dst. Returns the number of stolen values.

fn is_empty(&self) -> bool

Returns whether the queue is empty.

fn pop(&self) -> Option<T>

Pops a value from the queue and returns it.

impl<T: Send, const CAPACITY: usize> LockFreeConsumer<T> for CachePaddedSPMCConsumer<T, CAPACITY>

fn lock_free_pop_many(&self, dst: &mut [MaybeUninit<T>]) -> (usize, bool)

Pops many values from the queue. Returns the number of popped values and whether the operation failed because it should wait.

fn lock_free_steal_into( &self, dst: &impl SingleLockFreeProducer<T>, ) -> (usize, bool)

Steals some values from the consumer and places them into dst. Returns the number of stolen values and whether the operation failed because it should wait.

fn lock_free_pop(&self) -> Result<T, LockFreePopErr>

Pops a value from the queue. On failure, returns Err(LockFreePopErr).

impl<T: Send, const CAPACITY: usize> MultiConsumer<T> for CachePaddedSPMCConsumer<T, CAPACITY>

impl<T: Send, const CAPACITY: usize> MultiLockFreeConsumer<T> for CachePaddedSPMCConsumer<T, CAPACITY>

impl<T: Send, const CAPACITY: usize> Send for CachePaddedSPMCConsumer<T, CAPACITY>