org.grouplens.lenskit.util.parallel

Class TaskGraphExecutor

java.lang.Object

org.grouplens.lenskit.util.parallel.TaskGraphExecutor

public abstract class TaskGraphExecutor
extends Object

Run tasks with (pre-computed) dependencies. Task graphs are represented by Grapht DAG nodes.

Constructor Summary

Constructors

Constructor and Description
TaskGraphExecutor()

Method Summary

Modifier and Type	Method and Description
static TaskGraphExecutor	create() Create a task graph runner that uses Runtime.availableProcessors() threads.
static TaskGraphExecutor	create(int nthreads) Create a task graph runner that uses the specified number of threads.
static TaskGraphExecutor	create(int nthreads, String name) Create a task graph runner that uses the specified number of threads.
abstract <T extends Callable<?>,E> void	execute(DAGNode<T,E> graph) Execute a task graph.
static TaskGraphExecutor	singleThreaded() Return a single-threaded task graph runner.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskGraphExecutor

public TaskGraphExecutor()

Method Detail

create

public static TaskGraphExecutor create(int nthreads,
                                       String name)

Create a task graph runner that uses the specified number of threads.

Parameters:

nthreads - The number of threads (at least 1).

name - The name of the task executor (used to name threads)

Returns:

A new task graph runner.

create

public static TaskGraphExecutor create(int nthreads)

Create a task graph runner that uses the specified number of threads.

Parameters:

nthreads - The number of threads (at least 1).

Returns:

A new task graph runner.

create

public static TaskGraphExecutor create()

Create a task graph runner that uses Runtime.availableProcessors() threads.

Returns:

A new task graph runner.

singleThreaded

public static TaskGraphExecutor singleThreaded()

Return a single-threaded task graph runner.

Returns:

The runner.

execute

public abstract <T extends Callable<?>,E> void execute(DAGNode<T,E> graph)
                                                throws ExecutionException,
                                                       InterruptedException

Execute a task graph.

Type Parameters:

T - The task type.

E - The edge type.

Parameters:

graph - The graph to execute.

Throws:

ExecutionException - If there is an error executing one or more tasks.

InterruptedException - If task execution is interrupted.