Searched refs:finishLatch (Results 1 – 8 of 8) sorted by relevance
104 final CountDownLatch finishLatch = new CountDownLatch(1); in asyncClientStreaming_serverResponsePriorToRequest() local118 finishLatch.countDown(); in asyncClientStreaming_serverResponsePriorToRequest()123 finishLatch.countDown(); in asyncClientStreaming_serverResponsePriorToRequest()130 assertTrue(finishLatch.await(900, TimeUnit.MILLISECONDS)); in asyncClientStreaming_serverResponsePriorToRequest()163 final CountDownLatch finishLatch = new CountDownLatch(1); in asyncClientStreaming_serverErrorPriorToRequest() local177 finishLatch.countDown(); in asyncClientStreaming_serverErrorPriorToRequest()182 finishLatch.countDown(); in asyncClientStreaming_serverErrorPriorToRequest()189 assertTrue(finishLatch.await(900, TimeUnit.MILLISECONDS)); in asyncClientStreaming_serverErrorPriorToRequest()222 final CountDownLatch finishLatch = new CountDownLatch(1); in asyncClientStreaming_erroneousServiceImpl() local236 finishLatch.countDown(); in asyncClientStreaming_erroneousServiceImpl()[all …]
51 val finishLatch = CountDownLatch(2) in <lambda>() constant56 finishLatch.countDown() in <lambda>()61 finishLatch.countDown() in <lambda>()66 finishLatch.await() in <lambda>()75 val finishLatch = CountDownLatch(2) in <lambda>() constant80 finishLatch.countDown() in <lambda>()85 finishLatch.countDown() in <lambda>()90 finishLatch.await() in <lambda>()
31 private val finishLatch = CountDownLatch(1) constant in kotlinx.coroutines.scheduling.CoroutineSchedulerStressTest51 finishLatch.await() in testInternalTasksSubmissionProgress()79 finishLatch.await() in testStealingFromNonProgressing()82 finishLatch.await() in testStealingFromNonProgressing()92 finishLatch.countDown() in processTask()
136 final CountDownLatch finishLatch = new CountDownLatch(1); in recordRoute() local154 finishLatch.countDown(); in recordRoute()160 finishLatch.countDown(); in recordRoute()175 if (finishLatch.getCount() == 0) { in recordRoute()190 if (!finishLatch.await(1, TimeUnit.MINUTES)) { in recordRoute()201 final CountDownLatch finishLatch = new CountDownLatch(1); in routeChat() local219 finishLatch.countDown(); in routeChat()225 finishLatch.countDown(); in routeChat()248 return finishLatch; in routeChat()276 CountDownLatch finishLatch = client.routeChat(); in main() local[all …]
26 val finishLatch = CountDownLatch(threads) in <lambda>() constant43 finishLatch.countDown() in <lambda>()48 finishLatch.await() in <lambda>()
281 final CountDownLatch finishLatch = new CountDownLatch(1); in recordRoute() local299 finishLatch.countDown(); in recordRoute()305 finishLatch.countDown(); in recordRoute()324 if (finishLatch.getCount() == 0) { in recordRoute()339 if (!finishLatch.await(1, TimeUnit.MINUTES)) { in recordRoute()368 final CountDownLatch finishLatch = new CountDownLatch(1); in routeChat() local385 finishLatch.countDown(); in routeChat()391 finishLatch.countDown(); in routeChat()421 if (!finishLatch.await(1, TimeUnit.MINUTES)) { in routeChat()
484 final CountDownLatch finishLatch = new CountDownLatch(1); field in CycleDetectingLockFactoryTest.LockingThread496 finishLatch.await(1, TimeUnit.MINUTES); in run()509 finishLatch.countDown(); in releaseLockAndFinish()