@Beta @GwtCompatible(emulated=true) public final class Uninterruptibles extends java.lang.Object
Modifier | Constructor and Description |
---|---|
private |
Uninterruptibles() |
Modifier and Type | Method and Description |
---|---|
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,
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,
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,
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(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,
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. |
@GwtIncompatible public static void awaitUninterruptibly(java.util.concurrent.CountDownLatch latch)
latch.
await()
uninterruptibly.@GwtIncompatible public static boolean awaitUninterruptibly(java.util.concurrent.CountDownLatch latch, long timeout, java.util.concurrent.TimeUnit unit)
latch.
await(timeout, unit)
uninterruptibly.@GwtIncompatible public static boolean awaitUninterruptibly(java.util.concurrent.locks.Condition condition, long timeout, java.util.concurrent.TimeUnit unit)
condition.
await(timeout, unit)
uninterruptibly.@GwtIncompatible public static void joinUninterruptibly(java.lang.Thread toJoin)
toJoin.
join()
uninterruptibly.@GwtIncompatible 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 cancelled@GwtIncompatible public 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 out@GwtIncompatible public static <E> E takeUninterruptibly(java.util.concurrent.BlockingQueue<E> queue)
queue.
take()
uninterruptibly.@GwtIncompatible 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 queue@GwtIncompatible public static void sleepUninterruptibly(long sleepFor, java.util.concurrent.TimeUnit unit)
unit.
sleep(sleepFor)
uninterruptibly.@GwtIncompatible public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, long timeout, java.util.concurrent.TimeUnit unit)
semaphore.
tryAcquire(1,
timeout, unit)
uninterruptibly.@GwtIncompatible public static boolean tryAcquireUninterruptibly(java.util.concurrent.Semaphore semaphore, int permits, long timeout, java.util.concurrent.TimeUnit unit)
semaphore.
tryAcquire(permits,
timeout, unit)
uninterruptibly.