Struct async_stm::queues::tvecdequeue::TVecDequeue

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

Unbounded queue backed by a single VecDequeue.

The drawback is that reads and writes both touch the same TVar.

Implementations

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

pub fn new() -> TVecDequeue<T>

Create an empty TVecDequeue.

Trait Implementations

impl<T: Clone> Clone for TVecDequeue<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Any + Send + Sync + Clone> Default for TVecDequeue<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> TQueueLike<T> for TVecDequeue<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.