Lines Matching refs:barrier
52 CyclicBarrier barrier = new CyclicBarrier(2);
53 Parker parker = new Parker(barrier, false, 500);
56 new Thread(new WaitAndUnpark(barrier, 1000, parkerThread));
67 CyclicBarrier barrier = new CyclicBarrier(2);
68 Parker parker = new Parker(barrier, false, 1000);
71 new Thread(new WaitAndUnpark(barrier, 300, parkerThread));
82 CyclicBarrier barrier = new CyclicBarrier(1);
83 Parker parker = new Parker(barrier, false, 1000);
94 CyclicBarrier barrier = new CyclicBarrier(2);
95 Parker parker = new Parker(barrier, true, 500);
98 new Thread(new WaitAndUnpark(barrier, 1000, parkerThread));
109 CyclicBarrier barrier = new CyclicBarrier(2);
110 Parker parker = new Parker(barrier, true, 1000);
113 new Thread(new WaitAndUnpark(barrier, 300, parkerThread));
124 CyclicBarrier barrier = new CyclicBarrier(1);
125 Parker parker = new Parker(barrier, true, 1000);
142 private final CyclicBarrier barrier;
168 public Parker(CyclicBarrier barrier, boolean absolute, long parkMillis) {
169 this.barrier = barrier;
178 barrier.await(60, TimeUnit.SECONDS);
260 private final CyclicBarrier barrier;
264 public WaitAndUnpark(CyclicBarrier barrier, long waitMillis, Thread thread) {
265 this.barrier = barrier;
272 barrier.await(60, TimeUnit.SECONDS);
