Searched refs:startLatch (Results 1 – 3 of 3) sorted by relevance
20 final CountDownLatch startLatch = new CountDownLatch(1); in testAsyncServiceLifecycle() local26 assertEquals(1, startLatch.getCount()); in testAsyncServiceLifecycle()29 startLatch.countDown(); in testAsyncServiceLifecycle()34 assertEquals(0, startLatch.getCount()); in testAsyncServiceLifecycle()43 assertTrue(startLatch.await(2, TimeUnit.SECONDS)); in testAsyncServiceLifecycle()54 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()