public class CuratorLocker
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
(package private) static java.lang.String |
LOCK_PATH_NAME |
Constructor and Description |
---|
CuratorLocker(ServiceSpec serviceSpec) |
Modifier and Type | Method and Description |
---|---|
protected void |
exit()
Broken out into a separate function to allow overrides in tests.
|
protected java.util.concurrent.TimeUnit |
getWaitTimeUnit()
Broken out into a separate function to allow overrides in tests.
|
void |
lock()
Gets an exclusive lock on service-specific ZK node to ensure two schedulers aren't running simultaneously for the
same service.
|
void |
unlock()
Releases the lock previously obtained via
lock() . |
static final java.lang.String LOCK_PATH_NAME
public CuratorLocker(ServiceSpec serviceSpec)
public void lock()
public void unlock()
lock()
.protected java.util.concurrent.TimeUnit getWaitTimeUnit()
protected void exit()