Method Detail

• awaitUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static void awaitUninterruptibly(CountDownLatch latch)

  Invokes latch.await() uninterruptibly.

• awaitUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static boolean awaitUninterruptibly(CountDownLatch latch,
                                                  long timeout,
                                                  TimeUnit unit)

  Invokes latch.await(timeout, unit) uninterruptibly.

• joinUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static void joinUninterruptibly(Thread toJoin)

  Invokes toJoin.join() uninterruptibly.

• getUninterruptibly

  public static <V> V getUninterruptibly(Future<V> future)
                              throws ExecutionException

  Invokes future.get() uninterruptibly. To get uninterruptibility and remove checked exceptions, see Futures.getUnchecked(java.util.concurrent.Future<V>).

  If instead, you wish to treat InterruptedException uniformly with other exceptions, see Futures.getChecked.

  Throws:

  ExecutionException - if the computation threw an exception

  CancellationException - if the computation was cancelled

• getUninterruptibly

  @GwtIncompatible(value="TODO")
  public static <V> V getUninterruptibly(Future<V> future,
                                              long timeout,
                                              TimeUnit unit)
                              throws ExecutionException,
                                     TimeoutException

  Invokes future.get(timeout, unit) uninterruptibly.

  If instead, you wish to treat InterruptedException uniformly with other exceptions, see Futures.getChecked.

  Throws:

  ExecutionException - if the computation threw an exception

  CancellationException - if the computation was cancelled

  TimeoutException - if the wait timed out

• joinUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static void joinUninterruptibly(Thread toJoin,
                                              long timeout,
                                              TimeUnit unit)

  Invokes unit.timedJoin(toJoin, timeout) uninterruptibly.

• takeUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static <E> E takeUninterruptibly(BlockingQueue<E> queue)

  Invokes queue.take() uninterruptibly.

• putUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static <E> void putUninterruptibly(BlockingQueue<E> queue,
                                                 E element)

  Invokes queue.put(element) uninterruptibly.

  Throws:

  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

• sleepUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static void sleepUninterruptibly(long sleepFor,
                                               TimeUnit unit)

  Invokes unit.sleep(sleepFor) uninterruptibly.

• tryAcquireUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static boolean tryAcquireUninterruptibly(Semaphore semaphore,
                                                       long timeout,
                                                       TimeUnit unit)

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

  Since:

  18.0

• tryAcquireUninterruptibly

  @GwtIncompatible(value="concurrency")
  public static boolean tryAcquireUninterruptibly(Semaphore semaphore,
                                                       int permits,
                                                       long timeout,
                                                       TimeUnit unit)

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

  Since:

  18.0