Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Fixed-size thread pool with bounded FIFO task queue.

Uses crossbeam-channel for lock-free multi-consumer dispatch — each worker calls recv() directly, no mutex.

Implementations

impl WorkerPool

pub fn new(size: usize) -> Self

Create a pool with size worker threads and bounded channel. Channel capacity = 4 × size (provides backpressure without starving).

pub fn default_size() -> Self

Create a pool sized to the machine’s parallelism, clamped [2, 18].

pub fn submit<F>(&self, f: F)

where F: FnOnce() + Send + 'static,

Submit a task to the pool. Blocks if the queue is full (backpressure). Panics if the pool has been shut down.

pub fn submit_with_result<F, R>(&self, f: F) -> Receiver<R>

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

Submit a task and get a receiver for its result.

pub fn cancel(&self)

Signal all workers to drop pending tasks. Already-running tasks will finish, but queued tasks are skipped. Reset with reset_cancel().

pub fn reset_cancel(&self)

Clear the cancellation flag — pool resumes normal execution.

pub fn size(&self) -> usize

Number of worker threads.

pub fn queue_depth(&self) -> usize

Approximate number of tasks waiting in the queue.

pub fn completed(&self) -> usize

Total tasks completed since pool creation.

Trait Implementations

impl Drop for WorkerPool

fn drop(&mut self)

Executes the destructor for this type.