@Beta public class FutureIterables extends Object
Iterables dealing with Futures| Constructor and Description |
|---|
FutureIterables() |
| Modifier and Type | Method and Description |
|---|---|
static <F> Map<F,Exception> |
awaitCompletion(Map<F,? extends com.google.common.util.concurrent.ListenableFuture<?>> responses,
com.google.common.util.concurrent.ListeningExecutorService exec,
Long maxTime,
Logger logger,
String logPrefix) |
static <F,T> Iterable<T> |
transformParallel(Iterable<F> fromIterable,
com.google.common.base.Function<? super F,com.google.common.util.concurrent.ListenableFuture<? extends T>> function,
com.google.common.util.concurrent.ListeningExecutorService exec,
Long maxTime,
Logger logger,
String logPrefix) |
static <F,T> Iterable<T> |
transformParallel(Iterable<F> fromIterable,
com.google.common.base.Function<? super F,com.google.common.util.concurrent.ListenableFuture<? extends T>> function,
com.google.common.util.concurrent.ListeningExecutorService exec,
Long maxTime,
Logger logger,
String logPrefix,
BackoffLimitedRetryHandler retryHandler,
int maxRetries) |
public static <F,T> Iterable<T> transformParallel(Iterable<F> fromIterable, com.google.common.base.Function<? super F,com.google.common.util.concurrent.ListenableFuture<? extends T>> function, com.google.common.util.concurrent.ListeningExecutorService exec, @Nullable Long maxTime, Logger logger, String logPrefix)
public static <F,T> Iterable<T> transformParallel(Iterable<F> fromIterable, com.google.common.base.Function<? super F,com.google.common.util.concurrent.ListenableFuture<? extends T>> function, com.google.common.util.concurrent.ListeningExecutorService exec, @Nullable Long maxTime, Logger logger, String logPrefix, BackoffLimitedRetryHandler retryHandler, int maxRetries)
public static <F> Map<F,Exception> awaitCompletion(Map<F,? extends com.google.common.util.concurrent.ListenableFuture<?>> responses, com.google.common.util.concurrent.ListeningExecutorService exec, @Nullable Long maxTime, Logger logger, String logPrefix) throws TimeoutException
TimeoutExceptionCopyright © 2009-2018 The Apache Software Foundation. All Rights Reserved.