Uses of Interface
com.google.common.util.concurrent.ListeningExecutorService
Packages that use ListeningExecutorService
Package
Description
Concurrency utilities.
-
Uses of ListeningExecutorService in com.google.common.util.concurrent
Subinterfaces of ListeningExecutorService in com.google.common.util.concurrentModifier and TypeInterfaceDescriptioninterface
AScheduledExecutorService
that returnsListenableFuture
instances from itsExecutorService
methods.Classes in com.google.common.util.concurrent that implement ListeningExecutorServiceModifier and TypeClassDescriptionclass
AbstractListeningExecutorService
implementation that createsListenableFuture
instances for eachRunnable
andCallable
submitted to it.(package private) final class
See newDirectExecutorService javadoc for behavioral notes.class
A listening executor service which forwards all its method calls to another listening executor service.private static class
private static final class
Methods in com.google.common.util.concurrent that return ListeningExecutorServiceModifier and TypeMethodDescriptionprotected abstract ListeningExecutorService
ForwardingListeningExecutorService.delegate()
static ListeningExecutorService
MoreExecutors.listeningDecorator
(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 ListeningExecutorServiceModifier and TypeMethodDescriptionstatic <T> AsyncCallable
<T> Callables.asAsyncCallable
(Callable<T> callable, ListeningExecutorService listeningExecutorService) Creates anAsyncCallable
from aCallable
.(package private) static <T> T
MoreExecutors.invokeAnyImpl
(ListeningExecutorService executorService, Collection<? extends Callable<T>> tasks, boolean timed, long timeout, 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, Collection<? extends Callable<T>> tasks, boolean timed, 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, Callable<T> task, BlockingQueue<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 ListeningExecutorServiceModifier and TypeClassDescription(package private) class
A ScheduledExecutorService that executes all scheduled actions immediately in the calling thread.private static final class
Fields in com.google.common.util.concurrent.testing declared as ListeningExecutorServiceModifier and TypeFieldDescriptionprivate final ListeningExecutorService
SameThreadScheduledExecutorService.delegate