Searched defs:stopLatch (Results 1 – 7 of 7) sorted by relevance
87 val stopLatch = CountDownLatch(requestorActors) in run() constant122 val stopLatch: CountDownLatch) : UntypedAbstractActor() { constant in benchmarks.akka.StatefulActorAkkaBenchmark.RequestorActor
80 …class PingActorAkka(val pongRef: ActorRef, val stopLatch: CountDownLatch) : UntypedAbstractActor()… constant in benchmarks.akka.PingPongAkkaBenchmark.PingActorAkka
138 CountDownLatch stopLatch = new CountDownLatch(1); in createHintSessionWithExitedThreads() local145 private int[] createThreads(int tidCnt, CountDownLatch stopLatch) throws InterruptedException { in createThreads()
1352 CountDownLatch stopLatch = initWaitingForChildProcessGone( in testKillingAppChildProcess() local1492 CountDownLatch stopLatch = initWaitingForChildProcessGone( in testTrimAppChildProcess() local1585 final CountDownLatch stopLatch = new CountDownLatch(1); in stopChildProcess() local1611 final CountDownLatch stopLatch = new CountDownLatch(1); in initWaitingForChildProcessGone() local
21 final CountDownLatch stopLatch = new CountDownLatch(1); in testAsyncServiceLifecycle() local
962 final CountDownLatch stopLatch = new CountDownLatch(1); in testTransferToTwice() local
398 final CountDownLatch stopLatch = new CountDownLatch(1); in testTransferToTwice() local