Module datarush.commons

Package com.pervasive.datarush.cal

Class ExecutionUtil

java.lang.Object

com.pervasive.datarush.cal.ExecutionUtil

public final class ExecutionUtil
extends Object

Miscellaneous utilities related to DistributedExecutorService and its subordinate classes.

Method Summary

Modifier and Type	Method	Description
static boolean	cancel(List<? extends Future<?>> futures, boolean mayInterruptIfRunning)	Cancels all of the provided futures
static <T> List<T>	flatten(List<List<T>> lists)	Flattens a list of lists into a single list.
static <T> List<T>	getResults(List<? extends Future<T>> futures)	Invokes Future.get() on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.
static <T> List<T>	getResults(List<? extends Future<T>> futures, long timeout, TimeUnit timeunit)	Invokes Future.get() or Future.get(long, TimeUnit) on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.
static <S> List<S>	getStatus(List<? extends MonitoredFuture<S>> futures)	Invokes MonitoredFuture.getStatus() on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.
static boolean	isCancelled(List<? extends Future<?>> futures)	Returns true if all of the futures are cancelled, false otherwise.
static boolean	isDone(List<? extends Future<?>> futures)	Returns true if all of the futures are done, false otherwise.

Methods inherited from class java.lang.Object

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

Method Detail

flatten

public static <T> List<T> flatten(List<List<T>> lists)

Flattens a list of lists into a single list.

Type Parameters:

T - the element type of the lists

Parameters:

lists - the list of lists

Returns:

a single list

getResults

public static <T> List<T> getResults(List<? extends Future<T>> futures)
                              throws DistributedExecutionException,
                                     InterruptedException

Invokes Future.get() on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.

Type Parameters:

T - the result type

Parameters:

futures - the list of futures

Returns:

a list of results

Throws:

DistributedExecutionException - containing all of the errors. Any BatchExecutionException's will be flattened.

InterruptedException - if interrupted while waiting

CancellationException - if any were canceled

isCancelled

public static boolean isCancelled(List<? extends Future<?>> futures)

Returns true if all of the futures are cancelled, false otherwise.

Parameters:

futures - the futures

Returns:

whether all were cancelled

isDone

public static boolean isDone(List<? extends Future<?>> futures)

Returns true if all of the futures are done, false otherwise.

Parameters:

futures - the futures

Returns:

whether all are done

cancel

public static boolean cancel(List<? extends Future<?>> futures,
                             boolean mayInterruptIfRunning)

Cancels all of the provided futures

Parameters:

futures - the futures

mayInterruptIfRunning - whether we can interrupt a future that has already started running

Returns:

true iff all were cancelled

getResults

public static <T> List<T> getResults(List<? extends Future<T>> futures,
                                     long timeout,
                                     TimeUnit timeunit)
                              throws DistributedExecutionException,
                                     TimeoutException,
                                     InterruptedException,
                                     CancellationException

Invokes Future.get() or Future.get(long, TimeUnit) on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.

Type Parameters:

T - the result type

Parameters:

futures - the list of futures

timeout - the timeout; ignored if timeunit is null

timeunit - the timeunit or null for no timeout

Returns:

a list of results

Throws:

DistributedExecutionException - containing all of the errors. Any BatchExecutionException's will be flattened.

TimeoutException - if a timeout occurs. Will only be thrown if timeunit is non-null.

InterruptedException - if interrupted while waiting

CancellationException - if any were canceled

getStatus

public static <S> List<S> getStatus(List<? extends MonitoredFuture<S>> futures)
                             throws DistributedExecutionException,
                                    InterruptedException

Invokes MonitoredFuture.getStatus() on each element in the provided list of futures, returning a list of results or throwing an exception if there are any failures.

Type Parameters:

S - the result type

Parameters:

futures - the list of futures

Returns:

a list of statuses

Throws:

DistributedExecutionException - containing all of the errors. Any BatchExecutionException's will be flattened.

InterruptedException - if interrupted while waiting

CancellationException - if any were canceled