public final class Uninterruptibles
extends java.lang.Object
Modifier | Constructor and Description |
---|---|
private |
Uninterruptibles() |
Modifier and Type | Method and Description |
---|---|
static void |
awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor)
Invokes
executor. awaitTermination(long, TimeUnit) uninterruptibly with no timeout. |
static boolean |
awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor,
java.time.Duration timeout)
Invokes
executor. awaitTermination(long, TimeUnit) uninterruptibly. |
static boolean |
awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
executor. awaitTermination(long, TimeUnit) uninterruptibly. |
static boolean |
awaitUninterruptibly(java.util.concurrent.locks.Condition condition,
java.time.Duration timeout)
Invokes
condition. await(timeout, unit)
uninterruptibly. |
static boolean |
awaitUninterruptibly(java.util.concurrent.locks.Condition condition,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
condition. await(timeout, unit)
uninterruptibly. |
static void |
awaitUninterruptibly(java.util.concurrent.CountDownLatch latch)
Invokes
latch. await() uninterruptibly. |
static boolean |
awaitUninterruptibly(java.util.concurrent.CountDownLatch latch,
java.time.Duration timeout)
Invokes
latch. await(timeout, unit)
uninterruptibly. |
static boolean |
awaitUninterruptibly(java.util.concurrent.CountDownLatch latch,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
latch. await(timeout, unit)
uninterruptibly. |
static <V> V |
getUninterruptibly(java.util.concurrent.Future<V> future)
Invokes
future. get() uninterruptibly. |
static <V> V |
getUninterruptibly(java.util.concurrent.Future<V> future,
java.time.Duration timeout)
Invokes
future. get(timeout, unit) uninterruptibly. |
static <V> V |
getUninterruptibly(java.util.concurrent.Future<V> future,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
future. get(timeout, unit) uninterruptibly. |
static void |
joinUninterruptibly(java.lang.Thread toJoin)
Invokes
toJoin. join() uninterruptibly. |
static void |
joinUninterruptibly(java.lang.Thread toJoin,
java.time.Duration timeout)
Invokes
unit. timedJoin(toJoin, timeout)
uninterruptibly. |
static void |
joinUninterruptibly(java.lang.Thread toJoin,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
unit. timedJoin(toJoin, timeout)
uninterruptibly. |
static <E> void |
putUninterruptibly(java.util.concurrent.BlockingQueue<E> queue,
E element)
Invokes
queue. put(element) uninterruptibly. |
static void |
sleepUninterruptibly(java.time.Duration sleepFor)
Invokes
unit. sleep(sleepFor) uninterruptibly. |
static void |
sleepUninterruptibly(long sleepFor,
java.util.concurrent.TimeUnit unit)
Invokes
unit. sleep(sleepFor) uninterruptibly. |
static <E> E |
takeUninterruptibly(java.util.concurrent.BlockingQueue<E> queue)
Invokes
queue. take() uninterruptibly. |
static boolean |
tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore,
java.time.Duration timeout)
Invokes
semaphore. tryAcquire(1,
timeout, unit) uninterruptibly. |
static boolean |
tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore,
int permits,
java.time.Duration timeout)
Invokes
semaphore. tryAcquire(permits,
timeout, unit) uninterruptibly. |
static boolean |
tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore,
int permits,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
semaphore. tryAcquire(permits,
timeout, unit) uninterruptibly. |
static boolean |
tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
semaphore. tryAcquire(1,
timeout, unit) uninterruptibly. |
static boolean |
tryLockUninterruptibly(java.util.concurrent.locks.Lock lock,
java.time.Duration timeout)
Invokes
lock. tryLock(timeout, unit)
uninterruptibly. |
static boolean |
tryLockUninterruptibly(java.util.concurrent.locks.Lock lock,
long timeout,
java.util.concurrent.TimeUnit unit)
Invokes
lock. tryLock(timeout, unit)
uninterruptibly. |
public static void awaitUninterruptibly(java.util.concurrent.CountDownLatch latch)
latch.
await()
uninterruptibly.public static boolean awaitUninterruptibly(java.util.concurrent.CountDownLatch latch, java.time.Duration timeout)
latch.
await(timeout, unit)
uninterruptibly.public static boolean awaitUninterruptibly(java.util.concurrent.CountDownLatch latch, long timeout, java.util.concurrent.TimeUnit unit)
latch.
await(timeout, unit)
uninterruptibly.public static boolean awaitUninterruptibly(java.util.concurrent.locks.Condition condition, java.time.Duration timeout)
condition.
await(timeout, unit)
uninterruptibly.public static boolean awaitUninterruptibly(java.util.concurrent.locks.Condition condition, long timeout, java.util.concurrent.TimeUnit unit)
condition.
await(timeout, unit)
uninterruptibly.public static void joinUninterruptibly(java.lang.Thread toJoin)
toJoin.
join()
uninterruptibly.public static void joinUninterruptibly(java.lang.Thread toJoin, java.time.Duration timeout)
unit.
timedJoin(toJoin, timeout)
uninterruptibly.public static void joinUninterruptibly(java.lang.Thread toJoin, long timeout, java.util.concurrent.TimeUnit unit)
unit.
timedJoin(toJoin, timeout)
uninterruptibly.public static <V> V getUninterruptibly(java.util.concurrent.Future<V> future) throws java.util.concurrent.ExecutionException
future.
get()
uninterruptibly.
Similar methods:
Future
that is already done, use Futures.getDone
.
InterruptedException
uniformly with other exceptions, use Futures.getChecked
.
Futures.getUnchecked(java.util.concurrent.Future<V>)
.
java.util.concurrent.ExecutionException
- if the computation threw an exceptionjava.util.concurrent.CancellationException
- if the computation was cancelledpublic static <V> V getUninterruptibly(java.util.concurrent.Future<V> future, java.time.Duration timeout) throws java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
future.
get(timeout, unit)
uninterruptibly.
Similar methods:
Future
that is already done, use Futures.getDone
.
InterruptedException
uniformly with other exceptions, use Futures.getChecked
.
Futures.getUnchecked(java.util.concurrent.Future<V>)
.
java.util.concurrent.ExecutionException
- if the computation threw an exceptionjava.util.concurrent.CancellationException
- if the computation was cancelledjava.util.concurrent.TimeoutException
- if the wait timed outpublic static <V> V getUninterruptibly(java.util.concurrent.Future<V> future, long timeout, java.util.concurrent.TimeUnit unit) throws java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
future.
get(timeout, unit)
uninterruptibly.
Similar methods:
Future
that is already done, use Futures.getDone
.
InterruptedException
uniformly with other exceptions, use Futures.getChecked
.
Futures.getUnchecked(java.util.concurrent.Future<V>)
.
java.util.concurrent.ExecutionException
- if the computation threw an exceptionjava.util.concurrent.CancellationException
- if the computation was cancelledjava.util.concurrent.TimeoutException
- if the wait timed outpublic static <E> E takeUninterruptibly(java.util.concurrent.BlockingQueue<E> queue)
queue.
take()
uninterruptibly.public static <E> void putUninterruptibly(java.util.concurrent.BlockingQueue<E> queue, E element)
queue.
put(element)
uninterruptibly.java.lang.ClassCastException
- if the class of the specified element prevents it from being added
to the given queuejava.lang.IllegalArgumentException
- if some property of the specified element prevents it from
being added to the given queuepublic static void sleepUninterruptibly(java.time.Duration sleepFor)
unit.
sleep(sleepFor)
uninterruptibly.public static void sleepUninterruptibly(long sleepFor, java.util.concurrent.TimeUnit unit)
unit.
sleep(sleepFor)
uninterruptibly.public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, java.time.Duration timeout)
semaphore.
tryAcquire(1,
timeout, unit)
uninterruptibly.public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, long timeout, java.util.concurrent.TimeUnit unit)
semaphore.
tryAcquire(1,
timeout, unit)
uninterruptibly.public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, int permits, java.time.Duration timeout)
semaphore.
tryAcquire(permits,
timeout, unit)
uninterruptibly.public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, int permits, long timeout, java.util.concurrent.TimeUnit unit)
semaphore.
tryAcquire(permits,
timeout, unit)
uninterruptibly.public static boolean tryLockUninterruptibly(java.util.concurrent.locks.Lock lock, java.time.Duration timeout)
lock.
tryLock(timeout, unit)
uninterruptibly.public static boolean tryLockUninterruptibly(java.util.concurrent.locks.Lock lock, long timeout, java.util.concurrent.TimeUnit unit)
lock.
tryLock(timeout, unit)
uninterruptibly.public static void awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor)
executor.
awaitTermination(long, TimeUnit)
uninterruptibly with no timeout.public static boolean awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor, java.time.Duration timeout)
executor.
awaitTermination(long, TimeUnit)
uninterruptibly.public static boolean awaitTerminationUninterruptibly(java.util.concurrent.ExecutorService executor, long timeout, java.util.concurrent.TimeUnit unit)
executor.
awaitTermination(long, TimeUnit)
uninterruptibly.