Struct forkjoin::JoinBarrier [] [src]

pub struct JoinBarrier<Ret: Send + Sync> {
    pub ret_counter: AtomicUsize,
    pub joinfun: ReduceStyle<Ret>,
    pub joinarg: Option<Ret>,
    pub joinfunarg: Vec<Ret>,
    pub parent: ResultReceiver<Ret>,
}

Internal struct for receiving results from multiple subtasks in parallel

Fields

ret_counter

Atomic counter counting missing arguments before this join can be executed.

joinfun

Function to execute when all arguments have arrived.

joinarg

Extra argument to pass to joinfun only used when joinfun is ReduceStyle::Arg.

joinfunarg

Vector holding the results of all subtasks. Initialized unsafely so can't be used for anything until all the values have been put in place.

parent

Where to send the result of the execution of joinfun