Struct Semaphore 

pub struct Semaphore { /* private fields */ }

A counting semaphore for limiting concurrent access.

Implementations

impl Semaphore

pub fn new(permits: usize) -> Self

Creates a new semaphore with the given number of permits.

pub fn available_permits(&self) -> usize

Returns the number of currently available permits.

pub fn max_permits(&self) -> usize

Returns the maximum number of permits (initial count).

pub fn is_closed(&self) -> bool

Returns true if the semaphore is closed.

pub fn close(&self)

Closes the semaphore.

pub fn acquire<'a, 'b>( &'a self, cx: &'b Cx, count: usize, ) -> AcquireFuture<'a, 'b>

Acquires the given number of permits asynchronously.

pub fn try_acquire( &self, count: usize, ) -> Result<SemaphorePermit<'_>, TryAcquireError>

Tries to acquire the given number of permits without waiting.

pub fn add_permits(&self, count: usize)

Adds permits back to the semaphore.

Saturates at usize::MAX if adding would overflow.

Trait Implementations

impl Debug for Semaphore

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

Formats the value using the given formatter.