Uses of Interface
com.google.common.util.concurrent.ListenableFuture
-
Packages that use ListenableFuture Package Description com.google.common.cache This package contains caching utilities.com.google.common.util.concurrent Concurrency utilities.com.google.common.util.concurrent.testing -
-
Uses of ListenableFuture in com.google.common.cache
Methods in com.google.common.cache that return ListenableFuture Modifier and Type Method 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-cachedkey.Methods in com.google.common.cache with parameters of type ListenableFuture Modifier and Type Method Description (package private) VLocalCache.Segment. getAndRecordStats(K key, int hash, LocalCache.LoadingValueReference<K,V> loadingValueReference, ListenableFuture<V> newValue)Waits uninterruptibly fornewValueto be loaded, and then records loading stats. -
Uses of ListenableFuture in com.google.common.util.concurrent
Subinterfaces of ListenableFuture in com.google.common.util.concurrent Modifier and Type Interface Description interfaceCheckedFuture<V,X extends java.lang.Exception>ACheckedFutureis aListenableFuturethat includes versions of thegetmethods that can throw a checked exception.interfaceListenableScheduledFuture<V>Helper interface to implement bothListenableFutureandScheduledFuture.Classes in com.google.common.util.concurrent that implement ListenableFuture Modifier and Type Class Description (package private) classAbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>Implementations ofFutures.catching*.private static classAbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>AnAbstractCatchingFuturethat delegates to anAsyncFunctionandAbstractFuture.setFuture(ListenableFuture).private static classAbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>classAbstractCheckedFuture<V,X extends java.lang.Exception>A delegating wrapper around aListenableFuturethat adds support for theAbstractCheckedFuture.checkedGet()andAbstractCheckedFuture.checkedGet(long, TimeUnit)methods.classAbstractFuture<V>An abstract implementation ofListenableFuture, intended for advanced users only.(package private) static classAbstractFuture.TrustedFuture<V>A less abstract subclass of AbstractFuture.(package private) classAbstractTransformFuture<I,O,F,T>Implementations ofFutures.transform*.private static classAbstractTransformFuture.AsyncTransformFuture<I,O>AnAbstractTransformFuturethat delegates to anAsyncFunctionandAbstractFuture.setFuture(ListenableFuture).private static classAbstractTransformFuture.TransformFuture<I,O>(package private) classAggregateFuture<InputT,OutputT>A future made up of a collection of sub-futures.(package private) classCollectionFuture<V,C>Aggregate future that collects (stores) results of each future.(package private) static classCollectionFuture.ListFuture<V>(package private) classCombinedFuture<V>Aggregate future that computes its value by calling a callable.classForwardingCheckedFuture<V,X extends java.lang.Exception>A future which forwards all its method calls to another future.static classForwardingCheckedFuture.SimpleForwardingCheckedFuture<V,X extends java.lang.Exception>A simplified version ofForwardingCheckedFuturewhere subclasses can pass in an already constructedCheckedFutureas the delegate.classForwardingListenableFuture<V>AListenableFuturewhich forwards all its method calls to another future.static classForwardingListenableFuture.SimpleForwardingListenableFuture<V>A simplified version ofForwardingListenableFuturewhere subclasses can pass in an already constructedListenableFutureas the delegate.private static classFutures.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 classFutures.NonCancellationPropagatingFuture<V>A wrapped future that does not propagate cancellation to its delegate.(package private) classImmediateFuture<V>Implementations ofFutures.immediate*.(package private) static classImmediateFuture.ImmediateCancelledFuture<V>(package private) static classImmediateFuture.ImmediateFailedCheckedFuture<V,X extends java.lang.Exception>(package private) static classImmediateFuture.ImmediateFailedFuture<V>(package private) static classImmediateFuture.ImmediateSuccessfulCheckedFuture<V,X extends java.lang.Exception>(package private) static classImmediateFuture.ImmediateSuccessfulFuture<V>private static classJdkFutureAdapters.ListenableFutureAdapter<V>An adapter to turn aFutureinto aListenableFuture.classListenableFutureTask<V>AFutureTaskthat also implements theListenableFutureinterface.private static classMoreExecutors.ScheduledListeningDecorator.ListenableScheduledTask<V>private static classMoreExecutors.ScheduledListeningDecorator.NeverSuccessfulListenableFutureTaskclassSettableFuture<V>AListenableFuturewhose result can be set by aSettableFuture.set(Object),SettableFuture.setException(Throwable)orSettableFuture.setFuture(ListenableFuture)call.(package private) classTimeoutFuture<V>Implementation ofFutures#withTimeout.(package private) classTrustedListenableFutureTask<V>ARunnableFuturethat also implements theListenableFutureinterface.Fields in com.google.common.util.concurrent declared as ListenableFuture Modifier and Type Field Description private ListenableFuture<V>ForwardingListenableFuture.SimpleForwardingListenableFuture. delegateprivate ListenableFuture<V>TimeoutFuture. delegateRef(package private) ListenableFuture<? extends V>AbstractFuture.SetFuture. future(package private) ListenableFuture<? extends V>AbstractCatchingFuture. inputFuture(package private) ListenableFuture<? extends I>AbstractTransformFuture. inputFutureFields in com.google.common.util.concurrent with type parameters of type ListenableFuture Modifier and Type Field Description private static AsyncFunction<ListenableFuture<java.lang.Object>,java.lang.Object>Futures. DEREFERENCERprivate ImmutableCollection<? extends ListenableFuture<? extends InputT>>AggregateFuture.RunningState. futuresprivate ImmutableList<ListenableFuture<? extends V>>Futures.FutureCombiner. futuresMethods in com.google.common.util.concurrent that return ListenableFuture Modifier and Type Method Description static <V> ListenableFuture<java.util.List<V>>Futures. allAsList(ListenableFuture<? extends V>... futures)Creates a newListenableFuturewhose value is a list containing the values of all its input futures, if all succeed.static <V> ListenableFuture<java.util.List<V>>Futures. allAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)Creates a newListenableFuturewhose value is a list containing the values of all its input futures, if all succeed.ListenableFuture<O>AsyncFunction. apply(I input)Returns an outputFutureto use in place of the giveninput.ListenableFuture<V>AsyncCallable. call()Computes a resultFuture.<C> ListenableFuture<C>Futures.FutureCombiner. call(java.util.concurrent.Callable<C> combiner)LikeFutures.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 theListenableFuturewhich will return the result of callingCallable.call()incombinerwhen all futures complete, using the specifiedexecutor.<C> ListenableFuture<C>Futures.FutureCombiner. callAsync(AsyncCallable<C> combiner)<C> ListenableFuture<C>Futures.FutureCombiner. callAsync(AsyncCallable<C> combiner, java.util.concurrent.Executor executor)Creates theListenableFuturewhich will return the result of callingAsyncCallable.call()incombinerwhen all futures complete, using the specifiedexecutor.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.(package private) static <X extends java.lang.Throwable,V>
ListenableFuture<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>
ListenableFuture<V>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 <X extends java.lang.Throwable,V>
ListenableFuture<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>
ListenableFuture<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 <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 <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 <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 newListenableFuturewhose result is the product of callingget()on theFuturenested within the givenFuture, 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 aListenableFuturewhich is cancelled immediately upon construction, so thatisCancelled()always returnstrue.static <V> ListenableFuture<V>Futures. immediateFailedFuture(java.lang.Throwable throwable)Returns aListenableFuturewhich has an exception set immediately upon construction.static <V> ListenableFuture<V>Futures. immediateFuture(V value)Creates aListenableFuturewhich has its value set immediately upon construction.static <V> ListenableFuture<V>JdkFutureAdapters. listenInPoolThread(java.util.concurrent.Future<V> future)Assigns a thread to the givenFutureto provideListenableFuturefunctionality.static <V> ListenableFuture<V>JdkFutureAdapters. listenInPoolThread(java.util.concurrent.Future<V> future, java.util.concurrent.Executor executor)Submits a blocking task for the givenFutureto provideListenableFuturefunctionality.static <V> ListenableFuture<V>Futures. nonCancellationPropagating(ListenableFuture<V> future)Creates a newListenableFuturewhose result is set from the supplied future when it completes.ListenableFuture<?>AbstractListeningExecutorService. submit(java.lang.Runnable task)<T> ListenableFuture<T>AbstractListeningExecutorService. submit(java.lang.Runnable task, T result)<T> ListenableFuture<T>AbstractListeningExecutorService. submit(java.util.concurrent.Callable<T> task)ListenableFuture<?>ForwardingListeningExecutorService. submit(java.lang.Runnable task)<T> ListenableFuture<T>ForwardingListeningExecutorService. submit(java.lang.Runnable task, T result)<T> ListenableFuture<T>ForwardingListeningExecutorService. submit(java.util.concurrent.Callable<T> task)ListenableFuture<?>ListeningExecutorService. submit(java.lang.Runnable task)<T> ListenableFuture<T>ListeningExecutorService. submit(java.lang.Runnable task, T result)<T> ListenableFuture<T>ListeningExecutorService. submit(java.util.concurrent.Callable<T> task)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 toqueuewhen it completes.static <V> ListenableFuture<java.util.List<V>>Futures. successfulAsList(ListenableFuture<? extends V>... futures)Creates a newListenableFuturewhose value is a list containing the values of all its successful input futures.static <V> ListenableFuture<java.util.List<V>>Futures. successfulAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)Creates a newListenableFuturewhose 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 newFuturewhose result is derived from the result of the givenFuture.static <I,O>
ListenableFuture<O>Futures. transform(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)Returns a newFuturewhose result is derived from the result of the givenFuture.static <I,O>
ListenableFuture<O>Futures. transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function)Returns a newFuturewhose result is asynchronously derived from the result of the givenFuture.static <I,O>
ListenableFuture<O>Futures. transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)Returns a newFuturewhose result is asynchronously derived from the result of the givenFuture.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 aTimeoutExceptionwrapped in anExecutionException) if the specified duration expires.Methods in com.google.common.util.concurrent that return types with arguments of type ListenableFuture Modifier and Type Method 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.Methods in com.google.common.util.concurrent with parameters of type ListenableFuture Modifier and Type Method Description static <V> voidFutures. addCallback(ListenableFuture<V> future, FutureCallback<? super V> callback)Registers separate success and failure callbacks to be run when theFuture's computation is complete or, if the computation is already complete, immediately.static <V> voidFutures. addCallback(ListenableFuture<V> future, FutureCallback<? super V> callback, java.util.concurrent.Executor executor)Registers separate success and failure callbacks to be run when theFuture'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 newListenableFuturewhose value is a list containing the values of all its input futures, if all succeed.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catching(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.static <V,X extends java.lang.Throwable>
ListenableFuture<V>Futures. catchingAsync(ListenableFuture<? extends V> input, java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)Returns aFuturewhose result is taken from the given primaryinputor, if the primary input fails with the givenexceptionType, from the result provided by thefallback.(package private) static <X extends java.lang.Throwable,V>
ListenableFuture<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>
ListenableFuture<V>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 <X extends java.lang.Throwable,V>
ListenableFuture<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>
ListenableFuture<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 <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 <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 <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 newListenableFuturewhose result is the product of callingget()on theFuturenested within the givenFuture, effectively chaining the futures one after the other.private static java.lang.ObjectAbstractFuture. getFutureValue(ListenableFuture<?> future)Returns a value, suitable for storing in theAbstractFuture.valuefield.static <V,X extends java.lang.Exception>
CheckedFuture<V,X>Futures. makeChecked(ListenableFuture<V> future, Function<? super java.lang.Exception,X> mapper)Creates aCheckedFutureout of a normalListenableFutureand aFunctionthat maps fromExceptioninstances into the appropriate checked type.static <V> ListenableFuture<V>Futures. nonCancellationPropagating(ListenableFuture<V> future)Creates a newListenableFuturewhose result is set from the supplied future when it completes.protected booleanAbstractFuture. setFuture(ListenableFuture<? extends V> future)Sets the result of thisFutureto match the supplied inputFutureonce the suppliedFutureis done, unless thisFuturehas already been cancelled or set (including "set asynchronously," defined below).booleanSettableFuture. setFuture(ListenableFuture<? extends V> future)(package private) voidAbstractCatchingFuture.AsyncCatchingFuture. setResult(ListenableFuture<? extends V> result)(package private) voidAbstractTransformFuture.AsyncTransformFuture. setResult(ListenableFuture<? extends O> result)static <V> ListenableFuture<java.util.List<V>>Futures. successfulAsList(ListenableFuture<? extends V>... futures)Creates a newListenableFuturewhose 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 newFuturewhose result is derived from the result of the givenFuture.static <I,O>
ListenableFuture<O>Futures. transform(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)Returns a newFuturewhose result is derived from the result of the givenFuture.static <I,O>
ListenableFuture<O>Futures. transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function)Returns a newFuturewhose result is asynchronously derived from the result of the givenFuture.static <I,O>
ListenableFuture<O>Futures. transformAsync(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)Returns a newFuturewhose result is asynchronously derived from the result of the givenFuture.static <V> Futures.FutureCombiner<V>Futures. whenAllComplete(ListenableFuture<? extends V>... futures)Creates aFutures.FutureCombinerthat processes the completed futures whether or not they're successful.static <V> Futures.FutureCombiner<V>Futures. whenAllSucceed(ListenableFuture<? extends V>... futures)Creates aFutures.FutureCombinerrequiring 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 aTimeoutExceptionwrapped in anExecutionException) if the specified duration expires.Method parameters in com.google.common.util.concurrent with type arguments of type ListenableFuture Modifier and Type Method Description static <V> ListenableFuture<java.util.List<V>>Futures. allAsList(java.lang.Iterable<? extends ListenableFuture<? extends V>> futures)Creates a newListenableFuturewhose 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 newListenableFuturewhose result is the product of callingget()on theFuturenested within the givenFuture, 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 newListenableFuturewhose 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 aFutures.FutureCombinerthat 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 aFutures.FutureCombinerrequiring that all passed in futures are successful.Constructors in com.google.common.util.concurrent with parameters of type ListenableFuture Constructor Description AbstractCatchingFuture(ListenableFuture<? extends V> inputFuture, java.lang.Class<X> exceptionType, F fallback)AbstractCheckedFuture(ListenableFuture<V> delegate)Constructs anAbstractCheckedFuturethat 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 parameters in com.google.common.util.concurrent with type arguments of type ListenableFuture Constructor 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) -
Uses of ListenableFuture in com.google.common.util.concurrent.testing
Classes in com.google.common.util.concurrent.testing that implement ListenableFuture Modifier and Type Class Description private static classSameThreadScheduledExecutorService.ImmediateScheduledFuture<V>private static classTestingExecutors.NoOpScheduledExecutorService.NeverScheduledFuture<V>Fields in com.google.common.util.concurrent.testing declared as ListenableFuture Modifier and Type Field Description protected ListenableFuture<java.lang.Boolean>AbstractListenableFutureTest. futureprivate ListenableFuture<?>MockFutureListener. futureMethods in com.google.common.util.concurrent.testing that return ListenableFuture Modifier and Type Method 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.ListenableFuture<?>SameThreadScheduledExecutorService. submit(java.lang.Runnable task)<T> ListenableFuture<T>SameThreadScheduledExecutorService. submit(java.lang.Runnable task, T result)<T> ListenableFuture<T>SameThreadScheduledExecutorService. submit(java.util.concurrent.Callable<T> task)Constructors in com.google.common.util.concurrent.testing with parameters of type ListenableFuture Constructor Description ImmediateScheduledFuture(ListenableFuture<V> future)MockFutureListener(ListenableFuture<?> future)
-