Struct ParallelExecutor 

pub struct ParallelExecutor { /* private fields */ }

Branch-level parallel executor.

Holds the configured worker count and a “shutdown” flag. Each call to Self::execute_branches runs the supplied workers in parallel (when enabled and above the branching threshold) and collects their results in input order.

Implementations

impl ParallelExecutor

pub fn new(max_workers: usize) -> Self

Build an executor with at most max_workers concurrent branches. 0 disables parallel dispatch (every branch runs sequentially).

pub fn enabled(&self) -> bool

Whether the executor will dispatch concurrently.

pub fn shutdown(&self)

Mark the executor as shut down. Subsequent Self::execute_branches calls fall back to sequential execution.

pub fn execute_branches<R, F>(&self, workers: &[F]) -> Vec<R>

where R: Send, F: Fn() -> R + Sync + Send,

Run each worker and collect results in the same order. Uses rayon’s work-stealing pool when Self::enabled is true and the branch count is at least MIN_PARALLEL_BRANCHES; otherwise falls back to sequential execution.

Trait Implementations

impl Clone for ParallelExecutor

fn clone(&self) -> ParallelExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelExecutor

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

Formats the value using the given formatter.

impl Default for ParallelExecutor

fn default() -> Self

Returns the “default value” for a type.