Struct PoolScope 

pub struct PoolScope<'a, P: ThreadPool> { /* private fields */ }

Scoped execution context for a thread pool.

This provides a convenient way to run operations with a specific thread pool.

Implementations

impl<'a, P: ThreadPool> PoolScope<'a, P>

pub fn new(pool: &'a P) -> Self

Creates a new pool scope with default threshold.

pub fn with_threshold(pool: &'a P, threshold: ParThreshold) -> Self

Creates a new pool scope with a custom threshold.

pub fn num_threads(&self) -> usize

Returns the number of threads in the pool.

pub fn join<A, B, RA, RB>(&self, a: A, b: B) -> (RA, RB)

where A: FnOnce() -> RA + Send, B: FnOnce() -> RB + Send, RA: Send, RB: Send,

Joins two closures.

pub fn for_each<F>(&self, total: usize, f: F)

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

Parallel for_each over a range.

pub fn for_each_range<F>(&self, total: usize, f: F)

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

Parallel for_each over work ranges.

pub fn map_reduce<T, Map, Reduce>( &self, total: usize, identity: T, map: Map, reduce: Reduce, ) -> T

where T: Clone + Send + Sync, Map: Fn(usize) -> T + Send + Sync, Reduce: Fn(T, T) -> T + Send + Sync,

Parallel map-reduce operation.