Struct TaskPool 

pub struct TaskPool { /* private fields */ }

A fixed-size pool of worker threads driving an unbounded set of suspended tasks.

Implementations

impl TaskPool

pub fn new(n_workers: usize) -> Self

Build a pool with n_workers threads (clamped to at least 1).

pub fn worker_count(&self) -> usize

Number of worker threads in the pool.

pub fn spawn(&self, future: impl Future<Output = ()> + Send + 'static)

Spawn a future. It runs to completion on the pool, suspending (off-thread) whenever it awaits, with no thread dedicated to it.

pub fn shutdown(self)

Stop the workers once the current ready queue drains. Joins all threads. Call after the work you spawned has completed.

The flag is set while holding the queue lock, which is what makes a worker’s check-then-park atomic against it: a worker between the two holds that lock, so this store waits for it to park before the notify goes out.