Searched defs:barrier (Results 1 – 7 of 7) sorted by relevance
52 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkFor_1() local67 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkFor_2() local82 CyclicBarrier barrier = new CyclicBarrier(1); in test_parkFor_3() local95 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkUntil_1() local110 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkUntil_2() local125 CyclicBarrier barrier = new CyclicBarrier(1); in test_parkUntil_3() local146 private final CyclicBarrier barrier; field in ThreadsTest.Parker174 public Parker(CyclicBarrier barrier, boolean absolute, long parkMillis) { in Parker()281 private final CyclicBarrier barrier; field in ThreadsTest.WaitAndUnpark285 public WaitAndUnpark(CyclicBarrier barrier, long waitMillis, Thread thread) { in WaitAndUnpark()
41 void awaitNumberWaiting(CyclicBarrier barrier, int numberOfWaiters) { in awaitNumberWaiting()334 final CyclicBarrier barrier = new CyclicBarrier(3); in testResetWithoutBreakage() local365 final CyclicBarrier barrier = new CyclicBarrier(3); in testResetAfterInterrupt() local398 final CyclicBarrier barrier = new CyclicBarrier(3); in testResetAfterTimeout() local434 final CyclicBarrier barrier = in testResetAfterCommandException() local
141 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); in testAddAndSumMT() local154 final CyclicBarrier barrier; field in DoubleAdderTest.AdderTask157 AdderTask(DoubleAdder adder, CyclicBarrier barrier, int incs) { in AdderTask()
164 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); in testAddAndSumMT() local177 final CyclicBarrier barrier; field in LongAdderTest.AdderTask180 AdderTask(LongAdder adder, CyclicBarrier barrier, int incs) { in AdderTask()
217 final CheckedBarrier barrier = new CheckedBarrier(2); in testTimedPollWithOffer() local
1092 final CheckedBarrier barrier = new CheckedBarrier(2); in testTimedPollFirstWithOfferFirst() local
454 final CyclicBarrier barrier = new CyclicBarrier(2); in testIsLocked() local