Class AbstractListeningExecutorService
java.lang.Object
java.util.concurrent.AbstractExecutorService
com.google.common.util.concurrent.AbstractListeningExecutorService
- All Implemented Interfaces:
ListeningExecutorService,Executor,ExecutorService
- Direct Known Subclasses:
MoreExecutors.DirectExecutorService,MoreExecutors.ListeningDecorator,TestingExecutors.NoOpScheduledExecutorService
public abstract class AbstractListeningExecutorService
extends AbstractExecutorService
implements ListeningExecutorService
Abstract
ListeningExecutorService implementation that creates ListenableFuture
instances for each Runnable and Callable submitted to it. These tasks are run
with the abstract execute(Runnable) method.
In addition to Executor.execute(java.lang.Runnable), subclasses must implement all methods related to shutdown and
termination.
- Since:
- 14.0
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final <T> RunnableFuture<T>newTaskFor(Runnable runnable, T value) protected final <T> RunnableFuture<T>newTaskFor(Callable<T> callable) <T> ListenableFuture<T><T> ListenableFuture<T>Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAnyMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNowMethods inherited from interface com.google.common.util.concurrent.ListeningExecutorService
invokeAll, invokeAll
-
Constructor Details
-
AbstractListeningExecutorService
public AbstractListeningExecutorService()
-
-
Method Details
-
newTaskFor
- Overrides:
newTaskForin classAbstractExecutorService- Since:
- 19.0 (present with return type
ListenableFutureTasksince 14.0)
-
newTaskFor
- Overrides:
newTaskForin classAbstractExecutorService- Since:
- 19.0 (present with return type
ListenableFutureTasksince 14.0)
-
submit
- Specified by:
submitin interfaceExecutorService- Specified by:
submitin interfaceListeningExecutorService- Overrides:
submitin classAbstractExecutorService- Returns:
- a
ListenableFuturerepresenting pending completion of the task
-
submit
- Specified by:
submitin interfaceExecutorService- Specified by:
submitin interfaceListeningExecutorService- Overrides:
submitin classAbstractExecutorService- Returns:
- a
ListenableFuturerepresenting pending completion of the task
-
submit
- Specified by:
submitin interfaceExecutorService- Specified by:
submitin interfaceListeningExecutorService- Overrides:
submitin classAbstractExecutorService- Returns:
- a
ListenableFuturerepresenting pending completion of the task
-