Searched refs:startBarrier (Results 1 – 4 of 4) sorted by relevance
17 private val startBarrier = CyclicBarrier(3) in <lambda>() constant31 startBarrier.await() in <lambda>()52 startBarrier.await() // (2) resume at the same time in <lambda>()58 startBarrier.await() // (3) return at the same time in <lambda>()
25 val startBarrier = CyclicBarrier(threads + 1) in <lambda>() constant30 startBarrier.await() in <lambda>()47 startBarrier.await() in <lambda>()
104 public ClientWorker(CyclicBarrier startBarrier, CountDownLatch responsesDoneSignal) { in ClientWorker() argument105 this.startBarrier = startBarrier; in ClientWorker()124 startBarrier.await(); in run()131 private final CyclicBarrier startBarrier; field in ConcurrencyTest.ClientWorker175 CyclicBarrier startBarrier = new CyclicBarrier(NUM_CONCURRENT_REQUESTS); in serverStreamingTest() local179 clientExecutor.execute(new ClientWorker(startBarrier, responsesDoneSignal)); in serverStreamingTest()
93 CyclicBarrier startBarrier = new CyclicBarrier(2); in testSetDefaultDeadlock() local95 waitFor(startBarrier); in testSetDefaultDeadlock()106 waitFor(startBarrier); in testSetDefaultDeadlock()140 CyclicBarrier startBarrier = new CyclicBarrier(2); in testSetDefaultRace() local142 waitFor(startBarrier); in testSetDefaultRace()154 waitFor(startBarrier); in testSetDefaultRace()