Struct MpscQueue 

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

Multiple-Producer Single-Consumer очередь

Реализована как lock-free очередь Майкла-Скотта. Производители никогда не блокируются, потребитель может ждать появления данных.

Implementations

impl<T> MpscQueue<T>

pub fn new() -> Self

Создать новую очередь

pub fn with_capacity(capacity: usize) -> Self

Создать очередь с ограниченной ёмкостью

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

Добавить элемент (может вызываться из нескольких потоков)

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

Извлечь элемент (только consumer)

pub fn size(&self) -> usize

Текущий размер (приблизительный)

pub fn capacity(&self) -> usize

Вместимость (0 = неограничена)

pub fn is_empty(&self) -> bool

Проверить, пуста ли очередь

Trait Implementations

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>