Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Field and Description |
---|---|
private AsyncCallable<V> |
TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask.callable |
private AsyncCallable<V> |
CombinedFuture.AsyncCallableInterruptibleTask.callable |
Modifier and Type | Method and Description |
---|---|
static <T> AsyncCallable<T> |
Callables.asAsyncCallable(java.util.concurrent.Callable<T> callable,
ListeningExecutorService listeningExecutorService)
Creates an
AsyncCallable from a Callable . |
Modifier and Type | Method and Description |
---|---|
<C> ListenableFuture<C> |
Futures.FutureCombiner.callAsync(AsyncCallable<C> combiner,
java.util.concurrent.Executor executor)
Creates the
ListenableFuture which will return the result of calling call() in combiner when all futures complete, using the specified executor . |
(package private) static <V> TrustedListenableFutureTask<V> |
TrustedListenableFutureTask.create(AsyncCallable<V> callable) |
static <O> ListenableFuture<O> |
Futures.scheduleAsync(AsyncCallable<O> callable,
java.time.Duration delay,
java.util.concurrent.ScheduledExecutorService executorService)
Schedules
callable on the specified executor , returning a Future . |
static <O> ListenableFuture<O> |
Futures.scheduleAsync(AsyncCallable<O> callable,
long delay,
java.util.concurrent.TimeUnit timeUnit,
java.util.concurrent.ScheduledExecutorService executorService)
Schedules
callable on the specified executor , returning a Future . |
static <O> ListenableFuture<O> |
Futures.submitAsync(AsyncCallable<O> callable,
java.util.concurrent.Executor executor)
Executes
callable on the specified executor , returning a Future . |
<T> ListenableFuture<T> |
ExecutionSequencer.submitAsync(AsyncCallable<T> callable,
java.util.concurrent.Executor executor)
Enqueues a task to run when the previous task (if any) completes.
|
Constructor and Description |
---|
AsyncCallableInterruptibleTask(AsyncCallable<V> callable,
java.util.concurrent.Executor listenerExecutor) |
CombinedFuture(ImmutableCollection<? extends ListenableFuture<?>> futures,
boolean allMustSucceed,
java.util.concurrent.Executor listenerExecutor,
AsyncCallable<V> callable) |
TrustedFutureInterruptibleAsyncTask(AsyncCallable<V> callable) |
TrustedListenableFutureTask(AsyncCallable<V> callable) |