Trait concurrency_traits::queue::Queue

pub trait Queue: TryQueue {
    fn push(&self, value: Self::Item);
    fn pop(&self) -> Self::Item;
}

A generic queue that can push and pop in FIFO order

Required methods

fn push(&self, value: Self::Item)

Appends an item to the end of the queue blocking until appended

fn pop(&self) -> Self::Item

Blocks until an item is received from the queue

Implementors

impl<T, CS> Queue for ParkQueue<T, CS> where
    CS: ThreadParker + ThreadFunctions,
    CS::ThreadId: Clone, 

fn push(&self, value: Self::Item)

fn pop(&self) -> Self::Item

impl<T, S, CS> Queue for SemaphoreQueue<T, S, CS> where
    S: Semaphore,
    CS: ThreadFunctions, 

fn push(&self, value: Self::Item)

fn pop(&self) -> Self::Item