com.pervasive.datarush.cal.dr

Class ParallelStartupHelper

java.lang.Object

com.pervasive.datarush.cal.dr.ParallelStartupHelper

public final class ParallelStartupHelper
extends Object

Runs startup actions in-parallel

Constructor Summary

Constructors

Constructor and Description
ParallelStartupHelper(int maxThreads) Create a startup helper

Method Summary

Methods

Modifier and Type	Method and Description
static <T> List<T>	await(List<Future<T>> futures)
<T> List<T>	run(List<Callable<T>> actions) Runs the given actions in-parallel

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelStartupHelper

public ParallelStartupHelper(int maxThreads)

Create a startup helper

Parameters:

maxThreads - the max parallelization to use

Method Detail

run

public <T> List<T> run(List<Callable<T>> actions)

Runs the given actions in-parallel

Parameters:

actions - the actions. should only throw RuntimeExceptions or else we'll wrap

Returns:

a list of results

Throws:

RuntimeException - if an error occurred

CancellationException - if cancelled during

await

public static <T> List<T> await(List<Future<T>> futures)