Crate strided_exec 

Splittable CPU placement for the strided stack.

strided-exec is the single place that starts tasks. Kernels never see a scheduler type: they take an Exec, a token for budget slots of a Pool, and split it with Exec::fork, Exec::for_ranges, Exec::broadcast or Exec::external.

• A Pool is built once by its owner with Pool::builder.
• Exec::new mints a token from a pool; Exec::serial needs none.
• A token is not Clone/Copy; entries consume it; splits conserve slots.
• Serial, budget-one and one-task entries run inline and never reach any scheduler, so the process-global Rayon pool is never started implicitly.

Features

• parallel (default): run on a private pool. Without it the same types exist, every pool has width 1 and every entry runs inline.
• ledger: test support, see the ledger module (compiled only with this feature).

Examples

use std::sync::atomic::{AtomicUsize, Ordering};
use strided_exec::{Exec, Pool};

let pool = Pool::builder().threads(4).build()?;
let mut exec = Exec::new(&pool, 4)?;

// Phase 1: data-parallel loop.
let total = AtomicUsize::new(0);
exec.reborrow().for_ranges(1000, 64.try_into().unwrap(), |r| {
    total.fetch_add(r.len(), Ordering::Relaxed);
});
assert_eq!(total.into_inner(), 1000);

// Phase 2: two independent parts, each with its share of the slots.
exec.fork(2, |_i, child| {
    assert!(child.budget().get() <= 2);
});

Structs

Exec

budget slots of a Pool, or the calling thread alone.

Pool

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

PoolBuilder

Configuration of a Pool.

Enums

Error

Failure to build a Pool or an Exec.

Refused

A broadcast that cannot guarantee co-scheduling.