com.revolsys.parallel.process

Class RunnableChannelExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

com.revolsys.parallel.process.RunnableChannelExecutor

All Implemented Interfaces:

Process, Runnable, Executor, ExecutorService, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public class RunnableChannelExecutor
extends ThreadPoolExecutor
implements Process, org.springframework.beans.factory.BeanNameAware

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
RunnableChannelExecutor()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)
void	closeChannels()
void	execute(Runnable command)
String	getBeanName()
List<Channel<Runnable>>	getChannels()
ProcessNetwork	getProcessNetwork()
void	init()
void	postRun()
protected void	preRun()
void	run()
void	setBeanName(String beanName)
void	setChannels(List<Channel<Runnable>> channels)
void	setProcessNetwork(ProcessNetwork processNetwork)
void	stop()
String	toString()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated

Methods inherited from class java.util.concurrent.AbstractExecutorService

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RunnableChannelExecutor

public RunnableChannelExecutor()

Method Detail

afterExecute

protected void afterExecute(Runnable r,
                Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

closeChannels

public void closeChannels()

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

getBeanName

public String getBeanName()

Specified by:

getBeanName in interface Process

getChannels

public List<Channel<Runnable>> getChannels()

getProcessNetwork

public ProcessNetwork getProcessNetwork()

Specified by:

getProcessNetwork in interface Process

Returns:

the processNetwork

init

@PostConstruct
public void init()

postRun

public void postRun()

preRun

protected void preRun()

run

public void run()

Specified by:

run in interface Runnable

setBeanName

public void setBeanName(String beanName)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

setChannels

public void setChannels(List<Channel<Runnable>> channels)

setProcessNetwork

public void setProcessNetwork(ProcessNetwork processNetwork)

Specified by:

setProcessNetwork in interface Process

Parameters:

processNetwork - the processNetwork to set

stop

@PreDestroy
public void stop()

toString

public String toString()

Overrides:

toString in class ThreadPoolExecutor