org.lenskit.util.parallel

Class TaskGroup

java.lang.Object

java.util.concurrent.ForkJoinTask<java.lang.Void>

java.util.concurrent.RecursiveAction

org.lenskit.util.parallel.TaskGroup

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<java.lang.Void>

public class TaskGroup
extends java.util.concurrent.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(java.util.concurrent.ForkJoinTask<?> task) Add a task to be executed.
void	compute()
boolean	getContinueAfterError()
boolean	isParallel() Query whether the subtasks will be run in parallel.
void	setContinueAterError(boolean c)

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.

setContinueAterError

public void setContinueAterError(boolean c)

getContinueAfterError

public boolean getContinueAfterError()

addTask

public void addTask(java.util.concurrent.ForkJoinTask<?> task)

Add a task to be executed.

Parameters:

task - The task to execute.

compute

public void compute()

Specified by:

compute in class java.util.concurrent.RecursiveAction