Package | Description |
---|---|
com.google.common.cache |
This package contains caching utilities.
|
com.google.common.util.concurrent |
Concurrency utilities.
|
com.google.common.util.concurrent.testing |
Modifier and Type | Method and Description |
---|---|
private ListenableFuture<V> |
LocalCache.LoadingValueReference.fullyFailedFuture(java.lang.Throwable t) |
(package private) ListenableFuture<V> |
LocalCache.Segment.loadAsync(K key,
int hash,
LocalCache.LoadingValueReference<K,V> loadingValueReference,
CacheLoader<? super K,V> loader) |
ListenableFuture<V> |
LocalCache.LoadingValueReference.loadFuture(K key,
CacheLoader<? super K,V> loader) |
ListenableFuture<V> |
CacheLoader.reload(K key,
V oldValue)
Computes or retrieves a replacement value corresponding to an already-cached
key . |
Modifier and Type | Method and Description |
---|---|
(package private) V |
LocalCache.Segment.getAndRecordStats(K key,
int hash,
LocalCache.LoadingValueReference<K,V> loadingValueReference,
ListenableFuture<V> newValue)
Waits uninterruptibly for
newValue to be loaded, and then records loading stats. |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckedFuture<V,X extends java.lang.Exception>
A
CheckedFuture is a ListenableFuture that includes versions of the get
methods that can throw a checked exception. |
interface |
ListenableScheduledFuture<V>
Helper interface to implement both
ListenableFuture and ScheduledFuture . |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>
Implementations of
Futures.catching* . |
private static class |
AbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>
An
AbstractCatchingFuture that delegates to an AsyncFunction and
AbstractFuture.setFuture(ListenableFuture) . |
private static class |
AbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>
|
class |
AbstractCheckedFuture<V,X extends java.lang.Exception>
A delegating wrapper around a
ListenableFuture that adds support for the AbstractCheckedFuture.checkedGet() and AbstractCheckedFuture.checkedGet(long, TimeUnit) methods. |
class |
AbstractFuture<V>
An abstract implementation of
ListenableFuture , intended for advanced users only. |
(package private) static class |
AbstractFuture.TrustedFuture<V>
A less abstract subclass of AbstractFuture.
|
(package private) class |
AbstractTransformFuture<I,O,F,T>
Implementations of
Futures.transform* . |
private static class |
AbstractTransformFuture.AsyncTransformFuture<I,O>
An
AbstractTransformFuture that delegates to an AsyncFunction and
AbstractFuture.setFuture(ListenableFuture) . |
private static class |
AbstractTransformFuture.TransformFuture<I,O>
|
(package private) class |
AggregateFuture<InputT,OutputT>
A future made up of a collection of sub-futures.
|
(package private) class |
CollectionFuture<V,C>
Aggregate future that collects (stores) results of each future.
|
(package private) static class |
CollectionFuture.ListFuture<V>
|
(package private) class |
CombinedFuture<V>
Aggregate future that computes its value by calling a callable.
|
class |
ForwardingCheckedFuture<V,X extends java.lang.Exception>
A future which forwards all its method calls to another future.
|
static class |
ForwardingCheckedFuture.SimpleForwardingCheckedFuture<V,X extends java.lang.Exception>
A simplified version of
ForwardingCheckedFuture where subclasses can pass in an already
constructed CheckedFuture as the delegate. |
class |
ForwardingListenableFuture<V>
A
ListenableFuture which forwards all its method calls to another future. |
static class |
ForwardingListenableFuture.SimpleForwardingListenableFuture<V>
A simplified version of
ForwardingListenableFuture where subclasses can pass in an
already constructed ListenableFuture as the delegate. |
private static class |
Futures.MappingCheckedFuture<V,X extends java.lang.Exception>
A checked future that uses a function to map from exceptions to the appropriate checked type.
|
private static class |
Futures.NonCancellationPropagatingFuture<V>
A wrapped future that does not propagate cancellation to its delegate.
|
(package private) class |
ImmediateFuture<V>
Implementations of
Futures.immediate* . |
(package private) static class |
ImmediateFuture.ImmediateCancelledFuture<V> |
(package private) static class |
ImmediateFuture.ImmediateFailedCheckedFuture<V,X extends java.lang.Exception> |
(package private) static class |
ImmediateFuture.ImmediateFailedFuture<V> |
(package private) static class |
ImmediateFuture.ImmediateSuccessfulCheckedFuture<V,X extends java.lang.Exception> |
(package private) static class |
ImmediateFuture.ImmediateSuccessfulFuture<V> |
private static class |
JdkFutureAdapters.ListenableFutureAdapter<V>
An adapter to turn a
Future into a ListenableFuture . |
class |
ListenableFutureTask<V>
A
FutureTask that also implements the ListenableFuture interface. |
private static class |
MoreExecutors.ScheduledListeningDecorator.ListenableScheduledTask<V> |
private static class |
MoreExecutors.ScheduledListeningDecorator.NeverSuccessfulListenableFutureTask |
class |
SettableFuture<V>
A
ListenableFuture whose result can be set by a SettableFuture.set(Object) , SettableFuture.setException(Throwable) or SettableFuture.setFuture(ListenableFuture) call. |
(package private) class |
TimeoutFuture<V>
Implementation of
Futures#withTimeout . |
(package private) class |
TrustedListenableFutureTask<V>
A
RunnableFuture that also implements the ListenableFuture interface. |
Modifier and Type | Field and Description |
---|---|
private ListenableFuture<V> |
ForwardingListenableFuture.SimpleForwardingListenableFuture.delegate |
private ListenableFuture<V> |
TimeoutFuture.delegateRef |
(package private) ListenableFuture<? extends V> |
AbstractFuture.SetFuture.future |
(package private) ListenableFuture<? extends I> |
AbstractTransformFuture.inputFuture |
(package private) ListenableFuture<? extends V> |
AbstractCatchingFuture.inputFuture |
Modifier and Type | Field and Description |
---|---|
private static AsyncFunction<ListenableFuture<java.lang.Object>,java.lang.Object> |
Futures.DEREFERENCER
|
private ImmutableList<ListenableFuture<? extends V>> |
Futures.FutureCombiner.futures |
private ImmutableCollection<? extends ListenableFuture<? extends InputT>> |
AggregateFuture.RunningState.futures |
Modifier and Type | Method and Description |
---|---|
static <V> ListenableFuture<java.util.List<V>> |
Futures.allAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
input futures, if all succeed. |
static <V> ListenableFuture<java.util.List<V>> |
Futures.allAsList(ListenableFuture<? extends V>... futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
input futures, if all succeed. |
ListenableFuture<O> |
AsyncFunction.apply(I input)
Returns an output
Future to use in place of the given input . |
ListenableFuture<V> |
AsyncCallable.call()
Computes a result
Future . |
<C> ListenableFuture<C> |
Futures.FutureCombiner.call(java.util.concurrent.Callable<C> combiner)
Like
Futures.FutureCombiner.call(Callable, Executor) but using direct executor. |
<C> ListenableFuture<C> |
Futures.FutureCombiner.call(java.util.concurrent.Callable<C> combiner,
java.util.concurrent.Executor executor)
Creates the
ListenableFuture which will return the result of calling Callable.call() in combiner when all futures complete, using the specified executor . |
<C> ListenableFuture<C> |
Futures.FutureCombiner.callAsync(AsyncCallable<C> combiner)
|
<C> ListenableFuture<C> |
Futures.FutureCombiner.callAsync(AsyncCallable<C> combiner,
java.util.concurrent.Executor executor)
Creates the
ListenableFuture which will return the result of calling AsyncCallable.call() in combiner when all futures complete, using the specified executor . |
static <V,X extends java.lang.Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback) |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor) |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback) |
(package private) static <V,X extends java.lang.Throwable> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback,
java.util.concurrent.Executor executor) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
java.util.concurrent.Executor executor) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
Function<? super I,? extends O> function) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
Function<? super I,? extends O> function,
java.util.concurrent.Executor executor) |
(package private) static <V> ListenableFuture<V> |
TimeoutFuture.create(ListenableFuture<V> delegate,
long time,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.ScheduledExecutorService scheduledExecutor) |
protected abstract ListenableFuture<? extends V> |
ForwardingListenableFuture.delegate() |
protected ListenableFuture<V> |
ForwardingListenableFuture.SimpleForwardingListenableFuture.delegate() |
static <V> ListenableFuture<V> |
Futures.dereference(ListenableFuture<? extends ListenableFuture<? extends V>> nested)
Returns a new
ListenableFuture whose result is the product of calling get() on
the Future nested within the given Future , effectively chaining the futures one
after the other. |
(package private) ListenableFuture<? extends V> |
AbstractCatchingFuture.AsyncCatchingFuture.doFallback(AsyncFunction<? super X,? extends V> fallback,
X cause) |
(package private) ListenableFuture<? extends O> |
AbstractTransformFuture.AsyncTransformFuture.doTransform(AsyncFunction<? super I,? extends O> function,
I input) |
static <V> ListenableFuture<V> |
Futures.immediateCancelledFuture()
Creates a
ListenableFuture which is cancelled immediately upon construction, so that
isCancelled() always returns true . |
static <V> ListenableFuture<V> |
Futures.immediateFailedFuture(java.lang.Throwable throwable)
Returns a
ListenableFuture which has an exception set immediately upon construction. |
static <V> ListenableFuture<V> |
Futures.immediateFuture(V value)
Creates a
ListenableFuture which has its value set immediately upon construction. |
static <V> ListenableFuture<V> |
JdkFutureAdapters.listenInPoolThread(java.util.concurrent.Future<V> future)
Assigns a thread to the given
Future to provide ListenableFuture functionality. |
static <V> ListenableFuture<V> |
JdkFutureAdapters.listenInPoolThread(java.util.concurrent.Future<V> future,
java.util.concurrent.Executor executor)
Submits a blocking task for the given
Future to provide ListenableFuture
functionality. |
static <V> ListenableFuture<V> |
Futures.nonCancellationPropagating(ListenableFuture<V> future)
Creates a new
ListenableFuture whose result is set from the supplied future when it
completes. |
<T> ListenableFuture<T> |
ListeningExecutorService.submit(java.util.concurrent.Callable<T> task) |
<T> ListenableFuture<T> |
ForwardingListeningExecutorService.submit(java.util.concurrent.Callable<T> task) |
<T> ListenableFuture<T> |
AbstractListeningExecutorService.submit(java.util.concurrent.Callable<T> task) |
ListenableFuture<?> |
ListeningExecutorService.submit(java.lang.Runnable task) |
ListenableFuture<?> |
ForwardingListeningExecutorService.submit(java.lang.Runnable task) |
ListenableFuture<?> |
AbstractListeningExecutorService.submit(java.lang.Runnable task) |
<T> ListenableFuture<T> |
ListeningExecutorService.submit(java.lang.Runnable task,
T result) |
<T> ListenableFuture<T> |
ForwardingListeningExecutorService.submit(java.lang.Runnable task,
T result) |
<T> ListenableFuture<T> |
AbstractListeningExecutorService.submit(java.lang.Runnable task,
T result) |
private static <T> ListenableFuture<T> |
MoreExecutors.submitAndAddQueueListener(ListeningExecutorService executorService,
java.util.concurrent.Callable<T> task,
java.util.concurrent.BlockingQueue<java.util.concurrent.Future<T>> queue)
Submits the task and adds a listener that adds the future to
queue when it completes. |
static <V> ListenableFuture<java.util.List<V>> |
Futures.successfulAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
successful input futures. |
static <V> ListenableFuture<java.util.List<V>> |
Futures.successfulAsList(ListenableFuture<? extends V>... futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
successful input futures. |
static <I,O> ListenableFuture<O> |
Futures.transform(ListenableFuture<I> input,
Function<? super I,? extends O> function)
Returns a new
Future whose result is derived from the result of the given Future . |
static <I,O> ListenableFuture<O> |
Futures.transform(ListenableFuture<I> input,
Function<? super I,? extends O> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is derived from the result of the given Future . |
static <I,O> ListenableFuture<O> |
Futures.transformAsync(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function)
Returns a new
Future whose result is asynchronously derived from the result of the
given Future . |
static <I,O> ListenableFuture<O> |
Futures.transformAsync(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is asynchronously derived from the result of the
given Future . |
static <V> ListenableFuture<V> |
Futures.withTimeout(ListenableFuture<V> delegate,
long time,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via a
TimeoutException wrapped in an ExecutionException ) if the specified duration expires. |
Modifier and Type | Method and Description |
---|---|
static <T> ImmutableList<ListenableFuture<T>> |
Futures.inCompletionOrder(java.lang.Iterable<? extends ListenableFuture<? extends T>> futures)
Returns a list of delegate futures that correspond to the futures received in the order that
they complete.
|
Modifier and Type | Method and Description |
---|---|
static <V> void |
Futures.addCallback(ListenableFuture<V> future,
FutureCallback<? super V> callback)
Registers separate success and failure callbacks to be run when the
Future 's
computation is complete or, if the
computation is already complete, immediately. |
static <V> void |
Futures.addCallback(ListenableFuture<V> future,
FutureCallback<? super V> callback,
java.util.concurrent.Executor executor)
Registers separate success and failure callbacks to be run when the
Future 's
computation is complete or, if the
computation is already complete, immediately. |
static <V> ListenableFuture<java.util.List<V>> |
Futures.allAsList(ListenableFuture<? extends V>... futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
input futures, if all succeed. |
static <V,X extends java.lang.Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catching(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback) |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor) |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback) |
(package private) static <V,X extends java.lang.Throwable> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback,
java.util.concurrent.Executor executor) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
java.util.concurrent.Executor executor) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
Function<? super I,? extends O> function) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
Function<? super I,? extends O> function,
java.util.concurrent.Executor executor) |
(package private) static <V> ListenableFuture<V> |
TimeoutFuture.create(ListenableFuture<V> delegate,
long time,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.ScheduledExecutorService scheduledExecutor) |
static <V> ListenableFuture<V> |
Futures.dereference(ListenableFuture<? extends ListenableFuture<? extends V>> nested)
Returns a new
ListenableFuture whose result is the product of calling get() on
the Future nested within the given Future , effectively chaining the futures one
after the other. |
private static java.lang.Object |
AbstractFuture.getFutureValue(ListenableFuture<?> future)
Returns a value, suitable for storing in the
AbstractFuture.value field. |
static <V,X extends java.lang.Exception> |
Futures.makeChecked(ListenableFuture<V> future,
Function<? super java.lang.Exception,X> mapper)
Creates a
CheckedFuture out of a normal ListenableFuture and a Function
that maps from Exception instances into the appropriate checked type. |
static <V> ListenableFuture<V> |
Futures.nonCancellationPropagating(ListenableFuture<V> future)
Creates a new
ListenableFuture whose result is set from the supplied future when it
completes. |
protected boolean |
AbstractFuture.setFuture(ListenableFuture<? extends V> future)
Sets the result of this
Future to match the supplied input Future once the
supplied Future is done, unless this Future has already been cancelled or set
(including "set asynchronously," defined below). |
boolean |
SettableFuture.setFuture(ListenableFuture<? extends V> future) |
(package private) void |
AbstractTransformFuture.AsyncTransformFuture.setResult(ListenableFuture<? extends O> result) |
(package private) void |
AbstractCatchingFuture.AsyncCatchingFuture.setResult(ListenableFuture<? extends V> result) |
static <V> ListenableFuture<java.util.List<V>> |
Futures.successfulAsList(ListenableFuture<? extends V>... futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
successful input futures. |
static <I,O> ListenableFuture<O> |
Futures.transform(ListenableFuture<I> input,
Function<? super I,? extends O> function)
Returns a new
Future whose result is derived from the result of the given Future . |
static <I,O> ListenableFuture<O> |
Futures.transform(ListenableFuture<I> input,
Function<? super I,? extends O> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is derived from the result of the given Future . |
static <I,O> ListenableFuture<O> |
Futures.transformAsync(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function)
Returns a new
Future whose result is asynchronously derived from the result of the
given Future . |
static <I,O> ListenableFuture<O> |
Futures.transformAsync(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is asynchronously derived from the result of the
given Future . |
static <V> Futures.FutureCombiner<V> |
Futures.whenAllComplete(ListenableFuture<? extends V>... futures)
Creates a
Futures.FutureCombiner that processes the completed futures whether or not they're
successful. |
static <V> Futures.FutureCombiner<V> |
Futures.whenAllSucceed(ListenableFuture<? extends V>... futures)
Creates a
Futures.FutureCombiner requiring that all passed in futures are successful. |
static <V> ListenableFuture<V> |
Futures.withTimeout(ListenableFuture<V> delegate,
long time,
java.util.concurrent.TimeUnit unit,
java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to another but will finish early (via a
TimeoutException wrapped in an ExecutionException ) if the specified duration expires. |
Modifier and Type | Method and Description |
---|---|
static <V> ListenableFuture<java.util.List<V>> |
Futures.allAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
input futures, if all succeed. |
static <V> ListenableFuture<V> |
Futures.dereference(ListenableFuture<? extends ListenableFuture<? extends V>> nested)
Returns a new
ListenableFuture whose result is the product of calling get() on
the Future nested within the given Future , effectively chaining the futures one
after the other. |
static <T> ImmutableList<ListenableFuture<T>> |
Futures.inCompletionOrder(java.lang.Iterable<? extends ListenableFuture<? extends T>> futures)
Returns a list of delegate futures that correspond to the futures received in the order that
they complete.
|
static <V> ListenableFuture<java.util.List<V>> |
Futures.successfulAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a new
ListenableFuture whose value is a list containing the values of all its
successful input futures. |
static <V> Futures.FutureCombiner<V> |
Futures.whenAllComplete(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a
Futures.FutureCombiner that processes the completed futures whether or not they're
successful. |
static <V> Futures.FutureCombiner<V> |
Futures.whenAllSucceed(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)
Creates a
Futures.FutureCombiner requiring that all passed in futures are successful. |
Constructor and Description |
---|
AbstractCatchingFuture(ListenableFuture<? extends V> inputFuture,
java.lang.Class<X> exceptionType,
F fallback) |
AbstractCheckedFuture(ListenableFuture<V> delegate)
Constructs an
AbstractCheckedFuture that wraps a delegate. |
AbstractTransformFuture(ListenableFuture<? extends I> inputFuture,
F function) |
AsyncCatchingFuture(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback) |
AsyncTransformFuture(ListenableFuture<? extends I> inputFuture,
AsyncFunction<? super I,? extends O> function) |
CatchingFuture(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback) |
ListenableScheduledTask(ListenableFuture<V> listenableDelegate,
java.util.concurrent.ScheduledFuture<?> scheduledDelegate) |
MappingCheckedFuture(ListenableFuture<V> delegate,
Function<? super java.lang.Exception,X> mapper) |
NonCancellationPropagatingFuture(ListenableFuture<V> delegate) |
SetFuture(AbstractFuture<V> owner,
ListenableFuture<? extends V> future) |
SimpleForwardingListenableFuture(ListenableFuture<V> delegate) |
TimeoutFuture(ListenableFuture<V> delegate) |
TransformFuture(ListenableFuture<? extends I> inputFuture,
Function<? super I,? extends O> function) |
Constructor and Description |
---|
CollectionFutureRunningState(ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
boolean allMustSucceed) |
CombinedFuture(ImmutableCollection<? extends ListenableFuture<?>> futures,
boolean allMustSucceed,
java.util.concurrent.Executor listenerExecutor,
AsyncCallable<V> callable) |
CombinedFuture(ImmutableCollection<? extends ListenableFuture<?>> futures,
boolean allMustSucceed,
java.util.concurrent.Executor listenerExecutor,
java.util.concurrent.Callable<V> callable) |
CombinedFutureRunningState(ImmutableCollection<? extends ListenableFuture<? extends java.lang.Object>> futures,
boolean allMustSucceed,
CombinedFuture.CombinedFutureInterruptibleTask task) |
FutureCombiner(boolean allMustSucceed,
ImmutableList<ListenableFuture<? extends V>> futures) |
ListFuture(ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
boolean allMustSucceed) |
ListFutureRunningState(ImmutableCollection<? extends ListenableFuture<? extends V>> futures,
boolean allMustSucceed) |
RunningState(ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures,
boolean allMustSucceed,
boolean collectsValues) |
Modifier and Type | Class and Description |
---|---|
private static class |
SameThreadScheduledExecutorService.ImmediateScheduledFuture<V> |
private static class |
TestingExecutors.NoOpScheduledExecutorService.NeverScheduledFuture<V> |
Modifier and Type | Field and Description |
---|---|
protected ListenableFuture<java.lang.Boolean> |
AbstractListenableFutureTest.future |
private ListenableFuture<?> |
MockFutureListener.future |
Modifier and Type | Method and Description |
---|---|
protected <V> ListenableFuture<V> |
AbstractCheckedFutureTest.createListenableFuture(V value,
java.lang.Exception except,
java.util.concurrent.CountDownLatch waitOn) |
protected abstract <V> ListenableFuture<V> |
AbstractListenableFutureTest.createListenableFuture(V value,
java.lang.Exception except,
java.util.concurrent.CountDownLatch waitOn)
Constructs a listenable future with a value available after the latch
has counted down.
|
<T> ListenableFuture<T> |
SameThreadScheduledExecutorService.submit(java.util.concurrent.Callable<T> task) |
ListenableFuture<?> |
SameThreadScheduledExecutorService.submit(java.lang.Runnable task) |
<T> ListenableFuture<T> |
SameThreadScheduledExecutorService.submit(java.lang.Runnable task,
T result) |
Constructor and Description |
---|
ImmediateScheduledFuture(ListenableFuture<V> future) |
MockFutureListener(ListenableFuture<?> future) |