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()
104 final SimpleBarrier startBarrier = new SimpleBarrier(1); in testThread() local113 startBarrier.dec(); in testThread()129 startBarrier.waitFor(); in testThread()
601 final Barrier startBarrier = new Barrier(numberOfThreads + numberOfDaemons + 1); in runTest() local638 : new Daemon(lock, t, operations, mainThread, startBarrier); in runTest()678 startBarrier.await(); in runTest()746 startBarrier.await(); in runTest()794 Barrier startBarrier) { in Daemon() argument797 this.startBarrier = startBarrier; in Daemon()805 startBarrier.await(); in run()837 final Barrier startBarrier; field in Main.Daemon