Top Description Constructors Methods
com.google.common.util.concurrent

public final Class Uninterruptibles

extends Object
Class Inheritance
Annotations
@GwtCompatible
emulated:true
@ElementTypesAreNonnullByDefault
Static Imports
com.google.common.base.Verify.verify, com.google.common.util.concurrent.Internal.toNanosSaturated, java.util.concurrent.TimeUnit.NANOSECONDS

Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is interrupted during such a call, the call continues to block until the result is available or the timeout elapses, and only then re-interrupts the thread.
Author
Anthony Zana
Since
10.0

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public static void
public static boolean
awaitTerminationUninterruptibly(ExecutorService executor, Duration timeout)

Invokes executor.

public static boolean
awaitTerminationUninterruptibly(ExecutorService executor, long timeout, TimeUnit unit)

Invokes executor.

public static void
awaitUninterruptibly(CountDownLatch latch)

Invokes latch.

public static boolean
awaitUninterruptibly(CountDownLatch latch, Duration timeout)

Invokes latch.

public static boolean
awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit)

Invokes latch.

public static boolean
awaitUninterruptibly(Condition condition, Duration timeout)

Invokes condition.

public static boolean
awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit)

Invokes condition.

public static <V extends @Nullable Object> V
getUninterruptibly(Future<V> future)

Invokes future.

public static <V extends @Nullable Object> V
getUninterruptibly(Future<V> future, Duration timeout)

Invokes future.

public static <V extends @Nullable Object> V
getUninterruptibly(Future<V> future, long timeout, TimeUnit unit)

Invokes future.

public static void
joinUninterruptibly(Thread toJoin)

Invokes toJoin.

public static void
joinUninterruptibly(Thread toJoin, Duration timeout)

Invokes unit.

public static void
joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit)

Invokes unit.

public static <E> void
putUninterruptibly(BlockingQueue<E> queue, E element)

Invokes queue.

public static void
sleepUninterruptibly(Duration sleepFor)

Invokes unit.

public static void
sleepUninterruptibly(long sleepFor, TimeUnit unit)

Invokes unit.

public static <E> E
takeUninterruptibly(BlockingQueue<E> queue)

Invokes queue.

public static boolean
tryAcquireUninterruptibly(Semaphore semaphore, Duration timeout)

Invokes semaphore.

public static boolean
tryAcquireUninterruptibly(Semaphore semaphore, long timeout, TimeUnit unit)

Invokes semaphore.

public static boolean
tryAcquireUninterruptibly(Semaphore semaphore, int permits, Duration timeout)

Invokes semaphore.

public static boolean
tryAcquireUninterruptibly(Semaphore semaphore, int permits, long timeout, TimeUnit unit)

Invokes semaphore.

public static boolean
tryLockUninterruptibly(Lock lock, Duration timeout)

Invokes lock.

public static boolean
tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit)

Invokes lock.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

Uninterruptiblesback to summary
private Uninterruptibles()

Method Detail

awaitTerminationUninterruptiblyback to summary
public static void awaitTerminationUninterruptibly(ExecutorService executor)

Invokes executor.awaitTermination(long, TimeUnit) uninterruptibly with no timeout.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
30.0
awaitTerminationUninterruptiblyback to summary
public static boolean awaitTerminationUninterruptibly(ExecutorService executor, Duration timeout)

Invokes executor.awaitTermination(long, TimeUnit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
30.0
awaitTerminationUninterruptiblyback to summary
public static boolean awaitTerminationUninterruptibly(ExecutorService executor, long timeout, TimeUnit unit)

Invokes executor.awaitTermination(long, TimeUnit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
Since
30.0
awaitUninterruptiblyback to summary
public static void awaitUninterruptibly(CountDownLatch latch)

Invokes latch.await() uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
awaitUninterruptiblyback to summary
public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout)

Invokes latch.await(timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
28.0
awaitUninterruptiblyback to summary
public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit)

Invokes latch.await(timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
awaitUninterruptiblyback to summary
public static boolean awaitUninterruptibly(Condition condition, Duration timeout)

Invokes condition.await(timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
28.0
awaitUninterruptiblyback to summary
public static boolean awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit)

Invokes condition.await(timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
Since
23.6
getUninterruptiblyback to summary
public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future) throws ExecutionException

Invokes future.get() uninterruptibly.

Similar methods:

Annotations
@CanIgnoreReturnValue
@ParametricNullness
Exceptions
ExecutionException:
if the computation threw an exception
CancellationException:
if the computation was cancelled
getUninterruptiblyback to summary
public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future, Duration timeout) throws ExecutionException, TimeoutException

Invokes future.get(timeout, unit) uninterruptibly.

Similar methods:

Annotations
@CanIgnoreReturnValue
@J2ktIncompatible
@GwtIncompatible
@ParametricNullness
Exceptions
ExecutionException:
if the computation threw an exception
TimeoutException:
if the wait timed out
CancellationException:
if the computation was cancelled
Since
28.0
getUninterruptiblyback to summary
public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException

Invokes future.get(timeout, unit) uninterruptibly.

Similar methods:

Annotations
@CanIgnoreReturnValue
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
@ParametricNullness
Exceptions
ExecutionException:
if the computation threw an exception
TimeoutException:
if the wait timed out
CancellationException:
if the computation was cancelled
joinUninterruptiblyback to summary
public static void joinUninterruptibly(Thread toJoin)

Invokes toJoin.join() uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
joinUninterruptiblyback to summary
public static void joinUninterruptibly(Thread toJoin, Duration timeout)

Invokes unit.timedJoin(toJoin, timeout) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
28.0
joinUninterruptiblyback to summary
public static void joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit)

Invokes unit.timedJoin(toJoin, timeout) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
putUninterruptiblyback to summary
public static <E> void putUninterruptibly(BlockingQueue<E> queue, E element)

Invokes queue.put(element) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Exceptions
ClassCastException:
if the class of the specified element prevents it from being added to the given queue
IllegalArgumentException:
if some property of the specified element prevents it from being added to the given queue
sleepUninterruptiblyback to summary
public static void sleepUninterruptibly(Duration sleepFor)

Invokes unit.sleep(sleepFor) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
28.0
sleepUninterruptiblyback to summary
public static void sleepUninterruptibly(long sleepFor, TimeUnit unit)

Invokes unit.sleep(sleepFor) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
takeUninterruptiblyback to summary
public static <E> E takeUninterruptibly(BlockingQueue<E> queue)

Invokes queue.take() uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
tryAcquireUninterruptiblyback to summary
public static boolean tryAcquireUninterruptibly(Semaphore semaphore, Duration timeout)

Invokes semaphore.tryAcquire(1, timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
28.0
tryAcquireUninterruptiblyback to summary
public static boolean tryAcquireUninterruptibly(Semaphore semaphore, long timeout, TimeUnit unit)

Invokes semaphore.tryAcquire(1, timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
Since
18.0
tryAcquireUninterruptiblyback to summary
public static boolean tryAcquireUninterruptibly(Semaphore semaphore, int permits, Duration timeout)

Invokes semaphore.tryAcquire(permits, timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
28.0
tryAcquireUninterruptiblyback to summary
public static boolean tryAcquireUninterruptibly(Semaphore semaphore, int permits, long timeout, TimeUnit unit)

Invokes semaphore.tryAcquire(permits, timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
Since
18.0
tryLockUninterruptiblyback to summary
public static boolean tryLockUninterruptibly(Lock lock, Duration timeout)

Invokes lock.tryLock(timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
Since
30.0
tryLockUninterruptiblyback to summary
public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit)

Invokes lock.tryLock(timeout, unit) uninterruptibly.

Annotations
@J2ktIncompatible
@GwtIncompatible
@SuppressWarnings:GoodTime
Since
30.0