Struct Semaphore 

pub struct Semaphore<const MAX: u8> { /* private fields */ }

An async counting semaphore.

static SEM: rivet::sync::Semaphore<1> = rivet::sync::Semaphore::new(0);

#[rivet::task(priority = 1)]
async fn waiter() {
    loop {
        SEM.acquire().await;
        // got the semaphore
    }
}

// ISR or another task:
fn signaler() {
    SEM.release();
}

Implementations

impl<const MAX: u8> Semaphore<MAX>

pub const fn new(initial: u8) -> Self

Create a new semaphore with the given initial count.

pub fn try_acquire(&self) -> bool

Try to acquire without blocking. Returns true if acquired.

pub fn acquire(&self) -> Acquire<'_, MAX>

Acquire the semaphore, yielding the task if it’s currently taken.

Panics

Panics if polled outside of a task context (i.e. not from within the executor’s poll of a #[rivet::task]).

pub fn release(&self)

Release the semaphore. If tasks are waiting, the highest-priority one is woken and handed the token directly. Safe to call from ISR context.

Trait Implementations

impl<const MAX: u8> Sync for Semaphore<MAX>