Uses of Interface
org.apache.curator.framework.recipes.locks.InterProcessLock
-
Uses of InterProcessLock in org.apache.curator.framework.recipes.locks
Modifier and TypeClassDescriptionclass
A container that manages multiple locks as a single entity.class
A re-entrant mutex that works across JVMs.static class
static class
class
A NON re-entrant mutex that works across JVMs.Modifier and TypeMethodDescriptionprotected void
Locker.acquireLock
(InterProcessLock lock) protected boolean
Locker.acquireLock
(InterProcessLock lock, long timeout, TimeUnit unit) ModifierConstructorDescriptionLocker
(InterProcessLock lock) Locker
(InterProcessLock lock, long timeout, TimeUnit unit) ModifierConstructorDescriptionCreates a multi lock of any type of inter process lock -
Uses of InterProcessLock in org.apache.curator.x.async
Modifier and TypeMethodDescriptionstatic CompletionStage
<Void> AsyncWrappers.lockAsync
(InterProcessLock lock) Attempt to acquire the given lock asynchronously without timeout using theForkJoinPool.commonPool()
.static CompletionStage
<Void> AsyncWrappers.lockAsync
(InterProcessLock lock, long timeout, TimeUnit unit) Attempt to acquire the given lock asynchronously using the given timeout using theForkJoinPool.commonPool()
.static CompletionStage
<Void> AsyncWrappers.lockAsync
(InterProcessLock lock, long timeout, TimeUnit unit, Executor executor) Attempt to acquire the given lock asynchronously using the given timeout and executor.static CompletionStage
<Void> AsyncWrappers.lockAsync
(InterProcessLock lock, Executor executor) Attempt to acquire the given lock asynchronously using the given executor and without a timeout.static CompletionStage
<Boolean> AsyncWrappers.lockAsyncIf
(InterProcessLock lock, long timeout, TimeUnit unit) Attempt to acquire the given lock asynchronously using the given timeout using theForkJoinPool.commonPool()
.static CompletionStage
<Boolean> AsyncWrappers.lockAsyncIf
(InterProcessLock lock, long timeout, TimeUnit unit, Executor executor) Attempt to acquire the given lock asynchronously using the given timeout and executor.static void
AsyncWrappers.release
(InterProcessLock lock) Release the lock and wrap any exception inRuntimeException
static void
AsyncWrappers.release
(InterProcessLock lock, boolean ignoreNoLockExceptions) Release the lock and wrap any exception inRuntimeException