org.trancecode.concurrent

Class TcFutures

java.lang.Object

org.trancecode.concurrent.TcFutures

public final class TcFutures
extends Object

Utility methods related to Future.

Author:

Herve Quiroz

Method Summary

Methods

Modifier and Type	Method and Description
static <T> void	cancel(Iterable<Future<T>> tasks)
static <T> Iterable<Future<T>>	cancelled(Iterable<Future<T>> tasks)
static <T> Iterable<Future<T>>	done(Iterable<Future<T>> tasks)
static <T> Iterable<T>	get(Iterable<Future<T>> futures)
static <T> Iterable<T>	get(Iterable<Future<T>> futures, boolean cancelOnError)
static <T> Iterable<Future<T>>	notDone(Iterable<Future<T>> tasks)
static <T> Iterable<Future<T>>	submit(ExecutorService executor, Iterable<Callable<T>> tasks)
static <T> Iterable<Future<T>>	submit(TaskExecutor executor, Iterable<Callable<T>> tasks)

Methods inherited from class java.lang.Object

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

Method Detail

cancelled

public static <T> Iterable<Future<T>> cancelled(Iterable<Future<T>> tasks)

done

public static <T> Iterable<Future<T>> done(Iterable<Future<T>> tasks)

notDone

public static <T> Iterable<Future<T>> notDone(Iterable<Future<T>> tasks)

cancel

public static <T> void cancel(Iterable<Future<T>> tasks)

submit

public static <T> Iterable<Future<T>> submit(ExecutorService executor,
                             Iterable<Callable<T>> tasks)

submit

public static <T> Iterable<Future<T>> submit(TaskExecutor executor,
                             Iterable<Callable<T>> tasks)

get

public static <T> Iterable<T> get(Iterable<Future<T>> futures)
                       throws ExecutionException,
                              InterruptedException

Throws:

ExecutionException

InterruptedException

get

public static <T> Iterable<T> get(Iterable<Future<T>> futures,
                  boolean cancelOnError)
                       throws ExecutionException,
                              InterruptedException

Throws:

ExecutionException

InterruptedException