8788899091929394959697
} }); } }); threadGroupRunner.start(); threadGroupRunner.join(); } @Test public void testConcurrentLocking() throws InterruptedException {
137138139140141142143144145146147
} }); } }); threadGroupRunner.start(); threadGroupRunner.join(); assertEquals(1, lockCounter.intValue()); ClusterMutex mutex = clusterLockDao.getClusterMutex(mutexName);
193194195196197198199200201202203
129130131132133134135136137138139
} }); } }); threadGroupRunner.start(); threadGroupRunner.join(); assertEquals(1, executionCounter.get()); assertEquals(1, trueCounter.get()); assertEquals(threads - 1, falseCounter.get());