org.drools.reteoo
Class PartitionTaskManager.PartitionTask
java.lang.Object
org.drools.reteoo.PartitionTaskManager.PartitionTask
- All Implemented Interfaces:
- Comparable<PartitionTaskManager.PartitionTask>, Runnable
- Enclosing class:
- PartitionTaskManager
public static class PartitionTaskManager.PartitionTask
- extends Object
- implements Runnable, Comparable<PartitionTaskManager.PartitionTask>
A worker task that keeps processing the nodes queue.
The task uses a non-blocking queue and is re-submitted
for execution for each element that is added to the queue.
PartitionTaskManager.PartitionTask
public PartitionTaskManager.PartitionTask(PartitionManager manager,
InternalWorkingMemory workingMemory)
- Constructor
- Parameters:
workingMemory
- the working memory reference that is used for node processing
enqueue
public boolean enqueue(PartitionTaskManager.Action action)
run
public void run()
- Default execution method.
- Specified by:
run
in interface Runnable
- See Also:
Runnable
addToExecutorQueue
public void addToExecutorQueue()
getPriority
public int getPriority()
isEnqueued
public boolean isEnqueued()
compareTo
public int compareTo(PartitionTaskManager.PartitionTask o)
- Specified by:
compareTo
in interface Comparable<PartitionTaskManager.PartitionTask>
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2001-2013 JBoss Inc.. All Rights Reserved.