Struct timely::synchronization::barrier::Barrier

pub struct Barrier<A: Allocate> { /* fields omitted */ }

A re-usable barrier synchronization mechanism.

Implementations

impl<A: Allocate> Barrier<A>

pub fn new(worker: &mut Worker<A>) -> Self

Allocates a new barrier.

pub fn wait(&mut self)

Blocks until all other workers have reached this barrier.

This method does not block dataflow execution, which continues to execute while we await the arrival of the other workers.

pub fn advance(&mut self)

Advances this worker to the next barrier stage.

This change is not communicated until worker.step() is called.

pub fn reached(&mut self) -> bool

Indicates that the barrier has been reached by all workers.

This method may not change until worker.step() is called.