Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Thread pool for executing tasks

Implementations

impl ThreadPool

pub fn new(num_threads: usize) -> Result<Self>

Create a new thread pool with default configuration

pub fn with_config(config: ThreadPoolConfig) -> Result<Self>

Create a thread pool with custom configuration

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

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

Execute a task in the thread pool (fire-and-forget)

pub fn submit<F, T>(&self, f: F) -> Result<WorkResult<T>>

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

Submit a task that returns a value

pub fn parallel_for_each<T, F>(&self, items: Vec<T>, f: F) -> Result<()>

where T: Send, F: Fn(T) + Send + Sync,

Execute work in parallel using rayon (native only)

pub fn parallel_map<T, R, F>(&self, items: Vec<T>, f: F) -> Result<Vec<R>>

where T: Send, R: Send, F: Fn(T) -> R + Send + Sync,

Map operation in parallel (native only)

pub fn num_threads(&self) -> usize

Get the number of worker threads

pub fn pending_tasks(&self) -> usize

Get pending task count

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

Shutdown the thread pool gracefully

pub fn shutdown_timeout(self, timeout: Duration) -> Result<()>

Shutdown and wait with timeout