class Concurrent::CyclicBarrier

Overview

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

Defined in:

concurrent/cyclic_barrier.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(parties) #

[View source]

Instance Method Detail

def broken? : Bool #

[View source]
def parties : Int32 #

Returns the number of fibers needed to pass the barrier.


[View source]
def wait #

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

TODO

  • Accept a timeout

[View source]