Struct Pool 

pub struct Pool { /* private fields */ }

A fixed set of worker threads that Exec tokens place work on.

Pool is the only way to make a pool. It wraps the scheduler privately: no scheduler type appears in any signature, there is no constructor from an external pool and no accessor returning one. The pool’s owner keeps the Pool and mints tokens from it with Exec::new.

Dropping a Pool shuts its workers down and joins them: when drop returns, every worker thread has exited, so the thread-local destructors of the workers (including state set up by an on_start hook) have already run. Without the parallel feature there are no workers and nothing is joined.

A pool dropped from one of its own workers cannot wait for itself: that drop signals shutdown and returns without joining, so the workers exit shortly after instead of before the return. Drop the pool from a plain thread when the guarantee matters.

Examples

use strided_exec::Pool;

let pool = Pool::builder().threads(2).thread_name(|i| format!("w{i}")).build()?;
assert!(pool.width().get() <= 2);

Implementations

impl Pool

pub fn builder() -> PoolBuilder

Starts configuring a pool.

Examples

let pool = strided_exec::Pool::builder().threads(1).build()?;
assert_eq!(pool.width().get(), 1);

pub fn width(&self) -> NonZeroUsize

Number of worker threads, the largest budget a token can have.

Without the parallel feature this is always 1.

Examples

let pool = strided_exec::Pool::builder().threads(1).build()?;
assert_eq!(pool.width().get(), 1);

Trait Implementations

impl Debug for Pool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.