Struct tokio_sync::semaphore::Semaphore

pub struct Semaphore { /* fields omitted */ }

Futures-aware semaphore.

Implementations

impl Semaphore

pub fn new(permits: usize) -> Semaphore

Creates a new semaphore with the initial number of permits

Panics

Panics if permits is zero.

pub fn available_permits(&self) -> usize

Returns the current number of available permits

pub fn close(&self)

Close the semaphore. This prevents the semaphore from issuing new permits and notifies all pending waiters.

pub fn add_permits(&self, n: usize)

Add n new permits to the semaphore.

Trait Implementations

impl Debug for Semaphore

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

Formats the value using the given formatter.

impl Send for Semaphore

impl Sync for Semaphore