Searched refs:finishedRunLatch (Results 1 – 1 of 1) sorted by relevance
97 CountDownLatch finishedRunLatch = new CountDownLatch(1); in testProcessCrash() local113 t.addTransactionCommittedListener(Runnable::run, finishedRunLatch::countDown); in testProcessCrash()119 finishedRunLatch.await(5, TimeUnit.SECONDS); in testProcessCrash()125 finishedRunLatch.getCount()); in testProcessCrash()