edu.illinois.cs.cogcomp.core.utilities

Class Parallel

java.lang.Object

edu.illinois.cs.cogcomp.core.utilities.Parallel

public class Parallel
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Parallel.Method<T>

Constructor Summary

Constructors

Constructor and Description
Parallel()

Method Summary

Modifier and Type	Method and Description
static <T> void	forLoop(int nThreads, List<T> list, Parallel.Method<T> function, long timeout, TimeUnit unit) Run function on each item of list in parallel, using nThreads threads.
static <T,S> List<S>	map(int nThreads, List<T> list, ITransformer<T,S> function, long timeout, TimeUnit unit) Run function on each item of list in parallel, using nThreads threads.

Methods inherited from class java.lang.Object

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

Constructor Detail

Parallel

public Parallel()

Method Detail

map

public static <T,S> List<S> map(int nThreads,
                                List<T> list,
                                ITransformer<T,S> function,
                                long timeout,
                                TimeUnit unit)
                         throws InterruptedException,
                                ExecutionException

Run function on each item of list in parallel, using nThreads threads. The output is a list that has the same size as list, where each element has been transformed according to the input function.

Parameters:

nThreads - Number of threads to use

list - The input list

function - A function to apply to each element of the list

timeout - Timeout

unit - Units for the timeout

Returns:

A list, where each element of the input list has been mapped according to the transformer

Throws:

InterruptedException

ExecutionException

forLoop

public static <T> void forLoop(int nThreads,
                               List<T> list,
                               Parallel.Method<T> function,
                               long timeout,
                               TimeUnit unit)
                        throws InterruptedException

Run function on each item of list in parallel, using nThreads threads.

Parameters:

nThreads - Number of threads to use

list - The input list

function - A function to apply to each element of the list

timeout - Timeout

unit - Units for the timeout

Throws:

InterruptedException