Struct ExecutionPolicy 

pub struct ExecutionPolicy { /* private fields */ }

Immutable worker-budget policy with one persistent bounded execution pool.

requested_threads = None selects the available logical CPU count. Fixed budgets are capped to that count. Cloned execution contexts share the same Rayon pool, so prepared phases and workflow operations do not rebuild or nest worker pools.

Implementations

impl ExecutionPolicy

pub fn new( requested_threads: Option<usize>, minimum_parallel_tasks: usize, ) -> Result<Self, ExecutionPolicyError>

Construct and retain the bounded execution context for this policy.

Errors

Returns ExecutionPolicyError for zero budgets/thresholds or when Rayon cannot build the resolved worker pool.

pub fn bounded_default() -> Result<Self, ExecutionPolicyError>

Construct the bounded two-thread default policy.

Errors

Returns ExecutionPolicyError when Rayon cannot build the pool.

pub const fn requested_threads(&self) -> Option<usize>

Return the requested fixed worker count, or None for automatic mode.

pub const fn minimum_parallel_tasks(&self) -> usize

Return the independent-task threshold for parallel scheduling.

pub const fn resolved_budget(&self) -> usize

Return the resolved logical-CPU budget retained by this policy.

pub fn worker_count(&self, task_count: usize) -> usize

Return the worker count for a known number of independent tasks.

pub const fn context(&self) -> &ExecutionContext

Borrow the persistent bounded execution context.

Trait Implementations

impl Clone for ExecutionPolicy

fn clone(&self) -> ExecutionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionPolicy

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

Formats the value using the given formatter.

impl Eq for ExecutionPolicy

impl PartialEq for ExecutionPolicy

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.