Struct concurrency_traits::semaphore::FullAsyncSemaphore

pub struct FullAsyncSemaphore<C, CS> { /* fields omitted */ }

A semaphore that has asynchronous operations.

Implementations

impl<C, CS> FullAsyncSemaphore<C, CS>

pub fn new(start_count: C) -> Self

Creates a new FullAsyncSemaphore from a starting count.

Trait Implementations

impl<C, CS> AsyncSemaphore for FullAsyncSemaphore<C, CS> where
    C: Zero + One + AddAssign + SubAssign + Send,
    CS: ThreadFunctions, 

fn wait_async<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Awaits until able to decrement then decrements.

impl<C: Debug, CS: Debug> Debug for FullAsyncSemaphore<C, CS>

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

Formats the value using the given formatter.

impl<C, CS> Default for FullAsyncSemaphore<C, CS> where
    C: Zero, 

fn default() -> Self

Returns the “default value” for a type.

impl<C, CS> ReadoutSemaphore for FullAsyncSemaphore<C, CS> where
    C: Zero + One + AddAssign + SubAssign + Copy,
    CS: ThreadFunctions, 

type Count = C

The type of the count read from this semaphore.

fn count(&self) -> Self::Count

The count associated with this semaphore.

impl<C, CS> TrySemaphore for FullAsyncSemaphore<C, CS> where
    C: Zero + One + AddAssign + SubAssign,
    CS: ThreadFunctions, 

fn try_wait(&self) -> bool

Returns true if can decrement and did, or false if cannot.

fn signal(&self)

Increments the counter.