Struct YastlPool 

pub struct YastlPool(/* private fields */);

A wrapper for yastl::Pool and number of threads it was built with.

NOTE: The reason why yastl::Pool does not directly implement ParThreadPool is simply to be able to provide max_num_threads which is the argument used to create the pool with.

Two constructors of the yastl::Pool are made available to YastlPool:

• YastlPool::new
• YastlPool::with_config

Implementations

impl YastlPool

pub fn new(num_threads: usize) -> Self

Create a new Pool that will execute it’s tasks on num_threads worker threads.

pub fn with_config(num_threads: usize, config: ThreadConfig) -> Self

Create a new Pool that will execute it’s tasks on num_threads worker threads and spawn them using the given config.

pub fn inner(&self) -> &Pool

Reference to wrapped yastl::Pool.

pub fn inner_mut(&mut self) -> &mut Pool

Mutable reference to wrapped yastl::Pool.

pub fn into_inner(self) -> Pool

Returns the wrapped yastl::Pool.

Trait Implementations

impl ParThreadPool for &YastlPool

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

Scope type of the thread pool.

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.

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

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

Executes the scoped computation f.

fn max_num_threads(&self) -> NonZeroUsize

Returns the maximum number of threads available in the pool.

impl ParThreadPool for YastlPool

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

Scope type of the thread pool.

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.

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

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

Executes the scoped computation f.

fn max_num_threads(&self) -> NonZeroUsize

Returns the maximum number of threads available in the pool.