Searched refs:barrier (Results 1 – 9 of 9) sorted by relevance
191 val barrier = CyclicBarrier(2) in <lambda>() constant193 barrier.await(LONG_TIMEOUT, TimeUnit.MILLISECONDS) // barrier 1 in <lambda>()202 barrier.await() // barrier 1 in <lambda>()217 val barrier = CyclicBarrier(2) in <lambda>() constant219 barrier.await(LONG_TIMEOUT, TimeUnit.MILLISECONDS) // barrier 1 in <lambda>()220 barrier.await() // barrier 2 in <lambda>()224 barrier.await() // barrier 1 in <lambda>()227 barrier.await() // barrier 2 in <lambda>()
145 std::promise<void> barrier; in main() local146 std::future<void> barrier_future = barrier.get_future(); in main()147 root_canal.initialize(std::move(barrier)); in main()
151 void TestEnvironment::initialize(std::promise<void> barrier) { in initialize() argument154 barrier_ = std::move(barrier); in initialize()
61 void initialize(std::promise<void> barrier);
108 val barrier = CyclicBarrier(threadCount) in <lambda>() constant114 barrier.await() in <lambda>()132 barrier.await() in <lambda>()
720 final CyclicBarrier barrier = new CyclicBarrier(tasks.length); in rapidFire() local728 barrier.await(); in rapidFire()