Package org.apache.uima.collection.impl.cpm.engine

Class CPMExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.apache.uima.collection.impl.cpm.engine.CPMExecutorService

All Implemented Interfaces:

Executor, ExecutorService

public class CPMExecutorService
extends ThreadPoolExecutor

This component catches uncaught errors in the CPM. All critical threads in the CPM are part of this executor service. If OutOfMemory Error is thrown this component is notified by the JVM and its job is to notify registered listeners.

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	Description
CPMExecutorService()

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable aThread, Throwable aThrowable)
void	cleanup()	Cleanup.
protected <T> RunnableFuture<T>	newTaskFor(Runnable aRunnable, T aValue)
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> aCallable)
void	setListeners(List<BaseStatusCallbackListener> aListenerList)	Sets listeners to be used in notifications.
void	setProcessTrace(ProcessTrace aProcessTrace)	Sets the process trace.

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, 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, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

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

Methods inherited from class java.lang.Object

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

Constructor Details

CPMExecutorService

public CPMExecutorService()

Method Details

setListeners

public void setListeners(List<BaseStatusCallbackListener> aListenerList)

Sets listeners to be used in notifications.

Parameters:

aListenerList - list of registered listeners

setProcessTrace

public void setProcessTrace(ProcessTrace aProcessTrace)

Sets the process trace.

Parameters:

aProcessTrace - the new process trace

afterExecute

protected void afterExecute(Runnable aThread,
 Throwable aThrowable)

Overrides:

afterExecute in class ThreadPoolExecutor

cleanup

public void cleanup()

Cleanup.

newTaskFor

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

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable aRunnable,
 T aValue)

Overrides:

newTaskFor in class AbstractExecutorService