Struct SemaphoreQueue 

pub struct SemaphoreQueue<S: SemaphoreState<Params = Params, Permit = Permit> + ?Sized, C: IsCloseable, Params = <S as SemaphoreState>::Params, Permit = <S as SemaphoreState>::Permit> { /* private fields */ }

A queue that manages the acquisition of permits from a SemaphoreState, or queues tasks if no permits are available.

Implementations

impl<S: SemaphoreState + ?Sized, C: IsCloseable> SemaphoreQueue<S, C>

pub fn acquire<R: RawMutex>( this: &Mutex<R, Self>, params: S::Params, order: FairOrder, ) -> Acquire<'_, S, C, R>

Acquire a permit, or join the queue if not currently available.

• If the order is FairOrder::Lifo, then we enqueue at the front of the queue.
• If the order is FairOrder::Fifo, then we enqueue at the back of the queue.

pub fn try_acquire( &mut self, params: S::Params, fairness: Fairness, ) -> Result<S::Permit, TryAcquireError<S::Params, C>>

Try acquire a permit without joining the queue.

• If the fairness is Fairness::Unfair, or Fairness::Fair(FairOrder::Lifo), then we always try acquire a permit.
• If the fairness is Fairness::Fair(FairOrder::Fifo), then we only try acquire a permit if the queue is empty.

Errors

If there are currently not enough permits available for the given request, then TryAcquireError::NoPermits is returned.

If this is a Fairness::Fair(FairOrder::Fifo) semaphore queue, and there are other tasks waiting for permits, then TryAcquireError::NoPermits is returned.

If this semaphore is_closed, then TryAcquireError::Closed is returned.

impl<S: SemaphoreState, C: IsCloseable> SemaphoreQueue<S, C>

pub fn new(state: S) -> Self

Construct a new semaphore queue, with the given SemaphoreState.

impl<S: SemaphoreState + ?Sized, C: IsCloseable> SemaphoreQueue<S, C>

pub fn with_state<T>(&mut self, f: impl FnOnce(&mut S) -> T) -> T

Access the state with mutable access.

This gives direct access to the state, be careful not to break any of your own state invariants. You can use this to peek at the current state, or to modify it, eg to add or remove permits from the semaphore.

pub fn is_closed(&self) -> bool

Check if the queue is closed

impl<S: SemaphoreState + ?Sized> SemaphoreQueue<S, Closeable>

pub fn close(&mut self)

Close the semaphore queue.

All tasks currently waiting to acquire a token will immediately stop. No new acquire attempts will succeed.

Trait Implementations

impl<S: SemaphoreState + Debug, C: IsCloseable> Debug for SemaphoreQueue<S, C>

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

Formats the value using the given formatter.