Struct ForkJoin 

pub struct ForkJoin {
    pub value_domain_size: u64,
    pub wstate: Vec<WorkerState>,
    pub wvalue: Vec<u64>,
    pub phase: ForkJoinPhase,
    pub output_ready: bool,
    pub output_snapshot: Vec<u64>,
}

Fork-join execution owner.

Fields

value_domain_size: u64

Exclusive upper bound of worker values.

wstate: Vec<WorkerState>

Worker lifecycle states by worker index.

wvalue: Vec<u64>

Current values by worker index.

phase: ForkJoinPhase

Global fork-join phase.

output_ready: bool

Whether a stable output snapshot has been produced.

output_snapshot: Vec<u64>

Stable joined output values.

Implementations

impl ForkJoin

pub fn new( workers: usize, value_domain_size: u64, initial_value: u64, ) -> ForkJoin

Construct a fork-phase execution with ready workers.

pub fn start_worker(&mut self, worker: usize) -> bool

Start one ready worker, returning false when the transition is disabled.

pub fn complete_worker(&mut self, worker: usize, value: u64) -> bool

Complete one running worker with an in-domain value.

pub fn barrier(&mut self) -> bool

Commit the join barrier after every worker completes.

pub fn produce_output(&mut self) -> bool

Produce the stable output snapshot from joined worker values.

pub fn done_stuttering(&mut self) -> bool

Execute the terminal stutter when output production is complete.