A B C D E F G H I L M N O P R S T U V W

A

activeInteractiveTaskCount() - Static method in class pt.runtime.ParaTask

Returns a count of the number of active interactive tasks.

add(E) - Method in class pt.queues.FifoLifoQueue

Deprecated. If the calling thread already has a local queue, or the calling thread is registered as a worker thread, then this call is equivalent to FifoLifoQueue.addLocal(Object). Otherwise, the call is equivalent to FifoLifoQueue.addGlobal(Object). It is therefore recommended to explicitly use FifoLifoQueue.addLocal(Object) or FifoLifoQueue.addGlobal(Object) to ensure the correct intention is performed.

add(E) - Method in class pt.queues.WorkStealingQueue

add(TaskID<E>) - Method in class pt.runtime.TaskIDGroup

addAll(Collection<? extends E>) - Method in class pt.queues.WorkStealingQueue

addGlobal(E) - Method in class pt.queues.FifoLifoQueue

Add the specified element globally.

addLocal(E) - Method in class pt.queues.FifoLifoQueue

Add the specified element locally.

allTasksInGroup(TaskIDGroup) - Static method in class pt.runtime.ParaTask

A recursive convenience function that digs into the TaskIDGroup and returns all the individual TaskIDs.

allTasksInList(ArrayList<TaskID>) - Static method in class pt.runtime.ParaTask

Flattens a list of TaskIDs.

ArrayCOMBINE - Static variable in interface pt.runtime.Reduction

Combines the elements from the arrays into a new array.

asList() - Method in class pt.queues.FifoLifoQueue

asList() - Method in class pt.queues.WorkStealingQueue

attemptToStealNonRandom() - Method in class pt.queues.WorkStealingQueue

attemptToStealRandom() - Method in class pt.queues.WorkStealingQueue

B

barrier() - Static method in class pt.runtime.CurrentTask

Barrier synchronisation for multi-tasks.

BooleanAND - Static variable in interface pt.runtime.Reduction

Performs a Boolean AND

BooleanOR - Static variable in interface pt.runtime.Reduction

Performs a Boolean OR

C

cancelAttempt() - Method in class pt.runtime.TaskID

Attempts to cancel the task.

cancelAttempt() - Method in class pt.runtime.TaskIDGroup

Canceling a group is currently not supported.

cancelChildTasks() - Method in class pt.runtime.TaskID

For internal use only.

cancelled - Variable in class pt.runtime.TaskID

CANCELLED - Static variable in class pt.runtime.TaskID

cancelledSuccessfully() - Method in class pt.runtime.TaskID

Checks to see if this task has successfully cancelled.

cancelRequested() - Static method in class pt.runtime.CurrentTask

The current task checks to see if it has been requested to cancel.

cancelRequested - Variable in class pt.runtime.TaskID

cancelRequested() - Method in class pt.runtime.TaskID

Checks to see if this task has been requested to cancel.

capacity - Variable in class pt.queues.WorkStealingQueue

chunksize - Variable in class pt.queues.WorkStealingQueue

clear() - Method in class pt.queues.FifoLifoQueue

clear() - Method in class pt.queues.WorkStealingQueue

combine(E, E) - Method in interface pt.runtime.Reduction

Specifies a reduction as defined by 2 elements into 1.

contains(Object) - Method in class pt.queues.FifoLifoQueue

contains(Object) - Method in class pt.queues.WorkStealingQueue

containsAll(Collection<?>) - Method in class pt.queues.WorkStealingQueue

CREATED - Static variable in class pt.runtime.TaskID

CurrentTask - Class in pt.runtime

Helper methods for the currently executing task.

currentTaskID() - Static method in class pt.runtime.CurrentTask

Return the current TaskID associated with the currently executing task.

currentThreadID() - Static method in class pt.runtime.CurrentTask

Returns the ParaTask thread's ID.

currentThreadIsTheRegisteredThread() - Method in class pt.runtime.TaskID

currentThreadLocalID() - Static method in class pt.runtime.CurrentTask

D

DoubleMAX - Static variable in interface pt.runtime.Reduction

Perform a maximum reduction for Double values.

DoubleMIN - Static variable in interface pt.runtime.Reduction

Perform a minimum reduction for Double values.

DoubleSUM - Static variable in interface pt.runtime.Reduction

Perform a sum reduction for Double values.

drainTo(Collection<? super E>, int) - Method in class pt.queues.FifoLifoQueue

drainTo(Collection<? super E>) - Method in class pt.queues.WorkStealingQueue

drainTo(Collection<? super E>, int) - Method in class pt.queues.WorkStealingQueue

E

element() - Method in class pt.queues.FifoLifoQueue

element() - Method in class pt.queues.WorkStealingQueue

enclosingTask - Variable in class pt.runtime.TaskID

executeIntermediateSlots() - Method in class pt.runtime.TaskID

executeSlots() - Method in class pt.runtime.TaskID

F

FifoLifoQueue<E> - Class in pt.queues

A mixed-schedule queue.

FifoLifoQueue() - Constructor for class pt.queues.FifoLifoQueue

Creates an empty queue with maximum capacity and chunksize of 1.

FifoLifoQueue(int, int) - Constructor for class pt.queues.FifoLifoQueue

Creates an empty queue with the specified chunksize and capacity.

FifoLifoQueue(Collection<? extends E>, int) - Constructor for class pt.queues.FifoLifoQueue

Creates a queue containing the specified collection with the specified chunksize.

FifoLifoQueue(long[]) - Constructor for class pt.queues.FifoLifoQueue

Create an empty queue with unlimited capacity and chunksize of 1.

G

getActiveCount(ParaTask.ThreadPoolType) - Static method in class pt.runtime.ParaTask

getCount() - Method in class pt.runtime.TaskID

getEDT() - Static method in class pt.runtime.ParaTask

getException() - Method in class pt.runtime.TaskID

Returns the exception that occurred while this task executed.

getException() - Method in class pt.runtime.TaskIDGroup

getExceptionHandler(Class) - Method in class pt.runtime.TaskID

getExpanded() - Method in class pt.runtime.TaskIDGroup

getGroup() - Method in class pt.runtime.TaskID

Returns the group that this task is part of (assuming it is a multi-task).

getInnerTaskResult(int) - Method in class pt.runtime.TaskIDGroup

Returns the result of a particular task.

getOutputQueue() - Method in class pt.runtime.TaskID

If this is a pipeline stage, get a queue from which all future results can be retrieved.

getOutputQueue(TaskID) - Method in class pt.runtime.TaskID

If this is a pipeline stage, get a queue from which all future results can be retrieved.

getProgress() - Static method in class pt.runtime.CurrentTask

Returns the progress of the currently executed task.

getProgress() - Method in class pt.runtime.TaskID

Returns the current progress of this task

getReturnResult() - Method in class pt.runtime.TaskID

Returns the result of the task.

getReturnResult() - Method in class pt.runtime.TaskIDGroup

Get the result of a group of tasks.

getReturnResult(Reduction<E>) - Method in class pt.runtime.TaskIDGroup

Perform a reduction on the results contained in the group.

getScheduleType() - Static method in class pt.runtime.ParaTask

Returns the schedule being used in the runtime.

getTaskArguments() - Method in class pt.runtime.TaskID

Returns the arguments that were passed to this task when it was invoked.

getTaskName() - Method in class pt.runtime.TaskID

Returns the (method) name of the task.

getThreadPoolSize(ParaTask.ThreadPoolType) - Static method in class pt.runtime.ParaTask

Returns the size of the thread pool.

globalID() - Static method in class pt.runtime.CurrentTask

Returns the current task's global ID.

globalID - Variable in class pt.runtime.TaskID

globalID() - Method in class pt.runtime.TaskID

Returns the task's globally-unique ID.

group - Variable in class pt.runtime.TaskID

groupMembers() - Method in class pt.runtime.TaskIDGroup

Return an iterator for the set of TaskIDs contained in this group.

groupSize() - Method in class pt.runtime.TaskIDGroup

Returns the group size.

H

HALF - Static variable in class pt.queues.WorkStealingQueue

hasCompleted - Variable in class pt.runtime.TaskID

hasCompleted() - Method in class pt.runtime.TaskID

Checks to see whether the task has completed.

hasCompleted() - Method in class pt.runtime.TaskIDGroup

Checks to see whether all the inner tasks have completed.

hasSlots - Variable in class pt.runtime.TaskID

hasUserError - Variable in class pt.runtime.TaskID

hasUserError() - Method in class pt.runtime.TaskID

Checks to see whether the task had any errors.

hasUserError() - Method in class pt.runtime.TaskIDGroup

Checks to see whether any of the inner tasks contained an error.

I

init() - Static method in class pt.runtime.ParaTask

To be executed by the main thread (i.e.

insideTask() - Static method in class pt.runtime.CurrentTask

Inquire as to whether the current code being executed is inside a task.

IntegerMAX - Static variable in interface pt.runtime.Reduction

Perform a maximum reduction for Integer values.

IntegerMIN - Static variable in interface pt.runtime.Reduction

Perform a minimum reduction for Integer values.

IntegerSUM - Static variable in interface pt.runtime.Reduction

Perform a sum reduction for Integer values.

isEmpty() - Method in class pt.queues.FifoLifoQueue

isEmpty() - Method in class pt.queues.WorkStealingQueue

isInteractive() - Method in class pt.runtime.TaskID

Checks to see if this task is an interactibe task.

isMultiTask() - Static method in class pt.runtime.CurrentTask

isMultiTask() - Method in class pt.runtime.TaskID

Checks to see if this task is part of a multi-task group.

isMultiTask() - Method in class pt.runtime.TaskIDGroup

Checks whether this TaskIDGroup represents a multi-task.

isOneoffTask() - Static method in class pt.runtime.CurrentTask

isPipeline() - Method in class pt.runtime.TaskID

Checks to see if this task if a part of a pipeline.

isSubTask() - Static method in class pt.runtime.CurrentTask

isSubTask() - Method in class pt.runtime.TaskID

iterator() - Method in class pt.queues.WorkStealingQueue

L

localDeques - Variable in class pt.queues.WorkStealingQueue

M

main(String[]) - Static method in class pt.compiler.ParaTaskParser

A command-line option to use the ParaTask compiler.

multiTaskSize() - Static method in class pt.runtime.CurrentTask

Returns the current task's multi-task size.

multiTaskSize() - Method in class pt.runtime.TaskID

Returns the size of the multi-task this task is part of.

N

nextGlobalID - Static variable in class pt.runtime.TaskID

O

offer(E) - Method in class pt.queues.WorkStealingQueue

offer(E, long, TimeUnit) - Method in class pt.queues.WorkStealingQueue

P

ParaTask - Class in pt.runtime

Helper methods for the ParaTask runtime.

ParaTask.ScheduleType - Enum in pt.runtime

Enum representing the possible schedules that ParaTask supports.

ParaTask.ThreadPoolType - Enum in pt.runtime

Enum representing the possible thread pool types that ParaTask supports.

ParaTaskParser - Class in pt.compiler

The source-to-source ParaTask compiler.

parse(File) - Static method in class pt.compiler.ParaTaskParser

Parse the ParaTask input into standard Java code.

peek() - Method in class pt.queues.WorkStealingQueue

poll() - Method in class pt.queues.FifoLifoQueue

poll(long, TimeUnit) - Method in class pt.queues.WorkStealingQueue

poll() - Method in class pt.queues.WorkStealingQueue

pollLocalQueue() - Method in class pt.queues.WorkStealingQueue

pt.compiler - package pt.compiler

Parallel Task source-to-source compiler.

pt.queues - package pt.queues

Thread-safe queues with alternate scheduling policies.

pt.runtime - package pt.runtime

Parallel Task runtime classes.

publishInterim(E) - Static method in class pt.runtime.CurrentTask

Publish intermediate results.

put(E) - Method in class pt.queues.WorkStealingQueue

R

reduce(Reduction<E>) - Method in class pt.runtime.TaskIDGroup

Perform a reduction on the set of results.

Reduction<E> - Interface in pt.runtime

Define a reduction of two items into one.

relativeID() - Static method in class pt.runtime.CurrentTask

All tasks have a relative ID.

relativeID - Variable in class pt.runtime.TaskID

relativeID() - Method in class pt.runtime.TaskID

Returns the sub-task's relative ID in the multi-task.

remainingCapacity - Variable in class pt.queues.WorkStealingQueue

remainingCapacity() - Method in class pt.queues.WorkStealingQueue

remove(Object) - Method in class pt.queues.FifoLifoQueue

remove(Object) - Method in class pt.queues.WorkStealingQueue

remove() - Method in class pt.queues.WorkStealingQueue

removeAll(Collection<?>) - Method in class pt.queues.WorkStealingQueue

retainAll(Collection<?>) - Method in class pt.queues.WorkStealingQueue

S

setCount(int) - Method in class pt.runtime.TaskID

setExpanded(boolean) - Method in class pt.runtime.TaskIDGroup

setGlobalID(int) - Method in class pt.runtime.TaskID

setPipelineThread(PipelineThread) - Method in class pt.runtime.TaskID

Assigns the thread for this stage of the pipeline.

setProgress(int) - Static method in class pt.runtime.CurrentTask

Updates the progress of the currently executing task.

setScheduling(ParaTask.ScheduleType) - Static method in class pt.runtime.ParaTask

Set the scheduling scheme.

setSubTask(boolean) - Method in class pt.runtime.TaskID

setThreadPoolIDs(long[]) - Method in class pt.queues.FifoLifoQueue

Set the set of threads that will be the worker-threads.

setThreadPoolSize(ParaTask.ThreadPoolType, int) - Static method in class pt.runtime.ParaTask

Set the size of the thread pool.

size() - Method in class pt.queues.FifoLifoQueue

size() - Method in class pt.queues.WorkStealingQueue

sleep_amount_milli - Static variable in class pt.queues.WorkStealingQueue

STARTED - Static variable in class pt.runtime.TaskID

status - Variable in class pt.runtime.TaskID

T

take() - Method in class pt.queues.WorkStealingQueue

TaskID<E> - Class in pt.runtime

A future object representing a task invocation.

TaskIDGroup<E> - Class in pt.runtime

An extension of TaskID to contain multiple tasks.

TaskIDGroup(int) - Constructor for class pt.runtime.TaskIDGroup

This public constructor is actually used to group a bunch of tasks, which may include one-off task or multi task, should not give any id to this group.

taskInfo - Variable in class pt.runtime.TaskID

toArray() - Method in class pt.queues.WorkStealingQueue

toArray(T[]) - Method in class pt.queues.WorkStealingQueue

U

unregisterOutputQueue(<any>) - Method in class pt.runtime.TaskID

Unregisters a queue from a pipeline stage so that new results are no longer written to it.

V

valueOf(String) - Static method in enum pt.runtime.ParaTask.ScheduleType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum pt.runtime.ParaTask.ThreadPoolType

Returns the enum constant of this type with the specified name.

values() - Static method in enum pt.runtime.ParaTask.ScheduleType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum pt.runtime.ParaTask.ThreadPoolType

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitTillFinished() - Method in class pt.runtime.TaskID

Blocks the current thread until the task finishes.

waitTillFinished() - Method in class pt.runtime.TaskIDGroup

Waits for all the contained inner tasks to complete.

WorkStealingQueue<E> - Class in pt.queues

An implementation of a work-stealing queue.

WorkStealingQueue() - Constructor for class pt.queues.WorkStealingQueue

Create an empty WorkStealingQueue with maximum capacity and chunksize of 1.

WorkStealingQueue(int, int) - Constructor for class pt.queues.WorkStealingQueue

Create an empty WorkStealingQueue with the specified capacity and chunksize.

WorkStealingQueue(Collection<? extends E>, int) - Constructor for class pt.queues.WorkStealingQueue

Create a WorkStealingQueue that contains the specified collection of elements and specified chunksize.

writeToOutputQueues(E) - Method in class pt.runtime.TaskID

Write something into the output queue(s) handled by this TaskID.

A B C D E F G H I L M N O P R S T U V W