Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

A thread pool for executing blocking operations.

The pool can be configured as either bounded or unbounded, which determines how tasks are handled when all worker threads are busy.

The number of worker threads scales dynamically with load, but will never exceed the thread_limit parameter. When all worker threads are busy, tasks are queued until a worker thread becomes available.

Implementations

impl ThreadPool

pub fn new( name: &str, thread_limit: usize, recv_timeout: Duration, ) -> ThreadPool

Creates a ThreadPool with a maximum number of worker threads and a timeout for receiving tasks from the task channel.

A thread_limit of zero is treated as one.

pub fn execute<F, R>(&self, f: F) -> BlockingResult<R>

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

Submits a closure to the thread pool.

The task will be executed by an available worker thread. If no threads are available and the pool has reached its maximum size, the work will be queued until a worker thread becomes available. This method never blocks.

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 Debug for ThreadPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.