Package jadex.future
package jadex.future
-
ClassDescriptionThe CallMultiplexer unifies multiple executions of "similar" commands to a single execution.The call sequentializer realizes a 'critical region' for async calls, i.e.A listener that collects intermediate results and calls resultAvailable() on setFinished().Collection result listener collects a number of results and return a collection.Counter result listener for counting a specified number of resultAvailable calls.The default listener for logging exceptions as warning.Default tuple2 result listener that implements the (obsolete) methods - resultAvailable - intermediateResultAvailable - finished - resultCountAvailableResult listener that delegates calls to a future.A result listener that filters duplicates.Exception indicating that the result of a future was set twice.Result listener that delegates calls to a future.The exception listener is used for intercepting exceptions while ignoring results.Future<E>Future that includes mechanisms for callback notification.A future barrier allows for waiting for a variable number of futures.Allows monitoring a number of tasks (futures) and get a notification when set to finished (no more new tasks) and all tasks have been processed (futures notified).Helper class to access future notification stackException that signals that a future has been terminated.Send a backward command in direction of the source, i.e.Send a command from source to listeners (same flow as results).The available commands.IFuture<E>Interface for futures.Interface that extends both, result listener and future command.Future that support intermediate results.Interface that extends both, result listener and future command.Result listener with additional notifications in case of intermediate results.The default listener for just printing out result information.Intermediate version of the delegation result listener.Empty implementation of the intermediate result listener.Exception delegation listener for intermediate futures.Default implementation of an intermediate future.Helper class for iterating over the results of an intermediate future.Callback interface for methods that should operate decoupled from caller thread.Intermediate future with pull mechanism.Intermediate future with pull mechanism.Remoteable version of the result listener interface.Callback interface for methods that should operate decoupled from caller thread.The subscription intermediate future does not save the results but instead uses a fire and forget semantics.Interface for suspendable entities.Interface for a future that can be terminated from caller side.Interface for an intermediate future that can be terminated from caller side.A command to customize termination of a terminable future.ITuple2Future<E,
F> A tuple future has a defined number of results of possibly different types.Listener for tuple2 futures.Delegation future for pull future.Intermediate future with pull mechanism.Delegation future for pull future.Intermediate future that can be terminated from caller side.Result listener that delegates calls to a future and can be called from remote.Implementation of the subscription intermediate future.A terminable delegation future can be used when a termination future should be delegated.Handler for common code of (non) intermediate terminable delegation future.Future that can be terminated from caller side.A terminable intermediate delegation future can be used when a termination intermediate future should be delegated.Intermediate future that can be terminated from caller side.Base implementation of termination command to be used for sub-classing.Helps to transfer registered thread local values between different threads.Suspendable for threads.Tuple2Future<E,F> Implementation of tuple2 future.Used by tuple futures as internal result wrappers.Listener that forwards results but not finished events.