Package org.jboss.util.threadpool

Class 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 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 Description
      RunnableTaskWrapper​(java.lang.Runnable runnable)
      Create a new RunnableTaskWrapper
      RunnableTaskWrapper​(java.lang.Runnable runnable, long startTimeout, long completeTimeout)  

    • 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