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