Struct concurrency_traits::queue::ParkQueue

pub struct ParkQueue<T, CS> where
    CS: ThreadParker,  { /* fields omitted */ }

A queue based on VecDeques and parking.

Trait Implementations

impl<T: Debug, CS: Debug> Debug for ParkQueue<T, CS> where
    CS: ThreadParker, 

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

Formats the value using the given formatter.

impl<T, CS> Default for ParkQueue<T, CS> where
    CS: ThreadParker, 

fn default() -> Self

Returns the “default value” for a type.

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

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

impl<T, CS> TimeoutQueue for ParkQueue<T, CS> where
    CS: ThreadTimeoutParker + ThreadFunctions + TimeFunctions,
    CS::ThreadId: Clone, 

fn push_timeout(
    &self,
    value: Self::Item,
    _timeout: Duration
) -> Result<(), Self::Item>

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

fn pop_timeout(&self, timeout: Duration) -> Option<Self::Item>

Blocks until an item is received from the queue or timeout

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

type Item = T

The type the queue holds.

fn try_push(&self, value: Self::Item) -> Result<(), Self::Item>

Tries to append an item to the queue returning None if unsuccessful

fn try_pop(&self) -> Option<Self::Item>

Tries to receive an item from the queue returning None if none available