Struct LockFreeQueue 

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

A high-performance bounded MPMC queue using crossbeam-channel

This queue is optimized for producer-consumer patterns common in streaming:

• Network receive -> Message processing
• Message batching -> Disk write
• Raft log append -> Replication

Implementations

impl<T> LockFreeQueue<T>

pub fn bounded(capacity: usize) -> Self

Create a new bounded queue

pub fn unbounded() -> Self

Create a new unbounded queue (use with caution)

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

Try to enqueue an item without blocking

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

Blocking enqueue

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

Try to dequeue an item without blocking

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

Blocking dequeue

pub fn pop_batch(&self, max: usize) -> Vec<T>

Try to dequeue up to max items

pub fn len(&self) -> usize

Get approximate queue length

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn capacity(&self) -> usize

Get queue capacity

pub fn fill_ratio(&self) -> f64

Get fill percentage (0.0 - 1.0)

pub fn stats(&self) -> QueueStats

Get statistics