Struct MpMcQueue

pub struct MpMcQueue<T, const N: usize> { /* private fields */ }

MPMC queue with a capacity for N elements N must be a power of 2 The max value of N is u8::MAX - 1 if mpmc_large feature is not enabled.

Implementations

impl<T, const N: usize> MpMcQueue<T, N>

pub const fn new() -> Self

Creates an empty queue

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

Returns the item in the front of the queue, or None if the queue is empty

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

Adds an item to the end of the queue

Returns back the item if the queue is full

Trait Implementations

impl<T, const N: usize> Default for MpMcQueue<T, N>

fn default() -> Self

Returns the “default value” for a type.

impl<T, const N: usize> Sync for MpMcQueue<T, N>

where T: Send,