Struct async_stm::queues::tbqueue::TBQueue

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

Bounded queue using two vectors.

Similar to [TQueue] but every read and write touches a common TVar to track the current capacity, retrying if the queue is full.

Implementations

impl<T> TBQueue<T>where T: Any + Sync + Send + Clone,

pub fn new(capacity: u32) -> TBQueue<T>

Create an empty TBQueue.

Trait Implementations

impl<T: Clone> Clone for TBQueue<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> TQueueLike<T> for TBQueue<T>where T: Any + Sync + Send + Clone,

fn write(&self, value: T) -> Stm<()>

Push to the end of the queue.

fn read(&self) -> Stm<T>

Pop the head of the queue, or retry until there is an element if it’s empty.

fn is_empty(&self) -> Stm<bool>

Check if the queue is empty.