org.corfudb.util

Class CFUtils

java.lang.Object

org.corfudb.util.CFUtils

public final class CFUtils
extends Object

Created by mwei on 9/15/15.

Method Summary

Modifier and Type	Method and Description
static <T> CompletableFuture<Void>	allOf(Collection<CompletableFuture<T>> futures)
static <T> CompletableFuture<T>	failAfter(Duration duration) Generates a completable future which times out.
static <T> T	getUninterruptibly(Future<T> future)
static <T,A extends Throwable> T	getUninterruptibly(Future<T> future, Class<A> throwableA)
static <T,A extends Throwable,B extends Throwable> T	getUninterruptibly(Future<T> future, Class<A> throwableA, Class<B> throwableB)
static <T,A extends Throwable,B extends Throwable,C extends Throwable> T	getUninterruptibly(Future<T> future, Class<A> throwableA, Class<B> throwableB, Class<C> throwableC)
static <T,A extends Throwable,B extends Throwable,C extends Throwable,D extends Throwable> T	getUninterruptibly(Future<T> future, Class<A> throwableA, Class<B> throwableB, Class<C> throwableC, Class<D> throwableD)
static void	runAfter(Duration duration, Runnable toRun) Schedules a runnable after a given time
static void	unwrap(Throwable throwable) Unwraps ExecutionException thrown from a CompletableFuture.
static <A extends Throwable> void	unwrap(Throwable throwable, Class<A> throwableA) Unwraps ExecutionException thrown from a CompletableFuture.
static <T> CompletableFuture<T>	within(CompletableFuture<T> future, Duration duration) Takes a completable future, and ensures that it completes within a certain duration.

Methods inherited from class java.lang.Object

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

Method Detail

getUninterruptibly

public static <T,A extends Throwable,B extends Throwable,C extends Throwable,D extends Throwable> T getUninterruptibly(Future<T> future,
                                                                                                                       Class<A> throwableA,
                                                                                                                       Class<B> throwableB,
                                                                                                                       Class<C> throwableC,
                                                                                                                       Class<D> throwableD)
                                                                                                                throws A extends Throwable,
                                                                                                                       B extends Throwable,
                                                                                                                       C extends Throwable,
                                                                                                                       D extends Throwable

Throws:

A extends Throwable

getUninterruptibly

public static <T,A extends Throwable,B extends Throwable,C extends Throwable> T getUninterruptibly(Future<T> future,
                                                                                                   Class<A> throwableA,
                                                                                                   Class<B> throwableB,
                                                                                                   Class<C> throwableC)
                                                                                            throws A extends Throwable,
                                                                                                   B extends Throwable,
                                                                                                   C extends Throwable

Throws:

A extends Throwable

getUninterruptibly

public static <T,A extends Throwable,B extends Throwable> T getUninterruptibly(Future<T> future,
                                                                               Class<A> throwableA,
                                                                               Class<B> throwableB)
                                                                        throws A extends Throwable,
                                                                               B extends Throwable

Throws:

A extends Throwable

getUninterruptibly

public static <T,A extends Throwable> T getUninterruptibly(Future<T> future,
                                                           Class<A> throwableA)
                                                    throws A extends Throwable

Throws:

A extends Throwable

getUninterruptibly

public static <T> T getUninterruptibly(Future<T> future)

failAfter

public static <T> CompletableFuture<T> failAfter(Duration duration)

Generates a completable future which times out. inspired by NoBlogDefFound: http://www.nurkiewicz.com/2014/12/asynchronous-timeouts-with.html

Type Parameters:

T - Ignored, since the future will always timeout.

Parameters:

duration - The duration to timeout after.

Returns:

A completable future that will time out.

runAfter

public static void runAfter(Duration duration,
                            Runnable toRun)

Schedules a runnable after a given time

Parameters:

duration - The duration to timeout after.

within

public static <T> CompletableFuture<T> within(CompletableFuture<T> future,
                                              Duration duration)

Takes a completable future, and ensures that it completes within a certain duration. If it does not, it is cancelled and completes exceptionally with TimeoutException. inspired by NoBlogDefFound: www.nurkiewicz.com/2014/12/asynchronous-timeouts-with.html

Type Parameters:

T - The return type of the future.

Parameters:

future - The completable future that must be completed within duration.

duration - The duration the future must be completed in.

Returns:

A completable future which completes with the original value if completed within duration, otherwise completes exceptionally with TimeoutException.

allOf

public static <T> CompletableFuture<Void> allOf(Collection<CompletableFuture<T>> futures)

unwrap

public static <A extends Throwable> void unwrap(Throwable throwable,
                                                Class<A> throwableA)
                                         throws A extends Throwable

Unwraps ExecutionException thrown from a CompletableFuture.

Type Parameters:

A - Class of checked exception.

Parameters:

throwable - Throwable to unwrap.

throwableA - Checked Exception to expose.

Throws:

A - Throws checked exception.

A extends Throwable

unwrap

public static void unwrap(Throwable throwable)

Unwraps ExecutionException thrown from a CompletableFuture.

Parameters:

throwable - Throwable to unwrap.