0.10.8-alpha
ca.uqac.lif.cep.CompoundFuture< T, U > Class Template Referenceabstract

A Future object whose termination and output value depends on the termination and output values of multiple other Future objects. More...

Public Member Functions

 CompoundFuture (Future< U >[] futures)
 
boolean cancel (boolean may_interrupt_if_running)
 
boolean isCancelled ()
 
boolean isDone ()
 
get () throws InterruptedException, ExecutionException
 
get (long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
 
abstract T compute (U[] values)
 Computes the return value of this Future, based on the return values of each sub-future. More...
 

Protected Attributes

Future< U > [] m_futures
 The array of "sub-futures" this Future depends on. More...
 

Detailed Description

A Future object whose termination and output value depends on the termination and output values of multiple other Future objects.

Author
Sylvain Hallé
Since
0.9
Parameters
<T>The output type of this future
<U>The output type of the multiple "sub-futures" this Future depends on

Definition at line 35 of file CompoundFuture.java.

Constructor & Destructor Documentation

◆ CompoundFuture()

ca.uqac.lif.cep.CompoundFuture< T, U >.CompoundFuture ( Future< U > []  futures)

Definition at line 42 of file CompoundFuture.java.

Member Function Documentation

◆ cancel()

boolean ca.uqac.lif.cep.CompoundFuture< T, U >.cancel ( boolean  may_interrupt_if_running)

Definition at line 49 of file CompoundFuture.java.

◆ compute()

abstract T ca.uqac.lif.cep.CompoundFuture< T, U >.compute ( U []  values)
abstract

Computes the return value of this Future, based on the return values of each sub-future.

Parameters
valuesThe values returned by each sub-future
Returns
The output value to compute

◆ get() [1/2]

T ca.uqac.lif.cep.CompoundFuture< T, U >.get ( ) throws InterruptedException, ExecutionException

Definition at line 86 of file CompoundFuture.java.

◆ get() [2/2]

T ca.uqac.lif.cep.CompoundFuture< T, U >.get ( long  timeout,
TimeUnit  unit 
) throws InterruptedException, ExecutionException, TimeoutException

Definition at line 94 of file CompoundFuture.java.

◆ isCancelled()

boolean ca.uqac.lif.cep.CompoundFuture< T, U >.isCancelled ( )

Definition at line 60 of file CompoundFuture.java.

◆ isDone()

boolean ca.uqac.lif.cep.CompoundFuture< T, U >.isDone ( )

Definition at line 73 of file CompoundFuture.java.

Member Data Documentation

◆ m_futures

Future<U> [] ca.uqac.lif.cep.CompoundFuture< T, U >.m_futures
protected

The array of "sub-futures" this Future depends on.

Definition at line 40 of file CompoundFuture.java.


The documentation for this class was generated from the following file: