org.jboss.util.threadpool

Class RunnableTaskWrapper

java.lang.Object

org.jboss.util.threadpool.RunnableTaskWrapper

All Implemented Interfaces:

java.lang.Runnable, TaskWrapper

public class RunnableTaskWrapper
extends java.lang.Object
implements TaskWrapper

Makes a runnable a task.

Version:

$Revision$

Field Summary

Fields

Modifier and Type	Field and Description
private long	completionTimeout The completion timeout
private static org.jboss.logging.Logger	log The log
private java.lang.Runnable	runnable The runnable
private java.lang.Thread	runThread
private boolean	started
private long	startTimeout The start timeout

Constructor Summary

Constructors

Constructor and Description
RunnableTaskWrapper(java.lang.Runnable runnable) Create a new RunnableTaskWrapper
RunnableTaskWrapper(java.lang.Runnable runnable, long startTimeout, long completeTimeout)

Method Summary

Modifier and Type	Method and Description
void	acceptTask() The task has been accepted
long	getTaskCompletionTimeout() The time before the task must be completed
int	getTaskPriority() The priority of the task
long	getTaskStartTimeout() The time before the task must be accepted
int	getTaskWaitType() Get the type of wait
boolean	isComplete() Is the task complete.
void	rejectTask(java.lang.RuntimeException t) The task has been rejected
void	run()
void	stopTask() Invoked by the threadpool when it wants to stop the task
void	waitForTask() Wait according the wait type

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.jboss.logging.Logger log

The log

runnable

private java.lang.Runnable runnable

The runnable

started

private boolean started

runThread

private java.lang.Thread runThread

startTimeout

private long startTimeout

The start timeout

completionTimeout

private long completionTimeout

The completion timeout

Constructor Detail

RunnableTaskWrapper

public RunnableTaskWrapper(java.lang.Runnable runnable)

Create a new RunnableTaskWrapper

Parameters:

runnable - the runnable

Throws:

java.lang.IllegalArgumentException - for a null runnable

RunnableTaskWrapper

public RunnableTaskWrapper(java.lang.Runnable runnable,
                           long startTimeout,
                           long completeTimeout)

Method Detail

getTaskWaitType

public int getTaskWaitType()

Description copied from interface: TaskWrapper

Get the type of wait

Specified by:

getTaskWaitType in interface TaskWrapper

Returns:

the wait type

getTaskPriority

public int getTaskPriority()

Description copied from interface: TaskWrapper

The priority of the task

Specified by:

getTaskPriority in interface TaskWrapper

Returns:

the task priority

getTaskStartTimeout

public long getTaskStartTimeout()

Description copied from interface: TaskWrapper

The time before the task must be accepted

Specified by:

getTaskStartTimeout in interface TaskWrapper

Returns:

the start timeout

getTaskCompletionTimeout

public long getTaskCompletionTimeout()

Description copied from interface: TaskWrapper

The time before the task must be completed

Specified by:

getTaskCompletionTimeout in interface TaskWrapper

Returns:

the completion timeout

acceptTask

public void acceptTask()

Description copied from interface: TaskWrapper

The task has been accepted

Specified by:

acceptTask in interface TaskWrapper

rejectTask

public void rejectTask(java.lang.RuntimeException t)

Description copied from interface: TaskWrapper

The task has been rejected

Specified by:

rejectTask in interface TaskWrapper

Parameters:

t - any error associated with the rejection

stopTask

public void stopTask()

Description copied from interface: TaskWrapper

Invoked by the threadpool when it wants to stop the task

Specified by:

stopTask in interface TaskWrapper

waitForTask

public void waitForTask()

Description copied from interface: TaskWrapper

Wait according the wait type

Specified by:

waitForTask in interface TaskWrapper

isComplete

public boolean isComplete()

Description copied from interface: TaskWrapper

Is the task complete.

Specified by:

isComplete in interface TaskWrapper

Returns:

true if compelet, false otherwise

run

public void run()

Specified by:

run in interface java.lang.Runnable