Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

A thread pool that can execute tasks concurrently.

Manages a collection of worker threads and provides methods to submit tasks for execution.

Returns

• ThreadPool - A new thread pool instance.

Implementations

impl ThreadPool

Async implementation of thread pool operations.

pub fn async_execute<F>( &self, job: F, ) -> Result<(), SendError<Box<dyn RecoverableFunction<Output = ()>>>>

where F: AsyncRecoverableFunction,

Executes an async job in the thread pool.

Arguments

• F - The async function to execute.

Returns

• SendResult - Result of the job submission.

pub fn async_execute_with_catch<F, E>( &self, job: F, handle_error: E, ) -> Result<(), SendError<Box<dyn RecoverableFunction<Output = ()>>>>

where F: AsyncRecoverableFunction, E: AsyncErrorHandlerFunction,

Executes an async job with error handling in the thread pool.

Arguments

• F - The async function to execute.
• E - The async error handler function.

Returns

• SendResult - Result of the job submission.

pub fn async_execute_with_catch_finally<F, E, L>( &self, job: F, handle_error: E, finally: L, ) -> Result<(), SendError<Box<dyn RecoverableFunction<Output = ()>>>>

where F: AsyncRecoverableFunction, E: AsyncErrorHandlerFunction, L: AsyncRecoverableFunction,

Executes an async job with error handling and finalization in the thread pool.

Arguments

• F - The async function to execute.
• E - The async error handler function.
• L - The async finally handler function.

Returns

• SendResult - Result of the job submission.

impl ThreadPool

Sync implementation of thread pool operations.

pub fn new(size: usize) -> ThreadPool

Creates a new thread pool with the specified number of workers.

Arguments

• usize - The number of worker threads to create.

Returns

• ThreadPool - The new thread pool instance.

pub fn execute<F>( &self, job: F, ) -> Result<(), SendError<Box<dyn RecoverableFunction<Output = ()>>>>

where F: RecoverableFunction,

Executes a synchronous job in the thread pool.

Arguments

• F - The synchronous function to execute.

Returns

• SendResult - Result of the job submission.

pub fn execute_with_catch<F, E>( &self, job: F, handle_error: E, ) -> Result<(), SendError<Box<dyn RecoverableFunction<Output = ()>>>>

where F: RecoverableFunction, E: ErrorHandlerFunction,

Executes a synchronous job with error handling in the thread pool.

Arguments

• F - The synchronous function to execute.
• E - The error handler function.

Returns

• SendResult - Result of the job submission.

pub fn execute_with_catch_finally<F, E, L>( &self, job: F, handle_error: E, finally: L, ) -> Result<(), SendError<Box<dyn RecoverableFunction<Output = ()>>>>

where F: RecoverableFunction, E: ErrorHandlerFunction, L: RecoverableFunction,

Executes a synchronous job with error handling and finalization in the thread pool.

Arguments

• F - The synchronous function to execute.
• E - The error handler function.
• L - The finally handler function.

Returns

• SendResult - Result of the job submission.

Trait Implementations

impl Debug for ThreadPool

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

Formats the value using the given formatter.