|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use TaskID | |
---|---|
pt.queues | Thread-safe queues with alternate scheduling policies. |
pt.runtime | Parallel Task runtime classes. |
Uses of TaskID in pt.queues |
---|
Methods in pt.queues that return TaskID | |
---|---|
TaskID |
PipelineQueue.getHeadTask()
|
TaskID |
PipelineQueue.getTailTask()
|
Methods in pt.queues with parameters of type TaskID | |
---|---|
void |
PipelineQueue.setHeadTask(TaskID tid)
|
void |
PipelineQueue.setTailTask(TaskID tid)
|
Constructors in pt.queues with parameters of type TaskID | |
---|---|
PipelineQueue(TaskID head,
TaskID tail)
|
|
PipelineQueue(TaskID head,
TaskID tail)
|
Uses of TaskID in pt.runtime |
---|
Subclasses of TaskID in pt.runtime | |
---|---|
class |
TaskIDGroup<E>
An extension of TaskID to contain multiple tasks. |
Fields in pt.runtime declared as TaskID | |
---|---|
protected TaskID<?> |
TaskID.enclosingTask
|
Fields in pt.runtime with type parameters of type TaskID | |
---|---|
protected java.util.Stack<TaskID> |
TaskThread.currentTaskStack
|
protected static java.util.Comparator<TaskID<?>> |
AbstractTaskPool.FIFO_TaskID_Comparator
|
protected java.util.concurrent.PriorityBlockingQueue<TaskID<?>> |
AbstractTaskPool.globalTaskqueue
|
protected static java.util.Comparator<TaskID<?>> |
AbstractTaskPool.LIFO_TaskID_Comparator
|
protected FifoLifoQueue<TaskID<?>> |
AbstractTaskPool.mixedQueue
|
protected java.util.concurrent.ConcurrentHashMap<TaskID<?>,java.lang.Object> |
AbstractTaskPool.waitingTasks
|
Methods in pt.runtime that return TaskID | |
---|---|
TaskID |
TaskThread.currentExecutingTask()
Return the currently executing TaskID by this TaskThread |
static TaskID |
CurrentTask.currentTaskID()
Return the current TaskID associated with the currently executing task. |
TaskID |
Taskpool.enqueue(TaskInfo taskinfo)
Enqueues the specified task, whose information is contained in the TaskInfo. |
TaskID |
AbstractTaskPool.enqueue(TaskInfo taskinfo)
|
TaskID<?> |
Slot.getTaskID()
|
TaskID |
TaskpoolMixedScheduling.workerPollNextTask()
|
TaskID |
TaskpoolLIFOWorkStealing.workerPollNextTask()
|
TaskID |
TaskpoolFIFOWorkSharing.workerPollNextTask()
Tries to poll for a task for the current worker.. |
TaskID |
Taskpool.workerPollNextTask()
The worker thread polls the task pool for a task.. |
abstract TaskID |
AbstractTaskPool.workerPollNextTask()
|
TaskID |
Taskpool.workerTakeNextTask()
The worker thread blocks until it gets a task to execute. |
TaskID |
AbstractTaskPool.workerTakeNextTask()
|
Methods in pt.runtime that return types with arguments of type TaskID | |
---|---|
static java.util.ArrayList<TaskID> |
ParaTask.allTasksInGroup(TaskIDGroup group)
A recursive convenience function that digs into the TaskIDGroup and returns all the individual TaskIDs. |
static java.util.ArrayList<TaskID> |
ParaTask.allTasksInList(java.util.ArrayList<TaskID> list)
Flattens a list of TaskIDs. |
java.util.ArrayList<TaskID> |
TaskInfo.getDependences()
|
java.util.Iterator<TaskID<E>> |
TaskIDGroup.groupMembers()
Return an iterator for the set of TaskID s contained in this group. |
Methods in pt.runtime with parameters of type TaskID | |
---|---|
void |
TaskIDGroup.add(TaskID<E> id)
Add a task to this group. |
void |
TaskInfo.addDependsOn(TaskID otherTask)
Adds a dependency on the given task. |
protected void |
TaskpoolFIFOWorkSharing.enqueueReadyTask(TaskID taskID)
|
protected void |
TaskpoolMixedScheduling.enqueueReadyTask(TaskID<?> taskID)
|
protected void |
TaskpoolLIFOWorkStealing.enqueueReadyTask(TaskID<?> taskID)
|
protected abstract void |
AbstractTaskPool.enqueueReadyTask(TaskID<?> taskID)
|
protected void |
AbstractTaskPool.enqueueWaitingTask(TaskID taskID,
java.util.ArrayList<TaskID> allDependences)
|
protected boolean |
TaskThread.executeTask(TaskID task)
Executes the current task for this thread, and stores the result in the TaskID |
protected java.util.concurrent.BlockingQueue<E> |
TaskID.getOutputQueue(TaskID requester)
If this is a pipeline stage, get a queue from which all future results can be retrieved. |
void |
Taskpool.interactiveTaskCompleted(TaskID<?> taskID)
Used to decrement the count of interactive tasks |
void |
AbstractTaskPool.interactiveTaskCompleted(TaskID<?> taskID)
|
void |
Taskpool.nowReady(TaskID<?> taskID)
The specified task is currently on the waiting queue since it has some dependences. |
void |
AbstractTaskPool.nowReady(TaskID<?> waiter)
|
static void |
ParaTaskHelper.setComplete(TaskID id)
|
void |
Slot.setTaskID(TaskID<?> taskID)
|
void |
TaskInfo.setTaskIDForSlotsAndHandlers(TaskID taskID)
|
protected void |
AbstractTaskPool.startInteractiveTask(TaskID taskID)
|
protected void |
AbstractTaskPool.startPipelineTask(TaskID taskID)
|
Method parameters in pt.runtime with type arguments of type TaskID | |
---|---|
static java.util.ArrayList<TaskID> |
ParaTask.allTasksInList(java.util.ArrayList<TaskID> list)
Flattens a list of TaskIDs. |
protected void |
AbstractTaskPool.enqueueWaitingTask(TaskID taskID,
java.util.ArrayList<TaskID> allDependences)
|
Constructors in pt.runtime with parameters of type TaskID | |
---|---|
InteractiveThread(Taskpool taskpool,
TaskID task)
|
|
PipelineThread(Taskpool taskpool,
TaskID task)
|
|
SubstituteThread(TaskID<?> taskIDWaitingFor,
Taskpool taskpool,
int substituteForThreadID)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |