Concurrent.CyclicBarrier

enum CyclicBarrierSource

case CyclicBarrier(java.util.concurrent.CyclicBarrier)

A wrapper around a Java CyclicBarrier.

Definitions

def awaitBarrier(barrier: CyclicBarrier): Int32 \ IO Source

Waits until all parties have invoked await on this barrier

def newCyclicBarrier(parties: Int32): CyclicBarrier \ IO Source

Create a new CyclicBarrier which will wait for parties threads