class

Concurrent::CyclicBarrier

Inherits Reference / Object

A synchronization aid that allows a set of fibers to all wait for each other to reach a common barrier point.

Constructors

new(parties : Int32)
Source

Instance methods

broken?
Source
parties

Returns the number of fibers needed to pass the barrier.

Source
wait

Wait until #wait has been called by @parties Fibers.

TODO:

  • Accept a timeout
Source

Nested types