Struct GlobalReduction 

pub struct GlobalReduction {
    pub total_participants: u32,
    pub completed: AtomicU32,
    pub all_complete: AtomicBool,
    pub partial_results: Vec<AtomicU64>,
}

Global reduction tracker for K2K coordination

Fields

total_participants: u32

Total number of participants

completed: AtomicU32

Number of participants that have completed

all_complete: AtomicBool

Whether all participants are done

partial_results: Vec<AtomicU64>

Partial results (one per participant)

Implementations

impl GlobalReduction

pub fn new(participants: u32) -> Self

Create a new global reduction

pub fn submit(&self, participant_id: u32, value: f64) -> bool

Submit a partial result

pub fn is_complete(&self) -> bool

Check if all participants have submitted

pub fn completion_count(&self) -> u32

Get completion count

pub fn finalize_sum(&self) -> Option<f64>

Compute final result (sum of partials)

pub fn finalize_max(&self) -> Option<f64>

Compute final result (max of partials)

pub fn finalize_min(&self) -> Option<f64>

Compute final result (min of partials)

pub fn reset(&self)

Reset for reuse