Struct BlockingSemaphore 

pub struct BlockingSemaphore { /* private fields */ }

Cross-process semaphore with a kernel-park slow path.

Implementations

impl BlockingSemaphore

pub fn create( base_path: impl AsRef<Path>, max_permits: u32, init_permits: u32, ) -> Result<Self, BlockingSemaphoreError>

Create a new blocking semaphore. Lays out the underlying SharedSemaphore files plus a <base>.waker.bin for the waker. Caller picks max_permits (capacity) and init_permits (starting value); see SharedSemaphore::create for semantics.

pub fn open( base_path: impl AsRef<Path>, expected_max_permits: u32, ) -> Result<Self, BlockingSemaphoreError>

Open an existing blocking semaphore.

pub fn try_acquire(&self) -> Result<BlockingPermit<'_>, BlockingSemaphoreError>

Non-blocking acquire. Pure CAS; never sleeps.

pub fn acquire_park(&self) -> Result<BlockingPermit<'_>, BlockingSemaphoreError>

Blocking acquire with kernel-park slow path. Returns when a permit is available. No timeout variant returns Err(Timeout); for a bounded wait use acquire_park_timeout.

pub fn acquire_park_timeout( &self, timeout: Duration, ) -> Result<BlockingPermit<'_>, BlockingSemaphoreError>

Blocking acquire with bounded wait. Err(Timeout) when the timeout elapses before a permit is available.

pub fn release(&self) -> Result<(), BlockingSemaphoreError>

Release one permit. Bumps the inner generation atom and fires wake_up_to(new_gen) on the waker.

pub fn available(&self) -> u32

Available-permits observation (may race).

pub fn max_permits(&self) -> u32

Cap fixed at construction.

pub fn inner(&self) -> &Arc<SharedSemaphore>

Inner primitive (for sidecar / observability hooks).