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.

• In a bounded pool, submitting a task will fail if the number of concurrent operations has reached the thread limit.
• In an unbounded pool, tasks are queued and will wait until a worker thread becomes available.

The number of worker threads scales dynamically with load, but will never exceed the thread_limit parameter.

Implementations

impl ThreadPool

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

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

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

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

Submits a task (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 behavior depends on the boundedness configuration:

• For a bounded pool, the function returns an error.
• For an unbounded pool, the task is queued and executed when a worker becomes available.

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

Formats the value using the given formatter.