Struct CommandQueue 

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

Неблокирующая bounded очередь команд

Пример

use rill_core::queues::CommandQueue;

let queue = CommandQueue::<i32>::new("test", 16);
queue.send(42).unwrap();
assert_eq!(queue.try_recv(), Ok(42));

Implementations

impl<T: Send + 'static> CommandQueue<T>

pub fn new(name: &str, capacity: usize) -> Self

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

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

Отправить команду (из control thread)

pub fn try_recv(&self) -> Result<T, QueueError>

Попытаться получить команду (из signal thread)

pub fn sender(&self) -> Sender<T>

Получить отправителя

pub fn receiver(&self) -> Receiver<T>

Получить получателя

pub fn name(&self) -> &str

Имя очереди

pub fn capacity(&self) -> usize

Ёмкость

pub fn len(&self) -> usize

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

pub fn is_empty(&self) -> bool

Пуста ли

Trait Implementations

impl<T> Clone for CommandQueue<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: Debug + Send + 'static> Debug for CommandQueue<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl TelemetryQueueExt for CommandQueue<Telemetry>

fn send_parameter( &self, port: PortId, parameter: ParameterId, value: f32, ) -> Result<(), QueueError>

fn send_audio( &self, node_id: NodeId, channel: usize, data: Vec<f32>, ) -> Result<(), QueueError>

fn send_audio_with_sample_rate( &self, node_id: NodeId, channel: usize, data: Vec<f32>, sample_rate: f32, ) -> Result<(), QueueError>

fn send_peak(&self, port: PortId, value: f32) -> Result<(), QueueError>

fn send_peak_with_hold( &self, port: PortId, value: f32, hold_time_ms: u32, ) -> Result<(), QueueError>

fn send_event( &self, source: &str, kind: &str, data: Vec<f32>, ) -> Result<(), QueueError>

fn send_event_with_description( &self, source: &str, kind: &str, data: Vec<f32>, description: &str, ) -> Result<(), QueueError>

fn send_violation( &self, component: &str, expected_ns: u64, actual_ns: u64, value: Option<f32>, ) -> Result<(), QueueError>