Struct ParReduce 

pub struct ParReduce {
    pub size: usize,
    pub op: ReduceOp,
    pub config: ParallelConfig,
}

Parallel reduce descriptor.

result = parReduce(combine, map_fn, input)
// Equivalent to: result = combine(map_fn(input[0]), map_fn(input[1]), ...)

Fields

size: usize

Number of elements.

op: ReduceOp

Reduction operation.

config: ParallelConfig

Parallel configuration.

Implementations

impl ParReduce

pub fn new(size: usize, op: ReduceOp) -> Self

Create a new parallel reduce.

pub fn deterministic(self, det: bool) -> Self

Set deterministic mode.

pub fn chunk_assignments(&self) -> Vec<Range>

Generate chunk assignments for workers.

For deterministic mode, chunks are assigned in order:

• Worker 0 gets elements [0, chunk_size)
• Worker 1 gets elements [chunk_size, 2*chunk_size)
• etc.

Final reduction combines partial results in worker order.

pub fn identity(&self) -> f64

Returns the identity value for this reduction operation.

Trait Implementations

impl Clone for ParReduce

fn clone(&self) -> ParReduce

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParReduce

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

Formats the value using the given formatter.