Struct mpmc_ringbuf::core::MsgQueue

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

main struct for controlling buffer blocks Users should crate a new buffer block with fn add_producer, and explicitly delete the buffer blocks with fn delete_consumer If users want to add a producer and produce some data, make sure you call fn add_producer ahead, otherwise there are none data block for storing the data.

Implementations

impl<T> MsgQueue<T>where
    T: Default + Clone,

pub fn new() -> MsgQueue<T>

pub fn add_producer(&mut self) -> MsgQueueWriter<T>

pub fn get_consumer(&mut self, id: u64) -> MsgQueueReader<T>

pub fn add_consumer(&mut self) -> MsgQueueReader<T>

pub fn get_consumer_count(&self) -> u64

pub fn delete_consumer(&mut self, id: u64)

Trait Implementations

impl<T> Send for MsgQueue<T>

impl<T> Sync for MsgQueue<T>