Struct RtQueue 

pub struct RtQueue<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: Copy + Default + Send + 'static> RtQueue<T>

pub fn new(capacity: usize) -> Self

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

pub fn new_spsc() -> Self

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

pub fn new_mpsc(capacity: usize) -> Self

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

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

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

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: Copy> Clone for RtQueue<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Copy + Send> Send for RtQueue<T>

impl<T: Copy + Sync> Sync for RtQueue<T>