Struct MutexVecQueue 

pub struct MutexVecQueue<T> { /* private fields */ }

A wrapper around LightArc<Mutex<VecQueue<T>>>. It can be used as a global queue.

It implements BatchReceiver and LockFreeBatchReceiver with returning an error when it should wait.

Implementations

impl<T> MutexVecQueue<T>

pub fn new() -> Self

Creates a new MutexVecQueue.

pub fn len(&self) -> usize

Returns the number of elements in the queue.

pub fn is_empty(&self) -> bool

Returns whether the queue is empty.

pub fn push(&self, task: T)

Pushes a value to the queue.

pub fn move_batch_to_producer( &self, producer: &impl SingleProducer<T>, limit: usize, )

Moves at most limit elements from the queue to the producer.

Trait Implementations

impl<T> BatchReceiver<T> for MutexVecQueue<T>

unsafe fn push_many_and_slice(&self, first: &[T], last: &[T], slice: &[T])

Pushes a batch of values to the receiver.

unsafe fn push_many_and_one(&self, first: &[T], last: &[T], value: T)

Pushes a batch of values to the receiver.

impl<T: Clone> Clone for MutexVecQueue<T>

fn clone(&self) -> MutexVecQueue<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Default for MutexVecQueue<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> LockFreeBatchReceiver<T> for MutexVecQueue<T>

unsafe fn lock_free_push_many_and_slice_and_commit_if<F, FSuccess, FError>( &self, first: &[T], last: &[T], slice: &[T], f: F, ) -> Result<FSuccess, LockFreePushBatchErr<(), FError>>

where F: FnOnce() -> Result<FSuccess, FError>,

Pushes a batch of values to the receiver but commits it only if the function returns true.

unsafe fn push_many_and_one_and_commit_if<F, FSuccess, FError>( &self, first: &[T], last: &[T], value: T, f: F, ) -> Result<FSuccess, LockFreePushBatchErr<T, FError>>

where F: FnOnce() -> Result<FSuccess, FError>,

Pushes a batch of values to the receiver but commits it only if the function returns true.