Package com.google.common.util.concurrent

Class Uninterruptibles

com.google.common.util.concurrent.Uninterruptibles

@GwtCompatible(emulated=true)
public final class Uninterruptibles
extends 

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.

Since:

10.0

Author:

Anthony Zana

Method Summary

Modifier and Type	Method	Description
static void	executor)	Invokes executor. uninterruptibly with no timeout.
static boolean	executor, long timeout, unit)	Invokes executor. uninterruptibly.
static boolean	executor, timeout)	Invokes executor. uninterruptibly.
static void	latch)	Invokes latch. uninterruptibly.
static boolean	latch, long timeout, unit)	Invokes latch. uninterruptibly.
static boolean	latch, timeout)	Invokes latch. uninterruptibly.
static boolean	condition, long timeout, unit)	Invokes condition. uninterruptibly.
static boolean	condition, timeout)	Invokes condition. uninterruptibly.
static <V> V	<V> future)	Invokes future. uninterruptibly.
static <V> V	<V> future, long timeout, unit)	Invokes future. uninterruptibly.
static <V> V	<V> future, timeout)	Invokes future. uninterruptibly.
static void	toJoin)	Invokes toJoin. uninterruptibly.
static void	toJoin, long timeout, unit)	Invokes unit. uninterruptibly.
static void	toJoin, timeout)	Invokes unit. uninterruptibly.
static <E> void	<E> queue, E element)	Invokes queue. uninterruptibly.
static void	sleepUninterruptibly(long sleepFor, unit)	Invokes unit. uninterruptibly.
static void	sleepFor)	Invokes unit. uninterruptibly.
static <E> E	<E> queue)	Invokes queue. uninterruptibly.
static boolean	semaphore, int permits, long timeout, unit)	Invokes semaphore. uninterruptibly.
static boolean	semaphore, int permits, timeout)	Invokes semaphore. uninterruptibly.
static boolean	semaphore, long timeout, unit)	Invokes semaphore. uninterruptibly.
static boolean	semaphore, timeout)	Invokes semaphore. uninterruptibly.
static boolean	lock, long timeout, unit)	Invokes lock. uninterruptibly.
static boolean	lock, timeout)	Invokes lock. uninterruptibly.

Methods inherited from class java.lang.

, , , , , , , , , ,

Method Detail

awaitUninterruptibly

@GwtIncompatible
public static void  latch)

Invokes latch. uninterruptibly.

awaitUninterruptibly

@GwtIncompatible
@Beta
public static boolean  latch,
                                            timeout)

Invokes latch. uninterruptibly.

Since:

28.0

awaitUninterruptibly

@GwtIncompatible
public static boolean  latch,
                                           long timeout,
                                            unit)

Invokes latch. uninterruptibly.

awaitUninterruptibly

@GwtIncompatible
@Beta
public static boolean  condition,
                                            timeout)

Invokes condition. uninterruptibly.

Since:

28.0

awaitUninterruptibly

@GwtIncompatible
public static boolean  condition,
                                           long timeout,
                                            unit)

Invokes condition. uninterruptibly.

Since:

23.6

joinUninterruptibly

@GwtIncompatible
public static void  toJoin)

Invokes toJoin. uninterruptibly.

joinUninterruptibly

@GwtIncompatible
@Beta
public static void  toJoin,
                                        timeout)

Invokes unit. uninterruptibly.

Since:

28.0

joinUninterruptibly

@GwtIncompatible
public static void  toJoin,
                                       long timeout,
                                        unit)

Invokes unit. uninterruptibly.

getUninterruptibly

public static <V> V <V> future)
                                throws 

Invokes future. uninterruptibly.

Similar methods:

• To retrieve a result from a Future that is already done, use Futures.getDone.
• To treat uniformly with other exceptions, use Futures.getChecked.
• To get uninterruptibility and remove checked exceptions, use Futures.getUnchecked(java.util.concurrent.Future<V>).

Throws:

- if the computation threw an exception

- if the computation was cancelled

getUninterruptibly

@GwtIncompatible
@Beta
public static <V> V <V> future,
                                        timeout)
                                throws ,
                                       

Invokes future. uninterruptibly.

Similar methods:

• To retrieve a result from a Future that is already done, use Futures.getDone.
• To treat uniformly with other exceptions, use Futures.getChecked.
• To get uninterruptibility and remove checked exceptions, use Futures.getUnchecked(java.util.concurrent.Future<V>).

Throws:

- if the computation threw an exception

- if the computation was cancelled

- if the wait timed out

Since:

28.0

getUninterruptibly

@GwtIncompatible
public static <V> V <V> future,
                                       long timeout,
                                        unit)
                                throws ,
                                       

Invokes future. uninterruptibly.

Similar methods:

• To retrieve a result from a Future that is already done, use Futures.getDone.
• To treat uniformly with other exceptions, use Futures.getChecked.
• To get uninterruptibility and remove checked exceptions, use Futures.getUnchecked(java.util.concurrent.Future<V>).

Throws:

- if the computation threw an exception

- if the computation was cancelled

- if the wait timed out

takeUninterruptibly

@GwtIncompatible
public static <E> E <E> queue)

Invokes queue. uninterruptibly.

putUninterruptibly

@GwtIncompatible
public static <E> void <E> queue,
                                          E element)

Invokes queue. uninterruptibly.

Throws:

- if the class of the specified element prevents it from being added to the given queue

- if some property of the specified element prevents it from being added to the given queue

sleepUninterruptibly

@GwtIncompatible
@Beta
public static void  sleepFor)

Invokes unit. uninterruptibly.

Since:

28.0

sleepUninterruptibly

@GwtIncompatible
public static void sleepUninterruptibly(long sleepFor,
                                         unit)

Invokes unit. uninterruptibly.

tryAcquireUninterruptibly

@GwtIncompatible
@Beta
public static boolean  semaphore,
                                                 timeout)

Invokes semaphore. uninterruptibly.

Since:

28.0

tryAcquireUninterruptibly

@GwtIncompatible
public static boolean  semaphore,
                                                long timeout,
                                                 unit)

Invokes semaphore. uninterruptibly.

Since:

18.0

tryAcquireUninterruptibly

@GwtIncompatible
@Beta
public static boolean  semaphore,
                                                int permits,
                                                 timeout)

Invokes semaphore. uninterruptibly.

Since:

28.0

tryAcquireUninterruptibly

@GwtIncompatible
public static boolean  semaphore,
                                                int permits,
                                                long timeout,
                                                 unit)

Invokes semaphore. uninterruptibly.

Since:

18.0

tryLockUninterruptibly

@GwtIncompatible
@Beta
public static boolean  lock,
                                              timeout)

Invokes lock. uninterruptibly.

Since:

30.0

tryLockUninterruptibly

@GwtIncompatible
public static boolean  lock,
                                             long timeout,
                                              unit)

Invokes lock. uninterruptibly.

Since:

30.0

awaitTerminationUninterruptibly

@Beta
@GwtIncompatible
public static void  executor)

Invokes executor. uninterruptibly with no timeout.

Since:

30.0

awaitTerminationUninterruptibly

@Beta
@GwtIncompatible
public static boolean  executor,
                                                       timeout)

Invokes executor. uninterruptibly.

Since:

30.0

awaitTerminationUninterruptibly

@Beta
@GwtIncompatible
public static boolean  executor,
                                                      long timeout,
                                                       unit)

Invokes executor. uninterruptibly.

Since:

30.0