org.codehaus.plexus.taskqueue.execution
Class ThreadedTaskQueueExecutor

java.lang.Object
  extended byorg.codehaus.plexus.logging.AbstractLogEnabled
      extended byorg.codehaus.plexus.taskqueue.execution.ThreadedTaskQueueExecutor
All Implemented Interfaces:
org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable, org.codehaus.plexus.logging.LogEnabled, org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable, TaskQueueExecutor

public class ThreadedTaskQueueExecutor
extends org.codehaus.plexus.logging.AbstractLogEnabled
implements TaskQueueExecutor, org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable, org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable

Version:
$Id: ThreadedTaskQueueExecutor.java 3807 2006-09-02 12:33:18Z kenney $
Author:
Trygve Laugstøl, Kenney Westerhof

Field Summary
 
Fields inherited from interface org.codehaus.plexus.taskqueue.execution.TaskQueueExecutor
ROLE
 
Constructor Summary
ThreadedTaskQueueExecutor()
           
 
Method Summary
 boolean cancelTask(Task task)
          Cancels execution of this task, if it's currently running.
 Task getCurrentTask()
          Returns the currently executing task.
 void initialize()
           
 void start()
           
 void stop()
           
 
Methods inherited from class org.codehaus.plexus.logging.AbstractLogEnabled
enableLogging, getLogger, setupLogger, setupLogger, setupLogger
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ThreadedTaskQueueExecutor

public ThreadedTaskQueueExecutor()
Method Detail

initialize

public void initialize()
                throws org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException
Specified by:
initialize in interface org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable
Throws:
org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException

start

public void start()
           throws org.codehaus.plexus.personality.plexus.lifecycle.phase.StartingException
Specified by:
start in interface org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable
Throws:
org.codehaus.plexus.personality.plexus.lifecycle.phase.StartingException

stop

public void stop()
          throws org.codehaus.plexus.personality.plexus.lifecycle.phase.StoppingException
Specified by:
stop in interface org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable
Throws:
org.codehaus.plexus.personality.plexus.lifecycle.phase.StoppingException

getCurrentTask

public Task getCurrentTask()
Description copied from interface: TaskQueueExecutor
Returns the currently executing task.

Specified by:
getCurrentTask in interface TaskQueueExecutor
Returns:
the currently executing task.

cancelTask

public boolean cancelTask(Task task)
Description copied from interface: TaskQueueExecutor
Cancels execution of this task, if it's currently running. Does NOT remove it from the associated queue!

Specified by:
cancelTask in interface TaskQueueExecutor
Parameters:
task - The task to cancel
Returns:
true if the task was cancelled, false if the task was not executing.


Copyright © 2001-2007 Codehaus. All Rights Reserved.