Package org.awaitility.core

Class Uninterruptibles

java.lang.Object

org.awaitility.core.Uninterruptibles

class Uninterruptibles
extends Object

These code snippets are copied from the Guava library (e.g. Uninterruptibles#sleepUninterruptibly) to solve issue 134.

Constructor Summary

Constructors

Constructor	Description
Uninterruptibles()

Method Summary

Modifier and Type	Method	Description
(package private) static <V> V	getUninterruptibly(Future<V> future)	Invokes future.get() uninterruptibly.
(package private) static <V> V	getUninterruptibly(Future<V> future, long timeout, TimeUnit unit)	Invokes future.get(timeout, unit) uninterruptibly.
(package private) static <V> V	getUninterruptibly(Future<V> future, Duration timeout)	Invokes future.get(timeout, unit) uninterruptibly.
private static long	saturatedToNanos(Duration duration)	Returns the number of nanoseconds of the given duration without throwing or overflowing.
(package private) static void	shutdownUninterruptibly(ExecutorService executor, long timeout, TimeUnit unit)	Shuts down an executor service uninterruptedly Note that this method is created by Johan Haleby and is thus not covered by the Guava license
(package private) static void	sleepUninterruptibly(long sleepFor, TimeUnit unit)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Uninterruptibles

Uninterruptibles()

Method Details

sleepUninterruptibly

static void sleepUninterruptibly(long sleepFor,
 TimeUnit unit)

getUninterruptibly

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

Invokes future.get() uninterruptibly.

Throws:

ExecutionException - if the computation threw an exception

CancellationException - if the computation was cancelled

getUninterruptibly

static <V> V getUninterruptibly(Future<V> future,
 Duration timeout)
                         throws ExecutionException,
TimeoutException

Invokes future.get(timeout, unit) uninterruptibly.

Throws:

ExecutionException - if the computation threw an exception

CancellationException - if the computation was cancelled

TimeoutException - if the wait timed out

getUninterruptibly

static <V> V getUninterruptibly(Future<V> future,
 long timeout,
 TimeUnit unit)
                         throws ExecutionException,
TimeoutException

Invokes future.get(timeout, unit) uninterruptibly.

Throws:

ExecutionException - if the computation threw an exception

CancellationException - if the computation was cancelled

TimeoutException - if the wait timed out

shutdownUninterruptibly

static void shutdownUninterruptibly(ExecutorService executor,
 long timeout,
 TimeUnit unit)

Shuts down an executor service uninterruptedly Note that this method is created by Johan Haleby and is thus not covered by the Guava license

Parameters:

executor - The executor service to shut down

timeout - The timeout amount

unit - The time unit

saturatedToNanos

private static long saturatedToNanos(Duration duration)

Returns the number of nanoseconds of the given duration without throwing or overflowing.

Instead of throwing ArithmeticException, this method silently saturates to either Long.MAX_VALUE or Long.MIN_VALUE. This behavior can be useful when decomposing a duration in order to call a legacy API which requires a long, TimeUnit pair.