Struct embassy_sync::semaphore::GreedySemaphore

pub struct GreedySemaphore<M: RawMutex> { /* private fields */ }

A greedy Semaphore implementation.

Tasks can acquire permits as soon as they become available, even if another task is waiting on a larger number of permits.

Implementations

impl<M: RawMutex> GreedySemaphore<M>

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

Create a new Semaphore.

Trait Implementations

impl<M: RawMutex> Default for GreedySemaphore<M>

fn default() -> Self

Returns the “default value” for a type.

impl<M: RawMutex> Semaphore for GreedySemaphore<M>

type Error = Infallible

The error returned when the semaphore is unable to acquire the requested permits.

async fn acquire( &self, permits: usize, ) -> Result<SemaphoreReleaser<'_, Self>, Self::Error>

Asynchronously acquire one or more permits from the semaphore.

fn try_acquire(&self, permits: usize) -> Option<SemaphoreReleaser<'_, Self>>

Try to immediately acquire one or more permits from the semaphore.

async fn acquire_all( &self, min: usize, ) -> Result<SemaphoreReleaser<'_, Self>, Self::Error>

Asynchronously acquire all permits controlled by the semaphore.

fn try_acquire_all(&self, min: usize) -> Option<SemaphoreReleaser<'_, Self>>

Try to immediately acquire all available permits from the semaphore, if at least min permits are available.

fn release(&self, permits: usize)

Release permits back to the semaphore, making them available to be acquired.

fn set(&self, permits: usize)

Reset the number of available permints in the semaphore to permits.