Package jadex.future

Class TerminableDelegationFutureHandler<E>

java.lang.Object

jadex.future.TerminableDelegationFutureHandler<E>

public class TerminableDelegationFutureHandler<E>
extends Object

Handler for common code of (non) intermediate terminable delegation future. Workaround for missing multiple inheritance.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	pullcnt	The number of intermediate pulls to be performed, when the source is connected.
protected Exception	reason	Exception used for termination.
protected ITerminableFuture<E>	src	The termination source.
protected List<Object>	storedcmds	The list of stored backward commands, to be sent when src is connected.
protected boolean	terminate	Flag if source has to be terminated.
protected boolean	terminated	Flag if source has been terminated.

Constructor Summary

Constructors

Constructor	Description
TerminableDelegationFutureHandler()	Create a new future.

Method Summary

Modifier and Type	Method	Description
void	pullIntermediateResult()	Pull an intermediate result.
void	sendBackwardCommand(Object info)	Send a backward command in direction of the source.
void	setTerminationSource(ITerminableFuture<E> 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 java.lang.Object

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

Field Details

src

protected ITerminableFuture<E> src

The termination source.

terminate

protected boolean terminate

Flag if source has to be terminated.

terminated

protected boolean terminated

Flag if source has been terminated.

reason

protected Exception reason

Exception used for termination.

storedcmds

protected List<Object> storedcmds

The list of stored backward commands, to be sent when src is connected.

pullcnt

protected int pullcnt

The number of intermediate pulls to be performed, when the source is connected.

Constructor Details

TerminableDelegationFutureHandler

public TerminableDelegationFutureHandler()

Create a new future.

Method Details

setTerminationSource

public void setTerminationSource(ITerminableFuture<E> src)

Set the termination source.

terminate

public void terminate()

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

terminate

public void terminate(Exception reason)

Terminate the future and supply a custom reason.

pullIntermediateResult

public void pullIntermediateResult()

Pull an intermediate result.

sendBackwardCommand

public void sendBackwardCommand(Object info)

Send a backward command in direction of the source.

Parameters:

info - The command info.