Struct CpuPool 

pub struct CpuPool { /* private fields */ }

A persistent pool of parked workers.

Dropping the pool asks every worker to leave and joins it, so a pool never outlives its threads. The process-wide pool is a static and is therefore never dropped, exactly like rayon’s global pool.

Implementations

impl CpuPool

pub fn new(threads: usize) -> Self

Spawn threads workers, minus the submitter: the thread that calls Self::run is a worker too, which is why a one-thread pool spawns nothing at all and still works.

pub fn num_threads(&self) -> usize

Total width including the submitting thread.

pub fn run<F: Fn(usize) + Sync>(&self, n_tasks: usize, f: &F) -> bool

Run f(task) for every task in 0..n_tasks.

Returns false without running anything if another thread is already inside a region – the caller is expected to fall back to rayon rather than serialize behind it. Returns true when the work is complete, including the nested case, where the tasks run inline on the calling thread.

A panic in f is re-raised here, on the submitting thread.

Trait Implementations

impl Drop for CpuPool

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.