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 (package private) static interfaceAbstractFuture.Trusted<V>Tag interface marking trusted subclasses.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>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 whose value is derived from a collection of input futures.(package private) classAggregateFutureState<OutputT>A helper which does some thread-safe operations for aggregate futures, which must be implemented differently in GWT.(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.classFluentFuture<V>AListenableFuturethat supports fluent chains of operations.(package private) static classFluentFuture.TrustedFuture<V>A less abstract subclass of AbstractFuture.(package private) classForwardingFluentFuture<V>FluentFuturethat forwards all calls to a 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.InCompletionOrderFuture<T>private static classFutures.NonCancellationPropagatingFuture<V>A wrapped future that does not propagate cancellation to its delegate.(package private) classGwtFluentFutureCatchingSpecialization<V>Hidden superclass ofFluentFuturethat provides us a place to declare special GWT versions of theFluentFuture.catchingfamily of methods.(package private) classImmediateFuture<V>Implementation ofFutures.immediateFuture(V).(package private) static classImmediateFuture.ImmediateCancelledFuture<V>(package private) static classImmediateFuture.ImmediateFailedFuture<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>ForwardingFluentFuture. delegateprivate ListenableFuture<V>ForwardingListenableFuture.SimpleForwardingListenableFuture. delegateprivate ListenableFuture<V>Futures.NonCancellationPropagatingFuture. 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. inputFutureprivate ListenableFuture<? extends T>[]Futures.InCompletionOrderState. inputFutures(package private) static ListenableFuture<?>ImmediateFuture. NULLFields in com.google.common.util.concurrent with type parameters of type ListenableFuture Modifier and Type Field Description private ImmutableCollection<? extends ListenableFuture<? extends InputT>>AggregateFuture. futuresThe input futures.private ImmutableList<ListenableFuture<? extends V>>Futures.FutureCombiner. futuresprivate java.util.concurrent.atomic.AtomicReference<ListenableFuture<java.lang.Void>>ExecutionSequencer. refThis reference acts as a pointer tracking the head of a linked list of ListenableFutures.Methods 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.(package private) <V,U>
ListenableFuture<U>ClosingFuture.CloseableList. applyClosingFunction(ClosingFuture.ClosingFunction<? super V,U> transformation, V input)ListenableFuture<V>AsyncCallable. call()Computes a resultFuture.<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, 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, 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, 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 <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, java.util.concurrent.Executor executor)(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, 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()(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 ListenableFuture<java.lang.Void>Futures. immediateVoidFuture()Returns a successfulListenableFuture<Void>.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)Returns aListenableFuturewhose result is set from the supplied future when it completes.ListenableFuture<?>Futures.FutureCombiner. run(java.lang.Runnable combiner, java.util.concurrent.Executor executor)Creates theListenableFuturewhich will return the result of runningcombinerwhen all Futures complete.(package private) ListenableFuture<V>CombinedFuture.AsyncCallableInterruptibleTask. runInterruptibly()(package private) ListenableFuture<V>TrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask. runInterruptibly()static <O> ListenableFuture<O>Futures. scheduleAsync(AsyncCallable<O> callable, long delay, java.util.concurrent.TimeUnit timeUnit, java.util.concurrent.ScheduledExecutorService executorService)Schedulescallableon the specifiedexecutor, returning aFuture.static <O> ListenableFuture<O>Futures. scheduleAsync(AsyncCallable<O> callable, java.time.Duration delay, java.util.concurrent.ScheduledExecutorService executorService)Schedulescallableon the specifiedexecutor, returning aFuture.ListenableFuture<?>ClosingFuture. statusFuture()Returns a future that finishes when this step does.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)<T> ListenableFuture<T>ExecutionSequencer. submit(java.util.concurrent.Callable<T> callable, java.util.concurrent.Executor executor)Enqueues a task to run when the previous task (if any) completes.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)static ListenableFuture<java.lang.Void>Futures. submit(java.lang.Runnable runnable, java.util.concurrent.Executor executor)Executesrunnableon the specifiedexecutor, returning aFuturethat will complete after execution.static <O> ListenableFuture<O>Futures. submit(java.util.concurrent.Callable<O> callable, java.util.concurrent.Executor executor)Executescallableon the specifiedexecutor, returning aFuture.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.<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.static <O> ListenableFuture<O>Futures. submitAsync(AsyncCallable<O> callable, java.util.concurrent.Executor executor)Executescallableon the specifiedexecutor, returning aFuture.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, 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, 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.static <V> ListenableFuture<V>Futures. withTimeout(ListenableFuture<V> delegate, java.time.Duration time, 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, 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.(package private) voidTrustedListenableFutureTask.TrustedFutureInterruptibleAsyncTask. afterRanInterruptibly(ListenableFuture<V> result, java.lang.Throwable error)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, 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, 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 <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, java.util.concurrent.Executor executor)(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, 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 <C extends java.lang.Object & java.lang.AutoCloseable>
ClosingFuture<C>ClosingFuture. eventuallyClosing(ListenableFuture<C> future, java.util.concurrent.Executor closingExecutor)Deprecated.CreatingFutures of closeable types is dangerous in general because the underlying value may never be closed if theFutureis canceled after its operation begins.static <V> ClosingFuture<V>ClosingFuture. from(ListenableFuture<V> future)Starts aClosingFuturepipeline with aListenableFuture.static <V> FluentFuture<V>FluentFuture. from(ListenableFuture<V> future)Converts the givenListenableFutureto an equivalentFluentFuture.private static java.lang.ObjectAbstractFuture. getFutureValue(ListenableFuture<?> future)Returns a value that satisfies the contract of theAbstractFuture.valuefield based on the state of given future.static <V> ListenableFuture<V>Futures. nonCancellationPropagating(ListenableFuture<V> future)Returns aListenableFuturewhose 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)(package private) voidCombinedFuture.AsyncCallableInterruptibleTask. setValue(ListenableFuture<V> value)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, 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, 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.static <V> ListenableFuture<V>Futures. withTimeout(ListenableFuture<V> delegate, java.time.Duration time, 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 <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)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)ClosingFuture(ListenableFuture<V> future)ForwardingFluentFuture(ListenableFuture<V> delegate)InCompletionOrderState(ListenableFuture<? extends T>[] inputFutures)ListenableScheduledTask(ListenableFuture<V> listenableDelegate, java.util.concurrent.ScheduledFuture<?> scheduledDelegate)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 AggregateFuture(ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures, boolean allMustSucceed, boolean collectsValues)CollectionFuture(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)FutureCombiner(boolean allMustSucceed, ImmutableList<ListenableFuture<? extends V>> futures)ListFuture(ImmutableCollection<? extends ListenableFuture<? extends V>> futures, boolean allMustSucceed) -
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 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)
-