Struct ActiveBarrier 

pub struct ActiveBarrier<'a> { /* private fields */ }

An ActiveBarrier can be used to generate checkpoints which must be cleared (usually by worker threads) before wait() and drop() unblock.

Implementations

impl<'a> ActiveBarrier<'a>

pub fn checkpoint(&mut self) -> Checkpoint

Generate a new Checkpoint to be cleared.

Panics

This function will panics if called more than n times.

pub fn finished(&self) -> bool

Returns true if all checkpoints have been cleared and any calls to wait() or drop will not block.

pub fn wait(&self) -> WaitResult

Block thread until all checkpoints are cleared. Returns a CheckpointPanic Err if a checkpoint is passed by a panicking thread. Returns an InsufficientCheckpoints Err if less than n Checkpoints were generated.

pub fn n(&self) -> usize

The number of Checkpoints that must be generated and cleared each time the barrier is activated.

Trait Implementations

impl<'a> Drop for ActiveBarrier<'a>

fn drop(&mut self)

Executes the destructor for this type.