Uses of Interface
com.google.common.util.concurrent.ListeningExecutorService
-
Packages that use ListeningExecutorService Package Description com.google.common.util.concurrent Concurrency utilities.com.google.common.util.concurrent.testing -
-
Uses of ListeningExecutorService in com.google.common.util.concurrent
Subinterfaces of ListeningExecutorService in com.google.common.util.concurrent Modifier and Type Interface Description interface
ListeningScheduledExecutorService
AScheduledExecutorService
that returnsListenableFuture
instances from itsExecutorService
methods.Classes in com.google.common.util.concurrent that implement ListeningExecutorService Modifier and Type Class Description class
AbstractListeningExecutorService
AbstractListeningExecutorService
implementation that createsListenableFuture
instances for eachRunnable
andCallable
submitted to it.class
ForwardingListeningExecutorService
A listening executor service which forwards all its method calls to another listening executor service.private static class
MoreExecutors.DirectExecutorService
private static class
MoreExecutors.ListeningDecorator
private static class
MoreExecutors.ScheduledListeningDecorator
Methods in com.google.common.util.concurrent that return ListeningExecutorService Modifier and Type Method Description protected abstract ListeningExecutorService
ForwardingListeningExecutorService. delegate()
static ListeningExecutorService
MoreExecutors. listeningDecorator(java.util.concurrent.ExecutorService delegate)
Creates anExecutorService
whosesubmit
andinvokeAll
methods submitListenableFutureTask
instances to the given delegate executor.static ListeningExecutorService
MoreExecutors. newDirectExecutorService()
Creates an executor service that runs each task in the thread that invokesexecute/submit
, as inThreadPoolExecutor.CallerRunsPolicy
.Methods in com.google.common.util.concurrent with parameters of type ListeningExecutorService Modifier and Type Method Description static <T> AsyncCallable<T>
Callables. asAsyncCallable(java.util.concurrent.Callable<T> callable, ListeningExecutorService listeningExecutorService)
Creates anAsyncCallable
from aCallable
.(package private) static <T> T
MoreExecutors. invokeAnyImpl(ListeningExecutorService executorService, java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, boolean timed, long timeout, java.util.concurrent.TimeUnit unit)
An implementation ofExecutorService.invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>>)
forListeningExecutorService
implementations.(package private) static <T> T
MoreExecutors. invokeAnyImpl(ListeningExecutorService executorService, java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, boolean timed, java.time.Duration timeout)
An implementation ofExecutorService.invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>>)
forListeningExecutorService
implementations.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 toqueue
when it completes. -
Uses of ListeningExecutorService in com.google.common.util.concurrent.testing
Classes in com.google.common.util.concurrent.testing that implement ListeningExecutorService Modifier and Type Class Description (package private) class
SameThreadScheduledExecutorService
A ScheduledExecutorService that executes all scheduled actions immediately in the calling thread.private static class
TestingExecutors.NoOpScheduledExecutorService
Fields in com.google.common.util.concurrent.testing declared as ListeningExecutorService Modifier and Type Field Description private ListeningExecutorService
SameThreadScheduledExecutorService. delegate
-