Struct Semaphore 

pub struct Semaphore { /* private fields */ }

Counting semaphore built on Mutex + Condvar so blocked acquirers park in the kernel rather than spinning on an atomic.

Replaces the prior pattern in pipeline::chunked::exec:

while atomic.load(Relaxed) >= max { thread::sleep(50ms); }
atomic.fetch_add(1, Relaxed);

which polled 20 times/sec per blocked worker. Under N parallel chunks and a long-running export this burned ~N × 20 wake-ups per second doing nothing.

With Condvar::wait, blocked threads consume zero CPU until a release() notifies. The mutex is uncontended whenever traffic is light, so the lock path adds no measurable overhead vs the atomic.

Implementations

impl Semaphore

pub fn new(max: usize) -> Self

pub fn acquire(&self)

Block until a permit is available, then take one.

pub fn release(&self)

Return a permit and wake one blocked acquirer (if any).