jadex.commons.future

Class TerminableIntermediateDelegationFuture<E>

java.lang.Object

jadex.commons.future.Future<Collection<E>>

jadex.commons.future.IntermediateFuture<E>

jadex.commons.future.TerminableIntermediateDelegationFuture<E>

All Implemented Interfaces:

IFuture<Collection<E>>, IIntermediateFuture<E>, ITerminableFuture<Collection<E>>, ITerminableIntermediateFuture<E>

Direct Known Subclasses:

SubscriptionIntermediateDelegationFuture

public class TerminableIntermediateDelegationFuture<E>
extends IntermediateFuture<E>
implements ITerminableIntermediateFuture<E>

A terminable intermediate delegation future can be used when a termination intermediate future should be delegated. This kind of future needs to be connected to the termination source (another delegation or a real future). Termination calls are forwarded to the termination source. The future remembers when terminate() was called in unconnected state and forwards the request as soon as the connection is established.

Field Summary

Fields inherited from class jadex.commons.future.Future

DEBUG, EMPTY, NO_STACK_COMPACTION, STACK

Fields inherited from interface jadex.commons.future.IIntermediateFuture

DONE

Constructor Summary

Constructors

Constructor and Description
TerminableIntermediateDelegationFuture() Create a new future.
TerminableIntermediateDelegationFuture(ITerminableIntermediateFuture<?> src) Create a new future.

Method Summary

Methods

Modifier and Type	Method and Description
void	setTerminationSource(ITerminableIntermediateFuture<?> src) Set the termination source.
void	terminate() Terminate the future.
void	terminate(Exception reason) Terminate the future and supply a custom reason.

Methods inherited from class jadex.commons.future.IntermediateFuture

addIntermediateResult, addIntermediateResultIfUndone, addResultListener, getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult, setFinished, setFinishedIfUndone, setResult, setResultIfUndone

Methods inherited from class jadex.commons.future.Future

get, get, getEmptyFuture, getException, isDone, setException, setExceptionIfUndone

Methods inherited from class java.lang.Object

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

Methods inherited from interface jadex.commons.future.IIntermediateFuture

getIntermediateResults, getNextIntermediateResult, hasNextIntermediateResult

Methods inherited from interface jadex.commons.future.IFuture

addResultListener, get, get, getException, isDone

Constructor Detail

TerminableIntermediateDelegationFuture

public TerminableIntermediateDelegationFuture()

Create a new future.

TerminableIntermediateDelegationFuture

public TerminableIntermediateDelegationFuture(ITerminableIntermediateFuture<?> src)

Create a new future.

Method Detail

setTerminationSource

public void setTerminationSource(ITerminableIntermediateFuture<?> src)

Set the termination source.

terminate

public void terminate()

Terminate the future. The exception will be set to FutureTerminatedException.

Specified by:

terminate in interface ITerminableFuture<Collection<E>>

terminate

public void terminate(Exception reason)

Terminate the future and supply a custom reason.

Specified by:

terminate in interface ITerminableFuture<Collection<E>>