Struct MpscQueue 

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

Multiple-Producer Single-Consumer queue

Implemented as a Michael-Scott lock-free queue. Producers never block, the consumer can wait for data.

Implementations

impl<T> MpscQueue<T>

pub fn new() -> Self

Create a new queue

pub fn with_capacity(capacity: usize) -> Self

Create a queue with a limited capacity

pub fn push(&self, value: T) -> QueueResult<()>

Push an element (can be called from multiple threads)

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

Pop an element (consumer only)

pub fn size(&self) -> usize

Current size (approximate)

pub fn capacity(&self) -> usize

Capacity (0 = unlimited)

pub fn is_empty(&self) -> bool

Check if the queue is empty

Trait Implementations

impl<T> Default for MpscQueue<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Drop for MpscQueue<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send> Send for MpscQueue<T>

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