org.argeo.slc.core.execution

Class ProcessThread

java.lang.Object

java.lang.Thread

org.argeo.slc.core.execution.ProcessThread

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

JcrProcessThread

public class ProcessThread
extends java.lang.Thread

Main thread coordinating an ExecutionProcess, launching parallel or sequential ExecutionThreads.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ProcessThread(java.lang.ThreadGroup processesThreadGroup, ExecutionModulesManager executionModulesManager, ExecutionProcess process)

Method Summary

Modifier and Type	Method and Description
protected void	execute(RealizedFlow realizedFlow, java.lang.Boolean synchronous)
ExecutionModulesManager	getExecutionModulesManager()
ExecutionProcess	getProcess()
ProcessThreadGroup	getProcessThreadGroup()
protected void	process() Implementation specific execution.
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessThread

public ProcessThread(java.lang.ThreadGroup processesThreadGroup,
                     ExecutionModulesManager executionModulesManager,
                     ExecutionProcess process)

Method Detail

run

public final void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

process

protected void process()
                throws java.lang.InterruptedException

Implementation specific execution. To be overridden in order to deal with custom process types. Default expects an SlcExecution.

Throws:

java.lang.InterruptedException

execute

protected final void execute(RealizedFlow realizedFlow,
                             java.lang.Boolean synchronous)
                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getProcess

public ExecutionProcess getProcess()

getProcessThreadGroup

public ProcessThreadGroup getProcessThreadGroup()

getExecutionModulesManager

public ExecutionModulesManager getExecutionModulesManager()