Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Thread pool with advanced features

Implementations

impl ThreadPool

pub fn new( num_threads: usize, config: &WorkStealingConfig, ) -> IntegrateResult<Self>

Create new thread pool

pub fn execute_tasks( &self, tasks: Vec<Box<dyn ParallelTask + Send>>, ) -> IntegrateResult<Vec<ParallelResult>>

Execute tasks in parallel and collect their real results.

Large tasks are subdivided (when can_subdivide() and the estimated cost warrants it) and the resulting work items are sorted largest-first for better load balancing before being dispatched across the available CPU threads via the data-parallel runtime. Each returned ParallelResult is the genuine output of ParallelTask::execute; there is one entry per executed (sub)task, in dispatch order.

pub fn shutdown(&mut self) -> IntegrateResult<()>

Shutdown the thread pool and wait for all threads to complete

Trait Implementations

impl Drop for ThreadPool

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.