org.apache.river.thread

Class ExtensibleExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.apache.river.thread.ExtensibleExecutorService

All Implemented Interfaces:

Executor, ExecutorService

public class ExtensibleExecutorService
extends AbstractExecutorService

AbstractExecutorService introduced two protected methods in Java 1.6 to allow an ExecutorService to use customised RunnableFuture implementations other than the default FutureTask. This class requires a Factory to create the RunnableFuture, encapsulating any existing ExecutorService. This allows an ExecutorService to be provided by Configuration or a pool to be shared without requiring that all implementations also share the same type of RunnableFuture<T>.

Author:

Peter Firmstone

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ExtensibleExecutorService.RunnableFutureFactory Factory for creating custom RunnableFuture implementations.

Constructor Summary

Constructors

Constructor and Description
ExtensibleExecutorService(ExecutorService executor, ExtensibleExecutorService.RunnableFutureFactory factory)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable command)
boolean	isShutdown()
boolean	isTerminated()
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> c)
protected <T> RunnableFuture<T>	newTaskFor(Runnable r, T value)
void	shutdown()
List<Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

ExtensibleExecutorService

public ExtensibleExecutorService(ExecutorService executor,
                                 ExtensibleExecutorService.RunnableFutureFactory factory)

Method Detail

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable r,
                                           T value)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> c)

Overrides:

newTaskFor in class AbstractExecutorService

shutdown

public void shutdown()

shutdownNow

public List<Runnable> shutdownNow()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

awaitTermination

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

Throws:

InterruptedException

execute

public void execute(Runnable command)