Searched refs:CyclicBarrier (Results 1 – 5 of 5) sorted by relevance
15 import java.util.concurrent.CyclicBarrier;30 void awaitNumberWaiting(CyclicBarrier barrier, int numberOfWaiters) { in awaitNumberWaiting()44 new CyclicBarrier(-1, (Runnable)null); in testConstructor1()54 new CyclicBarrier(-1); in testConstructor2()63 CyclicBarrier b = new CyclicBarrier(2); in testGetParties()72 CyclicBarrier b = new CyclicBarrier(1); in testSingleParty()85 CyclicBarrier b = new CyclicBarrier(1, new MyAction()); in testBarrierAction()98 final CyclicBarrier b = new CyclicBarrier(2); in testTwoParties()119 final CyclicBarrier c = new CyclicBarrier(3); in testAwait1_Interrupted_BrokenBarrier()145 final CyclicBarrier c = new CyclicBarrier(3); in testAwait2_Interrupted_BrokenBarrier()[all …]
15 import java.util.concurrent.CyclicBarrier;436 final CyclicBarrier barrier = new CyclicBarrier(2); in testIsLocked()
1040 public class CheckedBarrier extends CyclicBarrier {
20 import java.util.concurrent.CyclicBarrier;52 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkFor_1()67 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkFor_2()82 CyclicBarrier barrier = new CyclicBarrier(1); in test_parkFor_3()94 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkUntil_1()109 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkUntil_2()124 CyclicBarrier barrier = new CyclicBarrier(1); in test_parkUntil_3()142 private final CyclicBarrier barrier;168 public Parker(CyclicBarrier barrier, boolean absolute, long parkMillis) { in Parker()260 private final CyclicBarrier barrier;[all …]
106 public class CyclicBarrier { class244 public CyclicBarrier(int parties, Runnable barrierAction) { in CyclicBarrier() method in CyclicBarrier260 public CyclicBarrier(int parties) { in CyclicBarrier() method in CyclicBarrier