Searched refs:startBarrier (Results 1 – 3 of 3) sorted by relevance
43 CyclicBarrier startBarrier = new CyclicBarrier(threads.length); in main() local46 threads[i] = new Thread(new Main(startBarrier)); in main()71 private Main(CyclicBarrier startBarrier) { in Main() argument72 this.startBarrier = startBarrier; in Main()76 private CyclicBarrier startBarrier; field in Main100 startBarrier.await(TIMEOUT_VALUE, java.util.concurrent.TimeUnit.MINUTES); in work()
99 final SimpleBarrier startBarrier = new SimpleBarrier(1); in testThread() local108 startBarrier.dec(); in testThread()124 startBarrier.waitFor(); in testThread()
583 final Barrier startBarrier = new Barrier(numberOfThreads + numberOfDaemons + 1); in runTest() local620 : new Daemon(lock, t, operations, mainThread, startBarrier); in runTest()660 startBarrier.await(); in runTest()723 startBarrier.await(); in runTest()771 Barrier startBarrier) { in Daemon() argument774 this.startBarrier = startBarrier; in Daemon()782 startBarrier.await(); in run()814 final Barrier startBarrier; field in Main.Daemon