Struct StdDefaultPool 

pub struct StdDefaultPool { /* private fields */ }

Native standard thread pool.

This is the default thread pool used when “std” feature is enabled. Note that the thread pool to be used for a parallel computation can be set by the with_runner transformation separately for each parallel iterator.

Uses std::thread::scope and scope.spawn(..) to distribute work to threads.

Value of max_num_threads is determined as the minimum of:

• the available parallelism of the host obtained via std::thread::available_parallelism(), and
• the upper bound set by the environment variable “ORX_PARALLEL_MAX_NUM_THREADS”, when set.

Trait Implementations

impl Clone for StdDefaultPool

fn clone(&self) -> StdDefaultPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for StdDefaultPool

fn default() -> Self

Returns the “default value” for a type.

impl ParThreadPool for &StdDefaultPool

type ScopeRef<'s, 'env, 'scope> = &'s Scope<'s, 'env> where 'scope: 's, 'env: 'scope + 's

Scope type of the thread pool.

fn max_num_threads(&self) -> NonZeroUsize

Returns the maximum number of threads available in the pool.

fn scoped_computation<'env, 'scope, F>(&'env mut self, f: F)

where for<'s> F: FnOnce(&'s Scope<'s, 'env>) + Send, 'env: 'scope,

Executes the scoped computation f.

fn run_in_scope<'s, 'env, 'scope, W>( s: &Self::ScopeRef<'s, 'env, 'scope>, work: W, )

where W: Fn() + Send + 'scope + 'env, 'scope: 's, 'env: 'scope + 's,

Executes the work within scope s.

impl ParThreadPool for StdDefaultPool

type ScopeRef<'s, 'env, 'scope> = &'s Scope<'s, 'env> where 'scope: 's, 'env: 'scope + 's

Scope type of the thread pool.

fn max_num_threads(&self) -> NonZeroUsize

Returns the maximum number of threads available in the pool.

fn scoped_computation<'env, 'scope, F>(&'env mut self, f: F)

where for<'s> F: FnOnce(&'s Scope<'s, 'env>) + Send, 'env: 'scope,

Executes the scoped computation f.

fn run_in_scope<'s, 'env, 'scope, W>( s: &Self::ScopeRef<'s, 'env, 'scope>, work: W, )

where W: Fn() + Send + 'scope + 'env, 'scope: 's, 'env: 'scope + 's,

Executes the work within scope s.