Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

A bounded pool of named worker threads, grown on demand, plus a single timer thread for Executor::wake_at.

Workers and the timer thread live as long as the process; the pool is meant to be created once per host, not per service.

Implementations

impl ThreadPool

pub fn new(max_threads: usize) -> ThreadPool

A pool that runs at most max_threads jobs at once (at least one).

pub fn default_threads() -> usize

Jobs are mostly blocking I/O (fetches, transport calls), so the default allows more workers than a CPU-bound pool would.

Trait Implementations

impl Clone for ThreadPool

fn clone(&self) -> ThreadPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Executor for ThreadPool

fn spawn( &self, name: &'static str, job: Box<dyn FnOnce() + Send>, ) -> Result<(), Unsupported>

Run job off the calling thread. name identifies the work in logs.

fn wake_at(&self, deadline: Instant, wake: WakeHandle)

Call WakeHandle::wake on wake once now reaches deadline. A deadline already in the past wakes promptly.

fn park(&self, deadline: Instant)

Block until background work may have made progress, or until deadline. For synchronous drivers only (headless capture, tests) — never call this on a live UI thread.

fn now(&self) -> Instant

This executor’s clock. Deadlines passed to wake_at are measured against it.