Trait RtQueueBase 

pub trait RtQueueBase<T>: Send + Sync {
    // Required methods
    fn push(&self, value: T) -> QueueResult<()>;
    fn pop(&self) -> Option<T>;
    fn len(&self) -> usize;
    fn capacity(&self) -> usize;
    fn clear(&self);

    // Provided methods
    fn is_empty(&self) -> bool { ... }
    fn is_full(&self) -> bool { ... }
}

Базовый трейт для всех очередей, безопасных для реального времени

Все реализации должны быть:

• Lock-free (никаких мьютексов)
• RT-safe (без аллокаций, без блокировок)

Required Methods

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

Добавить элемент в очередь

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

Извлечь элемент из очереди

fn len(&self) -> usize

Текущий размер очереди

fn capacity(&self) -> usize

Вместимость очереди

fn clear(&self)

Очистить очередь

Provided Methods

fn is_empty(&self) -> bool

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

fn is_full(&self) -> bool

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

Implementors

impl<T: Copy + Default + Send + Sync, const CAP: usize> RtQueueBase<T> for SpscQueue<T, CAP>