jadex.commons.future

Class FutureBarrier<E>

java.lang.Object

jadex.commons.future.FutureBarrier<E>

public class FutureBarrier<E>
extends java.lang.Object

A future barrier allows for waiting for a variable number of futures. Calling waitFor will wait until all futures are done.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<IFuture<E>>	futures The list of futures.

Constructor Summary

Constructors

Constructor and Description
FutureBarrier()

Method Summary

Modifier and Type	Method and Description
void	addFuture(IFuture<E> fut) Add a future to the barrier.
IFuture<java.lang.Void>	waitFor() Wait for all added futures being finished.
IFuture<java.lang.Void>	waitForIgnoreFailures(ICommand<java.lang.Exception> failurehandler) Wait for all added futures being finished.
IFuture<java.util.Collection<E>>	waitForResults() Wait for all added futures being finished and collect the results.
IFuture<java.util.Collection<E>>	waitForResultsIgnoreFailures(ICommand<java.lang.Exception> failurehandler) Wait for all added futures being finished and collect the results.

Methods inherited from class java.lang.Object

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

Field Detail

futures

protected java.util.List<IFuture<E>> futures

The list of futures.

Constructor Detail

FutureBarrier

public FutureBarrier()

Method Detail

addFuture

public void addFuture(IFuture<E> fut)

Add a future to the barrier.

Parameters:

fut - The future.

waitFor

public IFuture<java.lang.Void> waitFor()

Wait for all added futures being finished.

waitForIgnoreFailures

public IFuture<java.lang.Void> waitForIgnoreFailures(ICommand<java.lang.Exception> failurehandler)

Wait for all added futures being finished. Ignore failures and call optional failure handler, if any.

waitForResults

public IFuture<java.util.Collection<E>> waitForResults()

Wait for all added futures being finished and collect the results.

waitForResultsIgnoreFailures

public IFuture<java.util.Collection<E>> waitForResultsIgnoreFailures(ICommand<java.lang.Exception> failurehandler)

Wait for all added futures being finished and collect the results. Ignore failures and call optional failure handler, if any.