Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Thread pool for parallel execution

Implementations

impl ThreadPool

pub fn new() -> Self

Create a new thread pool with default configuration

pub fn with_config(config: ThreadPoolConfig) -> Self

Create a new thread pool with custom configuration

pub fn execute<F>(&self, f: F) -> Result<(), ThreadPoolError>

where F: FnOnce() + Send + 'static,

Execute a closure on the thread pool

pub fn execute_and_wait<F, R>(&self, f: F) -> Result<R, ThreadPoolError>

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

Execute a closure and wait for completion

pub fn execute_parallel<F, I>( &self, tasks: I, ) -> Result<Vec<()>, ThreadPoolError>

where F: FnOnce() + Send + 'static, I: IntoIterator<Item = F>,

Execute multiple tasks in parallel

pub fn get_stats(&self) -> ThreadPoolStats

Get thread pool statistics

pub fn get_config(&self) -> &ThreadPoolConfig

Get current configuration

pub fn resize(&mut self, newsize: usize) -> Result<(), ThreadPoolError>

Resize the thread pool

pub fn shutdown(self) -> Result<(), ThreadPoolError>

Shutdown the thread pool gracefully

Trait Implementations

impl Default for ThreadPool

fn default() -> Self

Returns the “default value” for a type.