jadex.commons.future

Class CallSequentializer<T>

java.lang.Object

jadex.commons.future.CallSequentializer<T>

public class CallSequentializer<T>
extends java.lang.Object

The call sequentializer realizes a 'critical region' for async calls, i.e. it sequentializes access to a method. - It uses a command to call the method - It guarantees first come first served method invocation.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<Tuple3<java.lang.String,java.lang.Object[],Future<T>>>	calls The list of waiting calls with future and args.
protected java.util.Map<java.lang.String,IResultCommand<IFuture<T>,java.lang.Object[]>>	commands The command to execute a call.
protected IFuture<T>	currentcall The current call.

Constructor Summary

Constructors

Constructor and Description
CallSequentializer() Create a new sequentializer.
CallSequentializer(IResultCommand<IFuture<T>,java.lang.Object[]> call) Create a new sequentializer.

Method Summary

Modifier and Type	Method and Description
void	addCommand(java.lang.String method, IResultCommand<IFuture<T>,java.lang.Object[]> call) Add a command by (method) name.
IFuture<T>	call(java.lang.Object[] args) Handles a call.
IFuture<T>	call(java.lang.String method, java.lang.Object[] args)
protected void	proceed() Called when a command returns.

Methods inherited from class java.lang.Object

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

Field Detail

currentcall

protected IFuture<T> currentcall

The current call.

calls

protected java.util.List<Tuple3<java.lang.String,java.lang.Object[],Future<T>>> calls

The list of waiting calls with future and args.

commands

protected java.util.Map<java.lang.String,IResultCommand<IFuture<T>,java.lang.Object[]>> commands

The command to execute a call.

Constructor Detail

CallSequentializer

public CallSequentializer()

Create a new sequentializer.

CallSequentializer

public CallSequentializer(IResultCommand<IFuture<T>,java.lang.Object[]> call)

Create a new sequentializer.

Parameters:

call - The command to execute on an invocation.

Method Detail

addCommand

public void addCommand(java.lang.String method,
                       IResultCommand<IFuture<T>,java.lang.Object[]> call)

Add a command by (method) name.

Parameters:

method - The method name (or just a name).

call

public IFuture<T> call(java.lang.Object[] args)

Handles a call. If no other call is in it will execute the command. If at least one call is in it will be added to the calls list. When a call finishes the next is fetched from the list until empty.

Parameters:

args - The call args.

Returns:

The call result future.

call

public IFuture<T> call(java.lang.String method,
                       java.lang.Object[] args)

proceed

protected void proceed()

Called when a command returns.