Package | Description |
---|---|
org.apache.curator.framework.recipes.locks | |
org.apache.curator.x.async |
Modifier and Type | Class and Description |
---|---|
class |
InterProcessMultiLock
A container that manages multiple locks as a single entity.
|
class |
InterProcessMutex
A re-entrant mutex that works across JVMs.
|
static class |
InterProcessReadWriteLock.ReadLock |
static class |
InterProcessReadWriteLock.WriteLock |
class |
InterProcessSemaphoreMutex
A NON re-entrant mutex that works across JVMs.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Locker.acquireLock(InterProcessLock lock) |
protected boolean |
Locker.acquireLock(InterProcessLock lock,
long timeout,
TimeUnit unit) |
Constructor and Description |
---|
Locker(InterProcessLock lock) |
Locker(InterProcessLock lock,
long timeout,
TimeUnit unit) |
Constructor and Description |
---|
InterProcessMultiLock(List<InterProcessLock> locks)
Creates a multi lock of any type of inter process lock
|
Modifier and Type | Method and Description |
---|---|
static CompletionStage<Void> |
AsyncWrappers.lockAsync(InterProcessLock lock)
Attempt to acquire the given lock asynchronously without timeout using the
ForkJoinPool.commonPool() . |
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<Void> |
AsyncWrappers.lockAsync(InterProcessLock lock,
long timeout,
TimeUnit unit)
Attempt to acquire the given lock asynchronously using the given timeout using the
ForkJoinPool.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<Boolean> |
AsyncWrappers.lockAsyncIf(InterProcessLock lock,
long timeout,
TimeUnit unit)
Attempt to acquire the given lock asynchronously using the given timeout using the
ForkJoinPool.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 in
RuntimeException |
static void |
AsyncWrappers.release(InterProcessLock lock,
boolean ignoreNoLockExceptions)
Release the lock and wrap any exception in
RuntimeException |
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.