Struct ParallelPolicy 

pub struct ParallelPolicy {
    pub min_parallel_shard_bytes: usize,
    pub min_bytes_per_job: usize,
    pub max_jobs: usize,
    pub l2_cache_bytes: usize,
}

Fields

min_parallel_shard_bytes: usize

min_bytes_per_job: usize

max_jobs: usize

l2_cache_bytes: usize

Estimated L2 cache size per core in bytes. Used to bound chunk sizes so each job’s working set fits in L2. Set to 0 to disable cache-aware sizing.

Implementations

impl ParallelPolicy

pub fn decide( &self, shard_size: usize, data_shards: usize, output_shards: usize, available_parallelism: usize, ) -> ParallelDecision

Decide whether to use parallel execution and how to chunk the work.

pub fn with_l2_cache_bytes(self, bytes: usize) -> Self

Builder-style setter for L2 cache size.

pub fn with_env_overrides(self) -> Self

Apply environment variable overrides (RS_PARALLEL_POLICY_*) to this policy.

Trait Implementations

impl Clone for ParallelPolicy

fn clone(&self) -> ParallelPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ParallelPolicy

impl Debug for ParallelPolicy

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

Formats the value using the given formatter.

impl Default for ParallelPolicy

Available on crate feature std only.

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ParallelPolicy

impl PartialEq for ParallelPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ParallelPolicy