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)
static RuntimeException	cancelAll(boolean mayInterrupt, Future[] futures, int from)
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 Pair<Map<Future,Object>,Exception>	getAllWithDeadlineNanos(long deadlineNanos, Future... futures) Gets all futures resuls.
static Pair<Map<Future,Object>,Exception>	getAllWithDeadlineNanos(long deadlineNanos, Iterable<Future> futures)
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

@CheckReturnValue
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)

Gets all futures resuls.

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)

timedOutFutures

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