water

Class Futures

java.lang.Object

water.Futures

public class Futures
extends java.lang.Object

A collection of Futures. We can add more, or block 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.

Constructor Summary

Constructors

Constructor and Description
Futures()

Method Summary

Methods

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

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 task completes

add

public void add(Futures fs)

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

blockForPending

public final void blockForPending()

Block until all pending futures have completed