org.jboss.util.threadpool
Class RunnableTaskWrapper

java.lang.Object
  extended byorg.jboss.util.threadpool.RunnableTaskWrapper
All Implemented Interfaces:
java.lang.Runnable, TaskWrapper (src)

public class RunnableTaskWrapper
extends java.lang.Object
implements TaskWrapper (src)

Makes a runnable a task.


Constructor Summary
RunnableTaskWrapper(java.lang.Runnable runnable)
          Create a new RunnableTaskWrapper
RunnableTaskWrapper(java.lang.Runnable runnable, long startTimeout, long completeTimeout)
           
 
Method Summary
 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()
          Indicate if the task has exited the Runnable#run method
 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
 

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 (src)
Get the type of wait

Specified by:
getTaskWaitType in interface TaskWrapper (src)
Returns:
the wait type

getTaskPriority

public int getTaskPriority()
Description copied from interface: TaskWrapper (src)
The priority of the task

Specified by:
getTaskPriority in interface TaskWrapper (src)
Returns:
the task priority

getTaskStartTimeout

public long getTaskStartTimeout()
Description copied from interface: TaskWrapper (src)
The time before the task must be accepted

Specified by:
getTaskStartTimeout in interface TaskWrapper (src)
Returns:
the start timeout

getTaskCompletionTimeout

public long getTaskCompletionTimeout()
Description copied from interface: TaskWrapper (src)
The time before the task must be completed

Specified by:
getTaskCompletionTimeout in interface TaskWrapper (src)
Returns:
the completion timeout

acceptTask

public void acceptTask()
Description copied from interface: TaskWrapper (src)
The task has been accepted

Specified by:
acceptTask in interface TaskWrapper (src)

rejectTask

public void rejectTask(java.lang.RuntimeException t)
Description copied from interface: TaskWrapper (src)
The task has been rejected

Specified by:
rejectTask in interface TaskWrapper (src)
Parameters:
t - any error associated with the rejection

stopTask

public void stopTask()
Description copied from interface: TaskWrapper (src)
Invoked by the threadpool when it wants to stop the task

Specified by:
stopTask in interface TaskWrapper (src)

waitForTask

public void waitForTask()
Description copied from interface: TaskWrapper (src)
Wait according the wait type

Specified by:
waitForTask in interface TaskWrapper (src)

isComplete

public boolean isComplete()
Description copied from interface: TaskWrapper (src)
Indicate if the task has exited the Runnable#run method

Specified by:
isComplete in interface TaskWrapper (src)
Returns:
true if the task has exited the Runnable#run method

run

public void run()
Specified by:
run in interface java.lang.Runnable