Searched refs:startLatch (Results 1 – 3 of 3) sorted by relevance
24 final CountDownLatch startLatch = new CountDownLatch(1); in testAsyncServiceLifecycle() local28 assertEquals(1, startLatch.getCount()); in testAsyncServiceLifecycle()31 startLatch.countDown(); in testAsyncServiceLifecycle()35 assertEquals(0, startLatch.getCount()); in testAsyncServiceLifecycle()44 assertTrue(startLatch.await(2, TimeUnit.SECONDS)); in testAsyncServiceLifecycle()55 assertEquals(0, startLatch.getCount()); in testAsyncServiceLifecycle()
143 private final CountDownLatch startLatch = new CountDownLatch(1); field in FailOnTimeout.CallableStatement147 startLatch.countDown(); in call()158 startLatch.await(); in awaitStarted()
151 final CountDownLatch startLatch = new CountDownLatch(numberOfThreads); in runConcurrentTest() local157 startLatch.countDown(); in runConcurrentTest()158 startLatch.await(); in runConcurrentTest()