Struct MpmcQueue 

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

Lock-free unbounded MPMC (Multi Producer Multi Consumer) queue Suitable for work-stealing and task distribution

Implementations

impl<T> MpmcQueue<T>

pub fn new() -> Self

Create a new unbounded MPMC queue

pub fn push(&self, item: T)

Push an item to the queue

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

Try to pop an item from the queue

pub fn len(&self) -> usize

Get approximate length

pub fn is_empty(&self) -> bool

Check if the queue is empty

Trait Implementations

impl<T: Debug> Debug for MpmcQueue<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for MpmcQueue<T>

fn default() -> Self

Returns the “default value” for a type.