Class ForwardingExecutorService

java.lang.Object

com.google.common.collect.ForwardingObject

com.google.common.util.concurrent.ForwardingExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

Direct Known Subclasses:

ForwardingListeningExecutorService

@GwtIncompatible
public abstract class ForwardingExecutorService
extends ForwardingObject
implements ExecutorService

An executor service which forwards all its method calls to another executor service. Subclasses should override one or more methods to modify the behavior of the backing executor service as desired per the decorator pattern.

default method warning: This class does not forward calls to default methods. Instead, it inherits their default implementations. When those implementations invoke methods, they invoke methods on the ForwardingExecutorService.

Since:

10.0

Author:

Kurt Alfred Kluever

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ForwardingExecutorService()	Constructor for use by subclasses.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
protected abstract ExecutorService	delegate()	Returns the backing delegate instance that methods are forwarded to.
void	execute(Runnable command)
<T extends @Nullable Object> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T extends @Nullable Object> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T extends @Nullable Object> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T extends @Nullable Object> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
<T extends @Nullable Object> Future<T>	submit(Runnable task, T result)
<T extends @Nullable Object> Future<T>	submit(Callable<T> task)

Methods inherited from class ForwardingObject

toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ExecutorService

close

Constructor Details

ForwardingExecutorService

protected ForwardingExecutorService()

Constructor for use by subclasses.

Method Details

delegate

protected abstract ExecutorService 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 as ForwardingSet.delegate(). Concrete subclasses override this method to supply the instance being decorated.

Specified by:

delegate in class ForwardingObject

awaitTermination

@CheckReturnValue
public boolean awaitTermination(long timeout,
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T extends @Nullable Object> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                                                       throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T extends @Nullable Object> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                                                       throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks)
                                         throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                                         throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@CanIgnoreReturnValue
public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

submit

public <T extends @Nullable Object> Future<T> submit(Callable<T> task)

Specified by:

submit in interface ExecutorService

submit

public Future<?> submit(Runnable task)

Specified by:

submit in interface ExecutorService

submit

public <T extends @Nullable Object> Future<T> submit(Runnable task,
 T result)

Specified by:

submit in interface ExecutorService