Struct BoundedWorkers 

pub struct BoundedWorkers<State> { /* private fields */ }

Each worker retains one state. All workers dequeue from the same bounded channel, so work is never stranded behind a busy worker’s private queue.

Implementations

impl<State: Send + 'static> BoundedWorkers<State>

pub fn start( states: Vec<State>, capacity: NonZeroUsize, name: &str, ) -> Result<Self>

Start all workers before returning a capability that can admit work.

pub async fn call<F, R>(&self, operation: F) -> R

where F: FnOnce(&mut State) -> R + Send + 'static, R: Send + 'static,

Wait for bounded admission and completion. Cancelling before execution discards the closure; running work finishes, but its reply is discarded. A closure panic resumes on the caller and leaves the worker available.

Trait Implementations

impl<State> Clone for BoundedWorkers<State>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.