Struct concurrency_traits::semaphore::ParkSemaphore

pub struct ParkSemaphore<C, CS> where
    CS: ThreadParker,  { /* fields omitted */ }

A semaphore based on thread parking

Implementations

impl<C, CS> ParkSemaphore<C, CS> where
    CS: ThreadParker, 

pub fn new(start_count: C) -> Self

Creates a new ParkSemaphore from a start_count.

Trait Implementations

impl<C: Debug, CS: Debug> Debug for ParkSemaphore<C, CS> where
    CS: ThreadParker, 

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

Formats the value using the given formatter.

impl<C, CS> Default for ParkSemaphore<C, CS> where
    C: Zero,
    CS: ThreadParker, 

fn default() -> Self

Returns the “default value” for a type.

impl<C, CS> ReadoutSemaphore for ParkSemaphore<C, CS> where
    C: Zero + One + AddAssign + SubAssign + Copy,
    CS: ThreadParker + 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> Semaphore for ParkSemaphore<C, CS> where
    C: Zero + One + AddAssign + SubAssign,
    CS: ThreadParker + ThreadFunctions, 

fn wait(&self)

Decrements the count if able or blocks until able.

impl<C, CS> TimeoutSemaphore for ParkSemaphore<C, CS> where
    C: Zero + One + AddAssign + SubAssign,
    CS: ThreadTimeoutParker + TimeFunctions + ThreadFunctions, 

fn wait_timeout(&self, timeout: Duration) -> bool

Blocks until can decrement or times out. Then returns true if decremented or false if timed out.

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

fn try_wait(&self) -> bool

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

fn signal(&self)

Increments the counter.