Struct CachePaddedMPMCConsumer 

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

The consumer of the MPMCBoundedQueue.

Implementations

impl<T: Send, const CAPACITY: usize> CachePaddedMPMCConsumer<T, CAPACITY>

pub fn queue(&self) -> &MPMCBoundedQueue<T, CAPACITY, CachePaddedLongAtomic>

Returns a reference to the inner MPMCBoundedQueue.

Trait Implementations

impl<T: Send, const CAPACITY: usize> Clone for CachePaddedMPMCConsumer<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 CachePaddedMPMCConsumer<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 CachePaddedMPMCConsumer<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> MultiLockFreeProducerSpawner<T> for CachePaddedMPMCConsumer<T, CAPACITY>

type SpawnedLockFreeProducer = CachePaddedMPMCProducer<T, CAPACITY>

An associated MultiLockFreeProducer type.

fn spawn_multi_lock_free_producer(&self) -> Self::SpawnedLockFreeProducer

Spawns a MultiLockFreeProducer.

impl<T: Send, const CAPACITY: usize> MultiProducerSpawner<T> for CachePaddedMPMCConsumer<T, CAPACITY>

type SpawnedProducer = CachePaddedMPMCProducer<T, CAPACITY>

An associated MultiProducer type.

fn spawn_multi_producer(&self) -> Self::SpawnedProducer

Spawns a MultiProducer.

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

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

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