Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Available on (crate features rayon or default-thread-pool) and crate feature default-thread-pool only.

A thread pool that can execute parallel pipelines.

This type doesn’t expose any public methods other than num_threads(). You can interact with it via the ThreadPoolBuilder::build() function to create a thread pool, and the with_thread_pool() method to attach a thread pool to a parallel iterator.

Implementations

impl ThreadPool

pub fn num_threads(&self) -> NonZeroUsize

Returns the number of worker threads that have been spawned in this thread pool.

Trait Implementations

impl GenericThreadPool for &mut ThreadPool

fn upper_bounded_pipeline<Output: Send, Accum>( self, input_len: usize, init: impl Fn() -> Accum + Sync, process_item: impl Fn(Accum, usize) -> ControlFlow<Accum, Accum> + Sync, finalize: impl Fn(Accum) -> Output + Sync, reduce: impl Fn(Output, Output) -> Output, cleanup: &(impl SourceCleanup + Sync), ) -> Output

Processes an input of the given length in parallel and returns the aggregated output.

fn iter_pipeline<Output, Accum: Send>( self, input_len: usize, accum: impl Accumulator<usize, Accum> + Sync, reduce: impl ExactSizeAccumulator<Accum, Output>, cleanup: &(impl SourceCleanup + Sync), ) -> Output

Processes an input of the given length in parallel and returns the aggregated output.