org.spf4j.concurrent

Class Futures

java.lang.Object

org.spf4j.concurrent.Futures

public final class Futures
extends Object

Author:

zoly

Method Summary

Modifier and Type	Method and Description
static RuntimeException	cancelAll(boolean mayInterrupt, Future[] futures, int from)
static RuntimeException	cancelAll(boolean mayInterrupt, Future<?>... futures)
static RuntimeException	cancelAll(boolean mayInterrupt, Iterator<Future<?>> iterator)
static Pair<Map<Future,Object>,Exception>	getAll(long timeoutMillis, Future... futures)
static Pair<Map<Future,Object>,Exception>	getAll(long timeoutMillis, Iterable<Future> futures)
static <T> Exception	getAllWithDeadlineNanos(long deadlineNanos, BiConsumer<Future<T>,T> consumer, Future<T>... futures)
static <T> Exception	getAllWithDeadlineNanos(long deadlineNanos, BiConsumer<Future<T>,T> consumer, Iterable<Future<T>> futures)
static Pair<Map<Future,Object>,Exception>	getAllWithDeadlineNanos(long deadlineNanos, Future... futures)
static Pair<Map<Future,Object>,Exception>	getAllWithDeadlineNanos(long deadlineNanos, Iterable<Future> futures)
static Exception	getAllWithDeadlineNanosRetVoid(long deadlineNanos, Future... futures) Gets all futures resuls for futures that return Void (no return).
static <T> List<Future<T>>	timedOutFutures(int copies, TimeoutException ex)

Methods inherited from class java.lang.Object

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

Method Detail

cancelAll

@Nullable
 @CheckReturnValue
public static RuntimeException cancelAll(boolean mayInterrupt,
                                                                      Future<?>... futures)

cancelAll

@Nullable
 @CheckReturnValue
public static RuntimeException cancelAll(boolean mayInterrupt,
                                                                      Future[] futures,
                                                                      int from)

cancelAll

@Nullable
public static RuntimeException cancelAll(boolean mayInterrupt,
                                                   Iterator<Future<?>> iterator)

getAll

@CheckReturnValue
 @Nonnull
public static Pair<Map<Future,Object>,Exception> getAll(long timeoutMillis,
                                                                                    Future... futures)

getAllWithDeadlineNanos

@CheckReturnValue
 @Nonnull
public static Pair<Map<Future,Object>,Exception> getAllWithDeadlineNanos(long deadlineNanos,
                                                                                                     Future... futures)

getAllWithDeadlineNanos

@CheckReturnValue
 @Nullable
public static <T> Exception getAllWithDeadlineNanos(long deadlineNanos,
                                                                                 BiConsumer<Future<T>,T> consumer,
                                                                                 Future<T>... futures)

Parameters:

deadlineNanos -

futures -

Returns:

getAllWithDeadlineNanosRetVoid

@CheckReturnValue
 @Nullable
public static Exception getAllWithDeadlineNanosRetVoid(long deadlineNanos,
                                                                                    Future... futures)

Gets all futures resuls for futures that return Void (no return).

Parameters:

deadlineNanos -

futures -

Returns:

getAll

@CheckReturnValue
 @Nonnull
public static Pair<Map<Future,Object>,Exception> getAll(long timeoutMillis,
                                                                                    Iterable<Future> futures)

getAllWithDeadlineNanos

@CheckReturnValue
 @Nonnull
public static Pair<Map<Future,Object>,Exception> getAllWithDeadlineNanos(long deadlineNanos,
                                                                                                     Iterable<Future> futures)

getAllWithDeadlineNanos

@CheckReturnValue
 @Nullable
public static <T> Exception getAllWithDeadlineNanos(long deadlineNanos,
                                                                                 BiConsumer<Future<T>,T> consumer,
                                                                                 Iterable<Future<T>> futures)

timedOutFutures

public static <T> List<Future<T>> timedOutFutures(int copies,
                                                  TimeoutException ex)