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 TypeInterfaceDescriptioninterfaceAScheduledExecutorServicethat returnsListenableFutureinstances from itsExecutorServicemethods.Classes in com.google.common.util.concurrent that implement ListeningExecutorServiceModifier and TypeClassDescriptionclassAbstractListeningExecutorServiceimplementation that createsListenableFutureinstances for eachRunnableandCallablesubmitted to it.(package private) final classSee newDirectExecutorService javadoc for behavioral notes.classA listening executor service which forwards all its method calls to another listening executor service.private static classprivate static final classMethods in com.google.common.util.concurrent that return ListeningExecutorServiceModifier and TypeMethodDescriptionprotected abstract ListeningExecutorServiceForwardingListeningExecutorService.delegate()static ListeningExecutorServiceMoreExecutors.listeningDecorator(ExecutorService delegate) Creates anExecutorServicewhosesubmitandinvokeAllmethods submitListenableFutureTaskinstances to the given delegate executor.static ListeningExecutorServiceMoreExecutors.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 anAsyncCallablefrom aCallable.(package private) static <T> TMoreExecutors.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>>)forListeningExecutorServiceimplementations.(package private) static <T> TMoreExecutors.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>>)forListeningExecutorServiceimplementations.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 toqueuewhen 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) classA ScheduledExecutorService that executes all scheduled actions immediately in the calling thread.private static final classFields in com.google.common.util.concurrent.testing declared as ListeningExecutorServiceModifier and TypeFieldDescriptionprivate final ListeningExecutorServiceSameThreadScheduledExecutorService.delegate