Searched refs:CyclicBarrier (Results 1 – 16 of 16) sorted by relevance
41 import java.util.concurrent.CyclicBarrier;60 void awaitNumberWaiting(CyclicBarrier barrier, int numberOfWaiters) { in awaitNumberWaiting()74 new CyclicBarrier(-1, (Runnable)null); in testConstructor1()84 new CyclicBarrier(-1); in testConstructor2()93 CyclicBarrier b = new CyclicBarrier(2); in testGetParties()102 CyclicBarrier b = new CyclicBarrier(1); in testSingleParty()117 CyclicBarrier b = new CyclicBarrier(1, incCount); in testBarrierAction()130 final CyclicBarrier b = new CyclicBarrier(2); in testTwoParties()151 final CyclicBarrier c = new CyclicBarrier(3); in testAwait1_Interrupted_BrokenBarrier()177 final CyclicBarrier c = new CyclicBarrier(3); in testAwait2_Interrupted_BrokenBarrier()[all …]
35 import java.util.concurrent.CyclicBarrier;164 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); in testAddAndSumMT()177 final CyclicBarrier barrier;180 AdderTask(DoubleAdder adder, CyclicBarrier barrier, int incs) { in AdderTask()
35 import java.util.concurrent.CyclicBarrier;187 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); in testAddAndSumMT()200 final CyclicBarrier barrier;203 AdderTask(LongAdder adder, CyclicBarrier barrier, int incs) { in AdderTask()
43 import java.util.concurrent.CyclicBarrier;477 final CyclicBarrier barrier = new CyclicBarrier(2); in testIsLocked()
105 import java.util.concurrent.CyclicBarrier;2026 public static class CheckedBarrier extends CyclicBarrier {
15 import java.util.concurrent.CyclicBarrier;41 void awaitNumberWaiting(CyclicBarrier barrier, int numberOfWaiters) { in awaitNumberWaiting()55 new CyclicBarrier(-1, (Runnable)null); in testConstructor1()65 new CyclicBarrier(-1); in testConstructor2()74 CyclicBarrier b = new CyclicBarrier(2); in testGetParties()83 CyclicBarrier b = new CyclicBarrier(1); in testSingleParty()96 CyclicBarrier b = new CyclicBarrier(1, new MyAction()); in testBarrierAction()109 final CyclicBarrier b = new CyclicBarrier(2); in testTwoParties()130 final CyclicBarrier c = new CyclicBarrier(3); in testAwait1_Interrupted_BrokenBarrier()156 final CyclicBarrier c = new CyclicBarrier(3); in testAwait2_Interrupted_BrokenBarrier()[all …]
9 import java.util.concurrent.CyclicBarrier;141 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); in testAddAndSumMT()154 final CyclicBarrier barrier;157 AdderTask(DoubleAdder adder, CyclicBarrier barrier, int incs) { in AdderTask()
9 import java.util.concurrent.CyclicBarrier;164 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); in testAddAndSumMT()177 final CyclicBarrier barrier;180 AdderTask(LongAdder adder, CyclicBarrier barrier, int incs) { in AdderTask()
17 import java.util.concurrent.CyclicBarrier;454 final CyclicBarrier barrier = new CyclicBarrier(2); in testIsLocked()
41 import java.util.concurrent.CyclicBarrier;1754 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()95 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkUntil_1()110 CyclicBarrier barrier = new CyclicBarrier(2); in test_parkUntil_2()125 CyclicBarrier barrier = new CyclicBarrier(1); in test_parkUntil_3()146 private final CyclicBarrier barrier;174 public Parker(CyclicBarrier barrier, boolean absolute, long parkMillis) { in Parker()281 private final CyclicBarrier barrier;[all …]
46 import java.util.concurrent.CyclicBarrier;61 final CyclicBarrier testEnd = new CyclicBarrier(3); in main()82 static final class TestBarrier extends CyclicBarrier104 private final CyclicBarrier testEnd;106 public TestThread(final Vector vector, final CyclicBarrier testEnd) { in TestThread()
141 public class CyclicBarrier { class279 public CyclicBarrier(int parties, Runnable barrierAction) { in CyclicBarrier() method in CyclicBarrier295 public CyclicBarrier(int parties) { in CyclicBarrier() method in CyclicBarrier
992 "ojluni/src/main/java/java/util/concurrent/CyclicBarrier.java",
1043 …ava/java/util/concurrent/CyclicBarrier.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…
15844 public class CyclicBarrier {15845 ctor public CyclicBarrier(int, Runnable);15846 ctor public CyclicBarrier(int);