Struct MpmcRing 

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

Multi-producer multi-consumer ring buffer (Vyukov bounded MPMC queue).

Uses per-slot sequence counters to synchronize producers and consumers. A producer may only write a slot once its sequence matches the expected head value, and a consumer may only read once the sequence shows the write is complete. This eliminates the race where a consumer observes an advanced head but the slot has not been written yet.

Implementations

impl<T: Copy> MpmcRing<T>

pub fn new(capacity: usize) -> Self

Creates a new MPMC ring buffer.

pub const fn capacity(&self) -> usize

Returns the capacity.

pub fn len(&self) -> usize

Returns the approximate length.

pub fn is_empty(&self) -> bool

Returns true if approximately empty.

pub fn enqueue(&self, item: T) -> Result<(), T>

Enqueues an item (Vyukov bounded MPMC algorithm).

Returns Err(item) if the queue is full.

pub fn dequeue(&self) -> Option<T>

Dequeues an item (Vyukov bounded MPMC algorithm).

Returns None if the queue is empty.

Trait Implementations

impl<T: Send> Send for MpmcRing<T>

impl<T: Send> Sync for MpmcRing<T>