org.ow2.petals.container.thread
Class AbstractThread

java.lang.Object
  java.lang.Thread
      org.ow2.petals.container.thread.AbstractThread

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

BootstrapThread, ComponentLifeCycleThread

public abstract class AbstractThread
extends java.lang.Thread

This class is the parent class for managing tasks to perform on Components, Bootstrap and ServiceAssemblies. Tasks on those objects are performed in a dedicated thread, preventing the main thread to be blocked. When a timeout exceeds on an action, the task is considered as blocked, and an exception is thrown

Author:

alouis,Christophe Hamerling - EBM WebSourcing

Nested Class Summary

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

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

Field Summary

protected javax.jbi.JBIException	jbiException Exception thrown when a task failed in its own thread.
protected org.ow2.petals.util.LoggingUtil	logger
protected java.util.concurrent.BlockingQueue<java.lang.String>	requestQueue The blocking working queue is equal to a FIFO.
protected java.util.concurrent.BlockingQueue<java.lang.String>	responseQueue The response queue used to wait for the task to complete.
static java.lang.String	SHUTDOWNTHREAD Shutdown thread action
protected long	timeout Time before an action is considered as blocked Exception is thrown when this time exceed

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

AbstractThread(long taskTimeout, org.ow2.petals.util.LoggingUtil logger)
Creates a new instance of AbstractThread

Method Summary

protected abstract boolean	doTask(java.lang.String action) Execute the task in the dedicated thread.
protected void	execute(java.lang.String action) Execute the action.
void	run()
void	shutdownThread() Shutdown the current thread

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

Field Detail

jbiException

protected javax.jbi.JBIException jbiException

Exception thrown when a task failed in its own thread. Retrieved by the main thread

requestQueue

protected java.util.concurrent.BlockingQueue<java.lang.String> requestQueue

The blocking working queue is equal to a FIFO. The worker thread is waiting for an element to be added in this queue by the caller thread. This queue is the synchronization object between caller thread and execution thread. When an element is added by the caller thread, the execution thread wakes up and do the task.

responseQueue

protected java.util.concurrent.BlockingQueue<java.lang.String> responseQueue

The response queue used to wait for the task to complete. The caller thread is blocked on this queue while the task is not complted by the worker thread. This queue is the synchronization object between execution thread and caller thread. When the execution thread put an object in this queue, the caller thread wakes up.

SHUTDOWNTHREAD

public static final java.lang.String SHUTDOWNTHREAD

Shutdown thread action

See Also:

Constant Field Values

logger

protected final org.ow2.petals.util.LoggingUtil logger

timeout

protected long timeout

Time before an action is considered as blocked Exception is thrown when this time exceed

Constructor Detail

AbstractThread

public AbstractThread(long taskTimeout,
                      org.ow2.petals.util.LoggingUtil logger)

Creates a new instance of AbstractThread

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

doTask

protected abstract boolean doTask(java.lang.String action)

Execute the task in the dedicated thread. A JBI exception can occur during the task execution. In this case, the local jbiException must be filled with this exception and is shared between client and thread.

Returns:

false if the current thread needs to be shutdowned

execute

protected void execute(java.lang.String action)
                throws javax.jbi.JBIException

Execute the action. If the thread is not alive, throw an exception. On the other cases, put the action in the FIFO and wait for the task to complete. This method is the entry point of the task submission, multiple threads will wait for other threads to complete.

Parameters:

action -

Throws:

javax.jbi.JBIException

shutdownThread

public void shutdownThread()
                    throws javax.jbi.JBIException

Shutdown the current thread

Throws:

javax.jbi.JBIException