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 interfaceListeningScheduledExecutorServiceAScheduledExecutorServicethat returnsListenableFutureinstances from itsExecutorServicemethods.Classes in com.google.common.util.concurrent that implement ListeningExecutorService Modifier and Type Class Description classAbstractListeningExecutorServiceAbstractListeningExecutorServiceimplementation that createsListenableFutureinstances for eachRunnableandCallablesubmitted to it.classForwardingListeningExecutorServiceA listening executor service which forwards all its method calls to another listening executor service.private static classMoreExecutors.DirectExecutorServiceprivate static classMoreExecutors.ListeningDecoratorprivate static classMoreExecutors.ScheduledListeningDecoratorMethods in com.google.common.util.concurrent that return ListeningExecutorService Modifier and Type Method Description protected abstract ListeningExecutorServiceForwardingListeningExecutorService. delegate()static ListeningExecutorServiceMoreExecutors. listeningDecorator(java.util.concurrent.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 ListeningExecutorService Modifier and Type Method Description static <T> AsyncCallable<T>Callables. asAsyncCallable(java.util.concurrent.Callable<T> callable, ListeningExecutorService listeningExecutorService)Creates anAsyncCallablefrom aCallable.(package private) static <T> TMoreExecutors. 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>>)forListeningExecutorServiceimplementations.(package private) static <T> TMoreExecutors. 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>>)forListeningExecutorServiceimplementations.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. -
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) classSameThreadScheduledExecutorServiceA ScheduledExecutorService that executes all scheduled actions immediately in the calling thread.private static classTestingExecutors.NoOpScheduledExecutorServiceFields in com.google.common.util.concurrent.testing declared as ListeningExecutorService Modifier and Type Field Description private ListeningExecutorServiceSameThreadScheduledExecutorService. delegate
-