Struct RtQueue 

pub struct RtQueue<T>
where
    T: Copy,
{ /* private fields */ }

Главная RT-safe очередь

Пример

use rill_core::queues::RtQueue;

// Создаём очередь для команд
let queue = RtQueue::<i32>::new(1024);

// Поток управления (soft RT)
queue.push(42).unwrap();

// Аудиопоток (hard RT)
if let Some(cmd) = queue.pop() {
    println!("Got command: {}", cmd);
}

Implementations

impl<T> RtQueue<T>

where T: Copy + Default + Send + 'static,

pub fn new(capacity: usize) -> RtQueue<T>

Создать новую очередь с фиксированным размером

pub fn new_spsc() -> RtQueue<T>

Создать очередь для одного производителя

pub fn new_mpsc(capacity: usize) -> RtQueue<T>

Создать очередь для многих производителей

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

Добавить элемент (из потока управления)

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

Извлечь элемент (из аудиопотока)

pub fn len(&self) -> usize

Текущий размер

pub fn capacity(&self) -> usize

Вместимость

pub fn is_empty(&self) -> bool

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

pub fn stats(&self) -> QueueStatsSnapshot

Получить статистику

Trait Implementations

impl<T> Clone for RtQueue<T>

where T: Copy,

fn clone(&self) -> RtQueue<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Send for RtQueue<T>

where T: Copy + Send,

impl<T> Sync for RtQueue<T>

where T: Copy + Sync,