Struct SPSCProducer 

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

The producer of the SPSCBoundedQueue.

Trait Implementations

impl<T: Send, const CAPACITY: usize> LockFreeProducer<T> for SPSCProducer<T, CAPACITY>

fn lock_free_maybe_push(&self, value: T) -> Result<(), LockFreePushErr<T>>

Pushes a value only if the queue is not full. On failure, returns Err(LockFreePushErr).

impl<T: Send, const CAPACITY: usize> Producer<T> for SPSCProducer<T, CAPACITY>

fn capacity(&self) -> usize

Returns the capacity of the queue.

fn len(&self) -> usize

Returns the length of the queue.

fn maybe_push(&self, value: T) -> Result<(), T>

Pushes a value only if the queue is not full. It returns an error if the queue is full.

fn is_empty(&self) -> bool

Returns whether the queue is empty.

fn free_slots(&self) -> usize

Returns the number of free slots in the queue.

impl<T: Send, const CAPACITY: usize> SingleLockFreeProducer<T> for SPSCProducer<T, CAPACITY>

unsafe fn lock_free_maybe_push_many( &self, slice: &[T], ) -> Result<(), LockFreePushManyErr>

Pushes multiple values into the queue or returns an Err(LockFreePushManyErr).

impl<T: Send, const CAPACITY: usize> SingleProducer<T> for SPSCProducer<T, CAPACITY>

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

Pushes multiple values into the queue. It accepts two slices to allow using it for ring-based queues.

unsafe fn maybe_push_many(&self, slice: &[T]) -> Result<(), ()>

Pushes multiple values into the queue or returns an error if the queue doesn’t have enough space.

unsafe fn copy_and_commit_if<F, FSuccess, FError>( &self, right: &[T], left: &[T], f: F, ) -> Result<FSuccess, FError>

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

Copies values, calls the provided function and commits the values if the function returns true. It returns an error if the function returns an error and doesn’t commit the values (caller must ensure that their destructors are called).

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