Struct MpmcChannel 

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

Multi-Producer Multi-Consumer channel with bounded capacity Uses mutex-based implementation for simplicity and correctness.

The shared state lives directly in this struct rather than behind a field per Arc: MpmcSender/MpmcReceiver already share one handle through Arc<MpmcChannel<T>>, so a channel costs one allocation plus the bounded ring’s slot array. Every operation reaches the mutex, condvars, both waiter counters and the ring through that single handle, with no second indirection on the send/receive paths.

Implementations

impl<T> MpmcChannel<T>

pub fn new(capacity: Option<usize>) -> MpmcChannel<T>

Create a new MPMC channel with optional capacity

pub fn unbounded() -> MpmcChannel<T>

Create an unbounded channel

pub fn bounded(capacity: usize) -> MpmcChannel<T>

Create a bounded channel with given capacity

pub fn channel(capacity: Option<usize>) -> (MpmcSender<T>, MpmcReceiver<T>)

Create a channel pair for ergonomic usage

Trait Implementations

impl<T> Channel<T> for MpmcChannel<T>

where T: Send,

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

Send a value, blocking if necessary

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

Try to send without blocking

fn recv(&self) -> Result<T, ChannelError>

Receive a value, blocking if necessary

fn try_recv(&self) -> Result<T, ChannelError>

Try to receive without blocking

fn is_empty(&self) -> bool

Check if channel is empty

fn is_full(&self) -> bool

Check if channel is full

fn capacity(&self) -> Option<usize>

Get the capacity of the channel

fn send_batch(&self, values: Vec<T>) -> Result<usize, ChannelError>

Send multiple values in batch. Default sends each individually.

fn recv_batch(&self, max_count: usize) -> Vec<T>

Receive up to max_count values in batch. Default receives individually.

fn close(&self)

Close the channel. Default: no-op (channels that support close override).

fn is_closed(&self) -> bool

Check if channel is closed. Default: false.

fn len(&self) -> usize

Current number of buffered items. Default: 0.

fn stats(&self) -> Option<ChannelStatistics>

Return statistics if the channel tracks them.

impl<T> Consumer<T> for MpmcChannel<T>

where T: Send,

fn recv(&self) -> Result<T, ChannelError>

Receive a value, blocking until one arrives.

fn try_recv(&self) -> Result<T, ChannelError>

Receive a value, or report ChannelError::Empty rather than waiting.

fn is_empty(&self) -> bool

Whether a receive would have to wait.

impl<T> Producer<T> for MpmcChannel<T>

where T: Send,

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

Send a value, blocking until there is room.

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

Send a value, or report ChannelError::Full rather than waiting.

fn is_full(&self) -> bool

Whether a further send would have to wait.

fn capacity(&self) -> Option<usize>

Bounded capacity, or None when the channel is unbounded.