Concurrency Utilities

KeyedMutexManager.lock("key");
try {
    // Critical section for this key
} finally {
    KeyedMutexManager.unlock("key");
}

KeyedLatchManager.createLatch("key", 3); // Count of 3
KeyedLatchManager.countDown("key");
KeyedLatchManager.await("key"); // Waits until count reaches 0

KeyedSemaphoreManager.createSemaphore("resource", 5); // Max 5 permits
KeyedSemaphoreManager.acquire("resource");
try {
    // Use resource
} finally {
    KeyedSemaphoreManager.release("resource");
}