water

Class Futures

java.lang.Object

water.Futures

public class Futures
extends java.lang.Object

A collection of Futures that can be extended, or blocked on the whole collection. Undefined if you try to add Futures while blocking.

Used as a service to sub-tasks, collect pending-but-not-yet-done future tasks that need to complete prior to *this* task completing... or if the caller of this task is knowledgeable, pass these pending tasks along to him to block on before he completes.

Highly efficient under a high load of short-completion-time Futures. Safe to call with e.g. millions of Futures per second, as long as they all complete in roughly the same rate.

Constructor Summary

Constructors

Constructor and Description
Futures()

Method Summary

Modifier and Type	Method and Description
Futures	add(java.util.concurrent.Future f) Some Future task which needs to complete before this Futures completes
void	add(Futures fs) Merge pending-task lists (often as part of doing a 'reduce' step)
void	blockForPending() Block until all pending futures have completed or canceled.

Methods inherited from class java.lang.Object

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

Constructor Detail

Futures

public Futures()

Method Detail

add

public Futures add(java.util.concurrent.Future f)

Some Future task which needs to complete before this Futures completes

add

public void add(Futures fs)

Merge pending-task lists (often as part of doing a 'reduce' step)

blockForPending

public final void blockForPending()

Block until all pending futures have completed or canceled.