Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Thread pool for executing work in parallel

This matches the C++ thread_pool class with similar functionality:

• Fixed number of worker threads
• Work queue
• Parallel for loop support

Implementations

impl ThreadPool

pub fn new(nthreads: usize) -> Self

Create a new thread pool with the specified number of threads

pub fn submit<F, R, Args>(&self, f: F, args: Args) -> Receiver<R>

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

Submit a function to be executed by the thread pool

Returns a receiver that can be used to get the result

pub fn parallel_for<F>(&self, start: usize, end: usize, stride: usize, f: F)

where F: Fn(usize, usize, usize) + Send + Sync + Clone + 'static,

Execute a parallel for loop over a range

This matches the C++ thread_pool::parallel_for method

pub fn size(&self) -> usize

Get the number of threads in the pool

pub fn is_done(&self) -> bool

Check if the pool has been shut down

Trait Implementations

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.