org.infinispan.util.concurrent

Class CompletableFutures

java.lang.Object

org.infinispan.util.concurrent.CompletableFutures

public class CompletableFutures
extends Object

Utility methods connecting CompletableFuture futures and our NotifyingNotifiableFuture futures.

Since:

8.0

Author:

Dan Berindei

Field Summary

Fields

Modifier and Type	Field and Description
static long	BIG_DELAY_NANOS

Constructor Summary

Constructors

Constructor and Description
CompletableFutures()

Method Summary

Modifier and Type	Method and Description
static boolean	await(CompletableFuture<?> future, long time, TimeUnit unit) It waits until the CompletableFuture is completed.
static <T> T	await(CompletableFuture<T> future) Wait for a long time until the CompletableFuture is completed.
static <T> CompletableFuture<T>	completedExceptionFuture(Throwable ex)
static <T> void	connect(NotifyingNotifiableFuture<T> sink, CompletableFuture<T> source)
static <K,V> CompletableFuture<Map<K,V>>	returnEmptyMap()
static <T> CompletableFuture<List<T>>	sequence(List<CompletableFuture<T>> futures)
static <T> CompletableFuture<T>	toCompletableFuture(NotifyingFuture<T> source)

Methods inherited from class java.lang.Object

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

Field Detail

BIG_DELAY_NANOS

public static final long BIG_DELAY_NANOS

Constructor Detail

CompletableFutures

public CompletableFutures()

Method Detail

returnEmptyMap

public static <K,V> CompletableFuture<Map<K,V>> returnEmptyMap()

connect

public static <T> void connect(NotifyingNotifiableFuture<T> sink,
                               CompletableFuture<T> source)

toCompletableFuture

public static <T> CompletableFuture<T> toCompletableFuture(NotifyingFuture<T> source)

sequence

public static <T> CompletableFuture<List<T>> sequence(List<CompletableFuture<T>> futures)

completedExceptionFuture

public static <T> CompletableFuture<T> completedExceptionFuture(Throwable ex)

await

public static boolean await(CompletableFuture<?> future,
                            long time,
                            TimeUnit unit)
                     throws InterruptedException

It waits until the CompletableFuture is completed.

It ignore if the CompletableFuture is completed normally or exceptionally.

Parameters:

future - the CompletableFuture to test.

time - the timeout.

unit - the timeout unit.

Returns:

true if completed, false if timed out.

Throws:

InterruptedException - if interrupted while waiting.

NullPointerException - if future or unit is null.

await

public static <T> T await(CompletableFuture<T> future)
                   throws ExecutionException,
                          InterruptedException

Wait for a long time until the CompletableFuture is completed.

Type Parameters:

T - the return type.

Parameters:

future - the CompletableFuture.

Returns:

the result value.

Throws:

ExecutionException - if the CompletableFuture completed exceptionally.

InterruptedException - if the current thread was interrupted while waiting.