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.