Searched refs:startedLatch (Results 1 – 8 of 8) sorted by relevance
95 CountDownLatch startedLatch = new CountDownLatch(1); in testCancelSchedule() local96 job.started = startedLatch::countDown; in testCancelSchedule()100 …assertTrue("Job should start after schedule. Iteration " + i, startedLatch.await(5, TimeUnit.SECON… in testCancelSchedule()
64 final CountDownLatch startedLatch; field in SocketReadWrite.EchoServer75 this.startedLatch = await; in EchoServer()80 startedLatch.countDown(); in run()
213 public final CountDownLatch startedLatch = new CountDownLatch(1); // It's the final countdown! field in TestServerNonceManager.TestRunnable238 startedLatch.await(); in start()247 startedLatch.countDown(); in run()
531 final CountDownLatch startedLatch = new CountDownLatch(numRequests); in testNonceCollision() local546 startedLatch.countDown(); in testNonceCollision()563 startedLatch.await(); // Wait until all threads are ready... in testNonceCollision()