Struct MpscQueue 

pub struct MpscQueue { /* private fields */ }

Multi-producer single-consumer lock-free queue.

This variant allows multiple producers (e.g., multiple host threads or kernel-to-kernel messaging) to enqueue messages concurrently.

Implementations

impl MpscQueue

pub fn new(capacity: usize) -> MpscQueue

Create a new MPSC queue.

Trait Implementations

impl MessageQueue for MpscQueue

fn capacity(&self) -> usize

Get the queue capacity.

fn len(&self) -> usize

Get current queue size.

fn try_enqueue(&self, envelope: MessageEnvelope) -> Result<(), RingKernelError>

Try to enqueue a message envelope.

fn try_dequeue(&self) -> Result<MessageEnvelope, RingKernelError>

Try to dequeue a message envelope.

fn stats(&self) -> QueueStats

Get queue statistics.

fn reset_stats(&self)

Reset queue statistics.

fn is_empty(&self) -> bool

Check if queue is empty.

fn is_full(&self) -> bool

Check if queue is full.