Struct PrioritySemaphore

pub struct PrioritySemaphore { /* private fields */ }

Async-aware priority semaphore.

Implementations

impl PrioritySemaphore

pub const fn new(permits: usize) -> Self

Create new semaphore with given maximum concurrent permits.

pub fn acquire(self: &Arc<Self>, prio: Priority) -> AcquireFuture

Async acquire (cancellation-safe).

pub fn try_acquire( self: &Arc<Self>, _prio: Priority, ) -> Result<Permit, TryAcquireError>

Try immediate acquire.

pub fn close(&self)

Close the semaphore: further acquires fail.

pub fn available_permits(&self) -> usize

Number of currently available permits.

pub fn queued(&self) -> usize

Number of tasks waiting in the queue.

Trait Implementations

impl Debug for PrioritySemaphore

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

Formats the value using the given formatter.