CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(1000, 3));
client.start();
InterProcessMutex lock = new InterProcessMutex(client, "/lock");
try {
if (lock.acquire(10, TimeUnit.SECONDS)) {
// ...
}
} finally {
lock.release();
}
