org.lenskit.util.parallel

Class TaskGroup

java.lang.Object

java.util.concurrent.ForkJoinTask<Void>

java.util.concurrent.RecursiveAction

org.lenskit.util.parallel.TaskGroup

All Implemented Interfaces:

Serializable, Future<Void>

public class TaskGroup
extends RecursiveAction

A group of tasks to be executed in a fork-join tree.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskGroup(boolean par) Create a new task group.

Method Summary

Modifier and Type	Method and Description
void	addTask(ForkJoinTask<?> task) Add a task to be executed.
protected void	compute()
boolean	isParallel() Query whether the subtasks will be run in parallel.

Methods inherited from class java.util.concurrent.RecursiveAction

exec, getRawResult, setRawResult

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskGroup

public TaskGroup(boolean par)

Create a new task group.

Parameters:

par - true to execute the subtasks in parallel.

Method Detail

isParallel

public boolean isParallel()

Query whether the subtasks will be run in parallel.

Returns:

true if the subtasks are run in parallel.

addTask

public void addTask(ForkJoinTask<?> task)

Add a task to be executed.

Parameters:

task - The task to execute.

compute

protected void compute()

Specified by:

compute in class RecursiveAction