Searched refs:secondBarrier (Results 1 – 3 of 3) sorted by relevance
480 final CyclicBarrier secondBarrier = new CyclicBarrier(2); in testCustomSchedule_startStop() local489 secondBarrier.await(); in testCustomSchedule_startStop()500 secondBarrier.await(); in testCustomSchedule_startStop()504 secondBarrier.await(); in testCustomSchedule_startStop()514 service.secondBarrier.await(); in testCustomSchedulerServiceStop()573 service.secondBarrier.await(); in testBig()582 final CyclicBarrier secondBarrier = new CyclicBarrier(2); field in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService589 secondBarrier.await(); in runOneIteration()616 service.secondBarrier.await(); in testCustomSchedulerFailure()630 final CyclicBarrier secondBarrier = new CyclicBarrier(2); field in TestFailingCustomScheduledService[all …]
82 val secondBarrier = CyclicBarrier(11) in <lambda>() constant87 …lockingDispatcher) { firstBarrier.await() }, launch(blockingDispatcher2) { secondBarrier.await() }) in <lambda>()99 secondBarrier.await() in <lambda>()