Class ForwardingListeningExecutorService
- java.lang.Object
-
- com.google.common.collect.ForwardingObject
-
- com.google.common.util.concurrent.ForwardingExecutorService
-
- com.google.common.util.concurrent.ForwardingListeningExecutorService
-
- All Implemented Interfaces:
ListeningExecutorService
,java.util.concurrent.Executor
,java.util.concurrent.ExecutorService
@GwtIncompatible public abstract class ForwardingListeningExecutorService extends ForwardingExecutorService implements ListeningExecutorService
A listening executor service which forwards all its method calls to another listening executor service. Subclasses should override one or more methods to modify the behavior of the backing executor service as desired per the decorator pattern.- Since:
- 10.0
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
ForwardingListeningExecutorService()
Constructor for use by subclasses.
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract ListeningExecutorService
delegate()
Returns the backing delegate instance that methods are forwarded to.ListenableFuture<?>
submit(java.lang.Runnable task)
<T> ListenableFuture<T>
submit(java.lang.Runnable task, T result)
<T> ListenableFuture<T>
submit(java.util.concurrent.Callable<T> task)
-
Methods inherited from class com.google.common.util.concurrent.ForwardingExecutorService
awaitTermination, execute, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow
-
Methods inherited from class com.google.common.collect.ForwardingObject
toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow
-
Methods inherited from interface com.google.common.util.concurrent.ListeningExecutorService
invokeAll, invokeAll
-
-
-
-
Method Detail
-
delegate
protected abstract ListeningExecutorService delegate()
Description copied from class:ForwardingObject
Returns the backing delegate instance that methods are forwarded to. Abstract subclasses generally override this method with an abstract method that has a more specific return type, such asForwardingSet.delegate()
. Concrete subclasses override this method to supply the instance being decorated.- Specified by:
delegate
in classForwardingExecutorService
-
submit
public <T> ListenableFuture<T> submit(java.util.concurrent.Callable<T> task)
- Specified by:
submit
in interfacejava.util.concurrent.ExecutorService
- Specified by:
submit
in interfaceListeningExecutorService
- Overrides:
submit
in classForwardingExecutorService
- Returns:
- a
ListenableFuture
representing pending completion of the task
-
submit
public ListenableFuture<?> submit(java.lang.Runnable task)
- Specified by:
submit
in interfacejava.util.concurrent.ExecutorService
- Specified by:
submit
in interfaceListeningExecutorService
- Overrides:
submit
in classForwardingExecutorService
- Returns:
- a
ListenableFuture
representing pending completion of the task
-
submit
public <T> ListenableFuture<T> submit(java.lang.Runnable task, T result)
- Specified by:
submit
in interfacejava.util.concurrent.ExecutorService
- Specified by:
submit
in interfaceListeningExecutorService
- Overrides:
submit
in classForwardingExecutorService
- Returns:
- a
ListenableFuture
representing pending completion of the task
-
-