Trait LockFreeProducer 

pub trait LockFreeProducer<T>: Producer<T> {
    // Required method
    fn lock_free_maybe_push(&self, value: T) -> Result<(), LockFreePushErr<T>>;
}

A lock-free producer of a queue.

Required Methods

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).

It is lock-free. If you can lock, you can look at the Producer::maybe_push method because if it is implemented not as lock-free, it should have better performance.

Implementors

impl<T, const CAPACITY: usize, AtomicWrapper> LockFreeProducer<T> for MPMCBoundedQueue<T, CAPACITY, AtomicWrapper>

where AtomicWrapper: Deref<Target = LongAtomic> + Default,

impl<T: Send, SC> LockFreeProducer<T> for CachePaddedSPMCUnboundedProducer<T, SC>

where SC: SyncCell<LightArc<Version<T>>> + LockFreeSyncCell<LightArc<Version<T>>>,

impl<T: Send, SC> LockFreeProducer<T> for SPMCUnboundedProducer<T, SC>

where SC: SyncCell<LightArc<Version<T>>> + LockFreeSyncCell<LightArc<Version<T>>>,

impl<T: Send, SC> LockFreeProducer<T> for CachePaddedSPSCUnboundedProducer<T, SC>

where SC: SyncCell<LightArc<Version<T>>> + LockFreeSyncCell<LightArc<Version<T>>>,

impl<T: Send, SC> LockFreeProducer<T> for SPSCUnboundedProducer<T, SC>

where SC: SyncCell<LightArc<Version<T>>> + LockFreeSyncCell<LightArc<Version<T>>>,

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

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

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

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

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

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