Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- abortGet(ISuspendable) - Method in class jadex.future.Future
-
Abort a blocking get call.
- addBackwardCommand(IFilter<Object>, ICommand<Object>) - Method in class jadex.future.TerminableFuture
-
Add a backward command with a filter.
- addBackwardCommand(IFilter<Object>, ICommand<Object>) - Method in class jadex.future.TerminableIntermediateFuture
-
Add a backward command with a filter.
- addCommand(String, IResultCommand<IFuture<T>, Object[]>) - Method in class jadex.future.CallSequentializer
-
Add a command by (method) name.
- addFuture(IFuture<E>) - Method in class jadex.future.FutureBarrier
-
Add a future to the barrier.
- addIntermediateResult(E) - Method in class jadex.future.IntermediateFuture
-
Add an intermediate result.
- addIntermediateResultIfUndone(E) - Method in class jadex.future.IntermediateFuture
-
Set the result.
- addQuietListener(IResultListener<Collection<E>>) - Method in interface jadex.future.ISubscriptionIntermediateFuture
-
Add a listener which does not consume the initial results.
- addQuietListener(IResultListener<Collection<E>>) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Add a listener which is only informed about new results, i.e.
- addQuietListener(IResultListener<Collection<E>>) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Add a listener which is only informed about new results, i.e.
- addResultListener(IResultListener<E>) - Method in class jadex.future.Future
-
Add a result listener.
- addResultListener(IResultListener<E>) - Method in interface jadex.future.IFuture
-
Add a result listener.
- addResultListener(IResultListener<Collection<E>>) - Method in class jadex.future.IntermediateFuture
-
Add a result listener.
- addResultListener(IResultListener<Collection<E>>) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Add a result listener.
- addResultListener(IResultListener<Collection<E>>) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Add a result listener.
- addTask(Future) - Method in class jadex.future.FutureFinishChecker
-
Add a task.
- addThreadLocal(ThreadLocal<?>) - Static method in class jadex.future.ThreadLocalTransferHelper
-
Add a thread local that will be automatically copied on thread resumption.
- afterSwitch() - Method in class jadex.future.ThreadLocalTransferHelper
-
Must be called after a thread switch occurs to restore the thread local values.
- asStream() - Method in interface jadex.future.IIntermediateFuture
-
Return a stream of the results of this future.
- asStream() - Method in class jadex.future.IntermediateFuture
-
Return a stream of the results of this future.
- asStream(long, boolean) - Method in interface jadex.future.IIntermediateFuture
-
Return a stream of the results of this future.
- asStream(long, boolean) - Method in class jadex.future.IntermediateFuture
-
Return a stream of the results of this future.
B
- bcommands - Variable in class jadex.future.TerminableFuture
-
The list of backward commands.
- bcommands - Variable in class jadex.future.TerminableIntermediateFuture
-
The list of backward commands.
- beforeSwitch() - Method in class jadex.future.ThreadLocalTransferHelper
-
Must be called before a thread switch occurs to save the thread local values.
C
- call(Object[]) - Method in class jadex.future.CallSequentializer
-
Handles a call.
- call(String, Object[]) - Method in class jadex.future.CallSequentializer
- CALLER_QUEUED - Static variable in class jadex.future.Future
-
A caller is queued for suspension.
- CALLER_RESUMED - Static variable in class jadex.future.Future
-
A caller is resumed.
- CALLER_SUSPENDED - Static variable in class jadex.future.Future
-
A caller is suspended.
- callers - Variable in class jadex.future.Future
-
The blocked callers (caller->state).
- CallMultiplexer - Class in jadex.future
-
The CallMultiplexer unifies multiple executions of "similar" commands to a single execution.
- CallMultiplexer() - Constructor for class jadex.future.CallMultiplexer
-
Instantiates a call multiplexer.
- calls - Variable in class jadex.future.CallSequentializer
-
The list of waiting calls with future and args.
- CallSequentializer<T> - Class in jadex.future
-
The call sequentializer realizes a 'critical region' for async calls, i.e.
- CallSequentializer() - Constructor for class jadex.future.CallSequentializer
-
Create a new sequentializer.
- CallSequentializer(IResultCommand<IFuture<T>, Object[]>) - Constructor for class jadex.future.CallSequentializer
-
Create a new sequentializer.
- capacity - Variable in class jadex.future.FutureBlockingQueue
- catchEx(Future<T>) - Method in class jadex.future.Future
-
Called on exception.
- catchEx(Future<T>) - Method in interface jadex.future.IFuture
-
Called on exception.
- catchEx(Future<T>) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Called on exception.
- catchEx(Future<T>) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Called on exception.
- catchEx(Consumer<? super Exception>) - Method in class jadex.future.Future
-
Called on exception.
- catchEx(Consumer<? super Exception>) - Method in interface jadex.future.IFuture
-
Called on exception.
- catchEx(Consumer<? super Exception>, Class<?>) - Method in class jadex.future.Future
-
Called on exception.
- catchEx(Consumer<? super Exception>, Class<?>) - Method in interface jadex.future.IFuture
-
Called on exception.
- catchEx(Consumer<? super Exception>, Class<?>) - Method in class jadex.future.IntermediateFuture
- catchEx(Consumer<? super Exception>, Class<?>) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Called on exception.
- catchEx(Consumer<? super Exception>, Class<?>) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Called on exception.
- check() - Method in class jadex.future.FutureFinishChecker
-
Check if completed.
- checkNotify(E, Exception) - Method in class jadex.future.CollectionResultListener
-
Check if the delegate should be notified.
- checkTermination(Exception) - Method in interface jadex.future.ITerminationCommand
-
Check if termination is allowed.
- checkTermination(Exception) - Method in class jadex.future.TerminationCommand
-
Check if termination is allowed.
- clistener - Variable in class jadex.future.IntermediateExceptionDelegationResultListener
-
Custom functional result count listener.
- cnt - Variable in class jadex.future.CounterResultListener
-
The number of received callbacks.
- CollectingIntermediateResultListener<E> - Class in jadex.future
-
A listener that collects intermediate results and calls resultAvailable() on setFinished().
- CollectingIntermediateResultListener() - Constructor for class jadex.future.CollectingIntermediateResultListener
- CollectionResultListener<E> - Class in jadex.future
-
Collection result listener collects a number of results and return a collection.
- CollectionResultListener(boolean, IResultListener<Collection<E>>) - Constructor for class jadex.future.CollectionResultListener
-
Create a new collection listener.
- CollectionResultListener(int, boolean, IResultListener<Collection<E>>) - Constructor for class jadex.future.CollectionResultListener
-
Create a new collection listener.
- CollectionResultListener(int, IResultListener<Collection<E>>) - Constructor for class jadex.future.CollectionResultListener
-
Create a new collection listener that stops on failures.
- CollectionResultListener(IResultListener<Collection<E>>) - Constructor for class jadex.future.CollectionResultListener
-
Create a new collection listener that stops on failures.
- commandAvailable(Object) - Method in class jadex.future.DefaultResultListener
-
Called when a command is available.
- commandAvailable(Object) - Method in class jadex.future.DelegationResultListener
-
Called when a command is available.
- commandAvailable(Object) - Method in class jadex.future.ExceptionDelegationResultListener
-
Called when a command is available.
- commandAvailable(Object) - Method in interface jadex.future.IFutureCommandResultListener
-
Called when a command is available.
- commandAvailable(Object) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when a command is available.
- commandAvailable(Object) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when a command is available.
- commands - Variable in class jadex.future.CallSequentializer
-
The command to execute a call.
- consumers - Variable in class jadex.future.FutureBlockingQueue
- CounterResultListener<E> - Class in jadex.future
-
Counter result listener for counting a specified number of resultAvailable calls.
- CounterResultListener(int, boolean, IResultListener<Void>) - Constructor for class jadex.future.CounterResultListener
-
Create a new counter listener.
- CounterResultListener(int, IResultListener<Void>) - Constructor for class jadex.future.CounterResultListener
-
Create a new counter listener.
- creation - Variable in class jadex.future.Future
-
For capturing call stack of future creation.
- currentcall - Variable in class jadex.future.CallSequentializer
-
The current call.
- customIntermediateResultAvailable(E) - Method in class jadex.future.DuplicateRemovalIntermediateResultListener
-
Check results before sending them further.
- customIntermediateResultAvailable(E) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when an intermediate result is available.
- customResultAvailable(E) - Method in class jadex.future.DelegationResultListener
-
Called when the result is available.
- customResultAvailable(E) - Method in class jadex.future.ExceptionDelegationResultListener
-
Called when the result is available.
- customResultAvailable(E) - Method in class jadex.future.RemoteDelegationResultListener
-
Called when the result is available.
- customResultAvailable(Collection<E>) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when the result is available.
- customResultAvailable(Collection<E>) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when the result is available.
- customResultListener - Variable in class jadex.future.DelegationResultListener
-
Custom functional result listener
D
- DEBUG - Static variable in class jadex.future.Future
-
Debug flag.
- DefaultResultListener<E> - Class in jadex.future
-
The default listener for logging exceptions as warning.
- DefaultResultListener() - Constructor for class jadex.future.DefaultResultListener
-
Create a new listener.
- DefaultResultListener(Logger) - Constructor for class jadex.future.DefaultResultListener
-
Create a new listener.
- DefaultTuple2ResultListener<E,
F> - Class in jadex.future -
Default tuple2 result listener that implements the (obsolete) methods - resultAvailable - intermediateResultAvailable - finished - resultCountAvailable
- DefaultTuple2ResultListener() - Constructor for class jadex.future.DefaultTuple2ResultListener
- delegate - Variable in class jadex.future.CollectionResultListener
-
The delegate result listener.
- delegate - Variable in class jadex.future.CounterResultListener
-
The delegate result listener.
- delegate - Variable in class jadex.future.FutureFinishChecker
-
The delegate to be notified.
- delegate - Variable in class jadex.future.IntermediateDelegationResultListener
-
Custom functional result listener
- delegate - Variable in class jadex.future.UnlimitedIntermediateDelegationResultListener
-
The delegate future.
- delegate(Future<E>) - Method in class jadex.future.Future
-
Deprecated.Use delegateTo.
- delegate(Future<E>) - Method in interface jadex.future.IFuture
-
Deprecated.Use delegateTo.
- delegateEx(Future<T>) - Method in class jadex.future.IntermediateFuture
-
Called on exception.
- delegateFrom(IFuture<E>) - Method in class jadex.future.Future
-
Delegate the result and exception from another future.
- delegateFrom(IFuture<E>) - Method in class jadex.future.TerminableDelegationFuture
-
Delegate the result and exception from another future.
- delegateFrom(IFuture<Collection<E>>) - Method in class jadex.future.IntermediateFuture
-
Delegate the result and exception from another future.
- delegateFrom(IFuture<Collection<E>>) - Method in class jadex.future.TerminableIntermediateDelegationFuture
-
Delegate the result and exception from another future.
- delegateTo(Future<E>) - Method in class jadex.future.Future
-
Forward the result and exception to another future.
- delegateTo(Future<E>) - Method in interface jadex.future.IFuture
-
Forward the result and exception to another future.
- DelegationResultListener<E> - Class in jadex.future
-
Result listener that delegates calls to a future.
- DelegationResultListener(Future<E>) - Constructor for class jadex.future.DelegationResultListener
-
Create a new listener.
- DelegationResultListener(Future<E>, boolean) - Constructor for class jadex.future.DelegationResultListener
-
Create a new listener.
- DelegationResultListener(Future<E>, boolean, Consumer<E>) - Constructor for class jadex.future.DelegationResultListener
-
Create a new listener.
- DelegationResultListener(Future<E>, Consumer<E>) - Constructor for class jadex.future.DelegationResultListener
-
Create a new listener.
- dequeue() - Method in class jadex.future.FutureBlockingQueue
- doAddIntermediateResult(E, boolean) - Method in class jadex.future.IntermediateFuture
-
Set the result and schedule listener notifications.
- doAddResultListener(IResultListener<E>) - Method in class jadex.future.Future
-
Add a listener and check if it should be notified immediately due to the future already being finished before add.
- doCall(IResultCommand<Object, Object>) - Method in class jadex.future.CallMultiplexer
-
Calls the command.
- doCall(Object, IResultCommand<Object, Object>) - Method in class jadex.future.CallMultiplexer
-
Calls the command.
- doCall(Object, IResultCommand<Object, Object>, boolean) - Method in class jadex.future.CallMultiplexer
-
Calls the command.
- doGetNextIntermediateResult(int, long, boolean) - Method in class jadex.future.IntermediateFuture
-
Perform the get without increasing the index.
- doGetNextIntermediateResult(int, long, boolean) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Perform the get without increasing the index.
- doGetNextIntermediateResult(int, long, boolean) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Perform the get without increasing the index.
- done(Consumer<? super Exception>) - Method in interface jadex.future.IIntermediateFuture
-
Called when the future is done (finished or exception occurred).
- done(Consumer<? super Exception>) - Method in class jadex.future.IntermediateFuture
-
Called when the future is done (finished or exception occurred).
- DONE - Static variable in interface jadex.future.IFuture
-
A future representing a completed action.
- DONE - Static variable in interface jadex.future.IIntermediateFuture
-
A future representing a completed action.
- doSetException(Exception, boolean) - Method in class jadex.future.Future
-
Set the exception (internal implementation for normal and if-undone).
- doSetException(Exception, boolean) - Method in class jadex.future.IntermediateFuture
- doSetFinished(boolean) - Method in class jadex.future.IntermediateFuture
-
Declare that the future is finished.
- doSetResult(E, boolean) - Method in class jadex.future.Future
-
Set the result without notifying listeners.
- doSetResult(Collection<E>, boolean) - Method in class jadex.future.IntermediateFuture
-
Set the result.
- doStartScheduledNotifications() - Static method in class jadex.future.Future
-
Start scheduled listener notifications.
- DuplicateRemovalIntermediateResultListener<E> - Class in jadex.future
-
A result listener that filters duplicates.
- DuplicateRemovalIntermediateResultListener(IIntermediateResultListener<E>, boolean, Function<Object, byte[]>) - Constructor for class jadex.future.DuplicateRemovalIntermediateResultListener
-
Create a new listener.
- DuplicateRemovalIntermediateResultListener(IIntermediateResultListener<E>, Function<Object, byte[]>) - Constructor for class jadex.future.DuplicateRemovalIntermediateResultListener
-
Create a new listener.
- DuplicateRemovalIntermediateResultListener(IntermediateFuture<E>) - Constructor for class jadex.future.DuplicateRemovalIntermediateResultListener
-
Create a new listener.
- DuplicateRemovalIntermediateResultListener(IntermediateFuture<E>, boolean) - Constructor for class jadex.future.DuplicateRemovalIntermediateResultListener
-
Create a new listener.
- DuplicateResultException - Exception Class in jadex.future
-
Exception indicating that the result of a future was set twice.
- DuplicateResultException(int, IFuture<?>, Object, Object) - Constructor for exception class jadex.future.DuplicateResultException
-
Create a duplicate result exception.
E
- enqueue(T) - Method in class jadex.future.FutureBlockingQueue
- exception - Variable in class jadex.future.Future
-
The exception (if any).
- ExceptionDelegationResultListener<E,
T> - Class in jadex.future -
Result listener that delegates calls to a future.
- ExceptionDelegationResultListener(Future<T>) - Constructor for class jadex.future.ExceptionDelegationResultListener
-
Create a new listener.
- ExceptionDelegationResultListener(Future<T>, boolean) - Constructor for class jadex.future.ExceptionDelegationResultListener
-
Create a new listener.
- exceptionOccurred(Exception) - Method in class jadex.future.CollectingIntermediateResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.CollectionResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.CounterResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.DefaultResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.DelegationResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.ExceptionDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.IntermediateEmptyResultListener
- exceptionOccurred(Exception) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in interface jadex.future.IResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.RemoteDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurred(Exception) - Method in class jadex.future.UnlimitedIntermediateDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in class jadex.future.CollectionResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in class jadex.future.CounterResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in class jadex.future.DelegationResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in class jadex.future.ExceptionDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when an exception occurred.
- exceptionOccurredIfUndone(Exception) - Method in interface jadex.future.IUndoneResultListener
-
Called when an exception occurred.
- ExceptionResultListener<E> - Class in jadex.future
-
The exception listener is used for intercepting exceptions while ignoring results.
- ExceptionResultListener() - Constructor for class jadex.future.ExceptionResultListener
- executeNotification(IResultListener<E>, ICommand<IResultListener<E>>) - Method in class jadex.future.Future
-
Execute a notification.
F
- FALSE - Static variable in interface jadex.future.IFuture
-
A future representing a false result.
- filter - Variable in class jadex.future.DuplicateRemovalIntermediateResultListener
-
The bloom filter.
- findResult(int) - Method in class jadex.future.Tuple2Future
-
Find result in results
- finished - Variable in class jadex.future.FutureFinishChecker
-
Flag, if set to finished (no more tasks allowed and notfication when all tasks finished).
- finished() - Method in class jadex.future.CollectingIntermediateResultListener
-
Declare that the future is finished.
- finished() - Method in class jadex.future.DefaultTuple2ResultListener
-
Declare that the future is finished.
- finished() - Method in class jadex.future.FutureFinishChecker
-
Set to finished.
- finished() - Method in interface jadex.future.IIntermediateResultListener
-
Declare that the future is finished.
- finished() - Method in class jadex.future.IntermediateDefaultResultListener
-
Declare that the future is finished.
- finished() - Method in class jadex.future.IntermediateDelegationResultListener
-
Declare that the future is finished.
- finished() - Method in class jadex.future.IntermediateEmptyResultListener
- finished() - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Declare that the future is finished.
- finished() - Method in class jadex.future.UnlimitedIntermediateDelegationResultListener
-
Declare that the future is finished.
- finished(Consumer<Void>) - Method in interface jadex.future.IIntermediateFuture
-
Called when the future is finished.
- finished(Consumer<Void>) - Method in class jadex.future.IntermediateFuture
-
Called when the future is finished.
- finished(Consumer<Void>) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Called when the future is finished.
- finished(Consumer<Void>) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Called when the future is finished.
- finishedIfUndone() - Method in class jadex.future.IntermediateDelegationResultListener
-
Declare that the future is finished.
- finishedIfUndone() - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Declare that the future is finished.
- finishedIfUndone() - Method in interface jadex.future.IUndoneIntermediateResultListener
-
Declare that the future is finished.
- first - Variable in exception class jadex.future.DuplicateResultException
-
The first result.
- first - Variable in class jadex.future.Future
-
For capturing call stack of first setResult/Exception call.
- firstResultAvailable(E) - Method in interface jadex.future.ITuple2ResultListener
-
Called when the first result is available.
- flistener - Variable in class jadex.future.IntermediateExceptionDelegationResultListener
-
Custom functional finished listener
- fut - Variable in class jadex.future.IntermediateFutureIterator
-
The future.
- future - Variable in class jadex.future.DelegationResultListener
-
The future to which calls are delegated.
- future - Variable in exception class jadex.future.DuplicateResultException
-
The future.
- future - Variable in class jadex.future.ExceptionDelegationResultListener
-
The future to which calls are delegated.
- future - Variable in class jadex.future.IntermediateDelegationResultListener
-
The future to which calls are delegated.
- future - Variable in class jadex.future.IntermediateExceptionDelegationResultListener
-
The future to which calls are delegated.
- future - Variable in class jadex.future.RemoteDelegationResultListener
-
The future to which calls are delegated.
- future - Variable in class jadex.future.ThreadSuspendable
-
The future.
- Future<E> - Class in jadex.future
-
Future that includes mechanisms for callback notification.
- Future() - Constructor for class jadex.future.Future
-
Create a new future.
- Future(E) - Constructor for class jadex.future.Future
-
Create a future that is already done.
- Future(Exception) - Constructor for class jadex.future.Future
-
Create a future that is already failed.
- FutureBarrier<E> - Class in jadex.future
-
A future barrier allows for waiting for a variable number of futures.
- FutureBarrier() - Constructor for class jadex.future.FutureBarrier
- FutureBlockingQueue<T> - Class in jadex.future
- FutureBlockingQueue(int) - Constructor for class jadex.future.FutureBlockingQueue
- FutureFinishChecker - Class in jadex.future
-
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).
- FutureFinishChecker(IResultListener) - Constructor for class jadex.future.FutureFinishChecker
-
Create a new checker.
- FutureHelper - Class in jadex.future
-
Helper class to access future notification stack
- FutureHelper() - Constructor for class jadex.future.FutureHelper
- futuremap - Variable in class jadex.future.CallMultiplexer
-
Map of futures of calls that are in progress.
- futures - Variable in class jadex.future.FutureBarrier
-
The list of futures.
- FutureTerminatedException - Exception Class in jadex.future
-
Exception that signals that a future has been terminated.
- FutureTerminatedException() - Constructor for exception class jadex.future.FutureTerminatedException
-
Create an exception.
- FutureTerminatedException(String) - Constructor for exception class jadex.future.FutureTerminatedException
-
Create an exception with message.
- FutureTerminatedException(String, Throwable) - Constructor for exception class jadex.future.FutureTerminatedException
-
Create an exception with message and cause.
- FutureTerminatedException(Throwable) - Constructor for exception class jadex.future.FutureTerminatedException
-
Create an exception with cause.
G
- get() - Method in class jadex.future.Future
-
Get the result - blocking call.
- get() - Method in interface jadex.future.IFuture
-
Get the result - blocking call.
- get(boolean) - Method in class jadex.future.Future
-
Get the result - blocking call.
- get(boolean) - Method in interface jadex.future.IFuture
-
Get the result - blocking call.
- get(long) - Method in class jadex.future.Future
-
Get the result - blocking call.
- get(long) - Method in interface jadex.future.IFuture
-
Get the result - blocking call.
- get(long, boolean) - Method in class jadex.future.Future
-
Get the result - blocking call.
- get(long, boolean) - Method in interface jadex.future.IFuture
-
Get the result - blocking call.
- get(ThreadSuspendable) - Method in class jadex.future.Future
-
Deprecated.- From 3.0. Use the version without suspendable. Will NOT use the suspendable given as parameter. Get the result - blocking call.
- get(ThreadSuspendable) - Method in interface jadex.future.IFuture
-
Deprecated.- From 3.0. Use the version without suspendable. Will NOT use the suspendable given as parameter. Get the result - blocking call.
- getCnt() - Method in class jadex.future.CounterResultListener
-
Get the current number of received results.
- getCount() - Method in class jadex.future.FutureBarrier
-
Get the number of futures.
- getDefaultTimeout() - Method in class jadex.future.ThreadSuspendable
-
Get the default timeout.
- getEmptyFuture() - Static method in class jadex.future.Future
-
Get the empty future of some type.
- getException() - Method in class jadex.future.Future
-
Get the exception, if any.
- getException() - Method in interface jadex.future.IFuture
-
Get the exception, if any.
- getFirstResult() - Method in interface jadex.future.ITuple2Future
-
Get the first result.
- getFirstResult() - Method in class jadex.future.Tuple2Future
-
Get the first result.
- getFirstResult(long) - Method in interface jadex.future.ITuple2Future
-
Get the first result.
- getFirstResult(long) - Method in class jadex.future.Tuple2Future
-
Get the first result.
- getFirstResult(long, boolean) - Method in interface jadex.future.ITuple2Future
-
Get the first result.
- getFirstResult(long, boolean) - Method in class jadex.future.Tuple2Future
-
Get the first result.
- getFirstResult(ThreadSuspendable) - Method in interface jadex.future.ITuple2Future
-
Deprecated.- From 3.0. Use method without suspendable. Get the first result.
- getFirstResult(ThreadSuspendable) - Method in class jadex.future.Tuple2Future
-
Deprecated.- From 3.0. Use method without suspendable. Will NOT use the suspendable that is supplied as parameter. Get the first result.
- getFuture() - Method in exception class jadex.future.DuplicateResultException
-
Get the future.
- getFuture() - Method in interface jadex.future.ISuspendable
-
Get the future if currently suspended, null otherwise.
- getFuture() - Method in class jadex.future.ThreadSuspendable
-
Get the future if currently suspended, null otherwise.
- getFuture(Class<?>) - Static method in class jadex.future.Future
-
Get the matching future object to a future (interface) type.
- getIntermediateResults() - Method in interface jadex.future.IIntermediateFuture
-
Get the intermediate results that are currently available.
- getIntermediateResults() - Method in class jadex.future.IntermediateFuture
-
Get the intermediate results that are available.
- getIntermediateResults() - Method in interface jadex.future.ISubscriptionIntermediateFuture
-
Get the intermediate results that are available.
- getIntermediateResults() - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Get the intermediate results that are available.
- getIntermediateResults() - Method in class jadex.future.SubscriptionIntermediateFuture
-
Get the intermediate results that are available.
- getLock() - Method in interface jadex.future.ISuspendable
-
Return the lock for internal synchronization.
- getLock() - Method in class jadex.future.ThreadSuspendable
-
Return the lock for internal synchronization.
- getMax() - Method in class jadex.future.Tuple2Future
-
Get the number of results of the type of future..
- getNextIntermediateResult() - Method in interface jadex.future.IIntermediateFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNextIntermediateResult() - Method in class jadex.future.IntermediateFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNextIntermediateResult(boolean) - Method in class jadex.future.IntermediateFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNextIntermediateResult(long, boolean) - Method in interface jadex.future.IIntermediateFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNextIntermediateResult(long, boolean) - Method in class jadex.future.IntermediateFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNextIntermediateResult(long, boolean) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNextIntermediateResult(long, boolean) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Iterate over the intermediate results in a blocking fashion.
- getNotificationCommand() - Method in class jadex.future.Future
-
Get the notification command.
- getNotificationCommand() - Method in class jadex.future.IntermediateFuture
-
Get the notification command.
- getNum() - Method in class jadex.future.TupleResult
-
Get the num.
- getNumber() - Method in class jadex.future.CounterResultListener
-
Get the number of results this Listener is waiting for.
- getResult() - Method in class jadex.future.TupleResult
-
Get the result.
- getResult(int) - Method in class jadex.future.FutureBarrier
-
Get the nth result.
- getResultCount() - Method in class jadex.future.CollectionResultListener
-
Get the result count.
- getResultCount() - Method in class jadex.future.IntermediateFuture
-
Get the number of results already collected.
- getResultCount() - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Get the number of results already collected.
- getResultCount() - Method in class jadex.future.SubscriptionIntermediateFuture
-
Get the number of results already collected.
- getSecondResult() - Method in interface jadex.future.ITuple2Future
-
Get the second result.
- getSecondResult() - Method in class jadex.future.Tuple2Future
-
Get the second result.
- getSecondResult(long) - Method in interface jadex.future.ITuple2Future
-
Get the second result.
- getSecondResult(long) - Method in class jadex.future.Tuple2Future
-
Get the second result.
- getSecondResult(long, boolean) - Method in interface jadex.future.ITuple2Future
-
Get the second result.
- getSecondResult(long, boolean) - Method in class jadex.future.Tuple2Future
-
Get the second result.
- getTerminationCommand() - Method in class jadex.future.TerminableIntermediateFuture
-
Get the terminate.
- getXResult(int, long, boolean) - Method in class jadex.future.Tuple2Future
-
Get the x result.
H
- handleException(Exception) - Method in class jadex.future.IntermediateDelegationResultListener
-
Handle an exception.
- handler - Variable in class jadex.future.TerminableDelegationFuture
-
The forward/backward handling helper.
- handler - Variable in class jadex.future.TerminableIntermediateDelegationFuture
-
The forward/backward handling helper.
- hasNext() - Method in class jadex.future.IntermediateFutureIterator
-
Check for more results.
- hasNextIntermediateResult() - Method in interface jadex.future.IIntermediateFuture
-
Check if there are more results for iteration for the given caller.
- hasNextIntermediateResult() - Method in class jadex.future.IntermediateFuture
-
Check if there are more results for iteration for the given caller.
- hasNextIntermediateResult(long, boolean) - Method in interface jadex.future.IIntermediateFuture
-
Check if there are more results for iteration for the given caller.
- hasNextIntermediateResult(long, boolean) - Method in class jadex.future.IntermediateFuture
-
Check if there are more results for iteration for the given caller.
- hasNextIntermediateResult(long, boolean) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Check if there are more results for iteration for the given caller.
- hasNextIntermediateResult(long, boolean) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Check if there are more results for iteration for the given caller.
- hasResultListener() - Method in class jadex.future.Future
-
Check, if the future has at least one listener.
I
- IBackwardCommandFuture - Interface in jadex.future
-
Send a backward command in direction of the source, i.e.
- icallers - Variable in class jadex.future.IntermediateFuture
-
The blocked intermediate callers (caller->state).
- IForwardCommandFuture - Interface in jadex.future
-
Send a command from source to listeners (same flow as results).
- IForwardCommandFuture.Type - Enum Class in jadex.future
-
The available commands.
- IFuture<E> - Interface in jadex.future
-
Interface for futures.
- IFutureCommandResultListener<E> - Interface in jadex.future
-
Interface that extends both, result listener and future command.
- ignorefailures - Variable in class jadex.future.CollectionResultListener
-
Flag to indicate that failures should be ignored and only valid results returned.
- ignorefailures - Variable in class jadex.future.CounterResultListener
-
The ignore failure flag.
- IIntermediateFuture<E> - Interface in jadex.future
-
Future that support intermediate results.
- IIntermediateFutureCommandResultListener<E> - Interface in jadex.future
-
Interface that extends both, result listener and future command.
- IIntermediateResultListener<E> - Interface in jadex.future
-
Result listener with additional notifications in case of intermediate results.
- indices - Variable in class jadex.future.IntermediateFuture
-
The index of the next result for a thread.
- intermediate - Variable in class jadex.future.IntermediateFuture
-
Flag indicating that addIntermediateResult()has been called.
- IntermediateDefaultResultListener<E> - Class in jadex.future
-
The default listener for just printing out result information.
- IntermediateDefaultResultListener() - Constructor for class jadex.future.IntermediateDefaultResultListener
-
Create a new listener.
- IntermediateDefaultResultListener(Logger) - Constructor for class jadex.future.IntermediateDefaultResultListener
-
Create a new listener.
- IntermediateDelegationResultListener<E> - Class in jadex.future
-
Intermediate version of the delegation result listener.
- IntermediateDelegationResultListener(IIntermediateResultListener<E>) - Constructor for class jadex.future.IntermediateDelegationResultListener
-
Create a new listener.
- IntermediateDelegationResultListener(IIntermediateResultListener<E>, boolean) - Constructor for class jadex.future.IntermediateDelegationResultListener
-
Create a new listener.
- IntermediateDelegationResultListener(IntermediateFuture<E>) - Constructor for class jadex.future.IntermediateDelegationResultListener
-
Create a new listener.
- IntermediateDelegationResultListener(IntermediateFuture<E>, boolean) - Constructor for class jadex.future.IntermediateDelegationResultListener
-
Create a new listener.
- IntermediateEmptyResultListener<E> - Class in jadex.future
-
Empty implementation of the intermediate result listener.
- IntermediateEmptyResultListener() - Constructor for class jadex.future.IntermediateEmptyResultListener
- IntermediateExceptionDelegationResultListener<E,
T> - Class in jadex.future -
Exception delegation listener for intermediate futures.
- IntermediateExceptionDelegationResultListener(Future<T>) - Constructor for class jadex.future.IntermediateExceptionDelegationResultListener
-
Create a new listener.
- IntermediateExceptionDelegationResultListener(Future<T>, Consumer<E>, Runnable, Consumer<Integer>) - Constructor for class jadex.future.IntermediateExceptionDelegationResultListener
-
Create a new listener.
- intermediateExceptionOccurred(Exception) - Method in class jadex.future.CounterResultListener
-
Method that can be overridden to do sth.
- IntermediateFuture<E> - Class in jadex.future
-
Default implementation of an intermediate future.
- IntermediateFuture() - Constructor for class jadex.future.IntermediateFuture
-
Create a future that is already done.
- IntermediateFuture(Exception) - Constructor for class jadex.future.IntermediateFuture
-
Create a future that is already done (failed).
- IntermediateFuture(Collection<E>) - Constructor for class jadex.future.IntermediateFuture
-
Create a future that is already done.
- IntermediateFutureIterator<E> - Class in jadex.future
-
Helper class for iterating over the results of an intermediate future.
- IntermediateFutureIterator(IIntermediateFuture<E>) - Constructor for class jadex.future.IntermediateFutureIterator
-
Create an intermediate future iterator.
- intermediateResultAvailable(E) - Method in class jadex.future.CollectingIntermediateResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(E) - Method in class jadex.future.CounterResultListener
-
Method that can be overridden to do sth.
- intermediateResultAvailable(E) - Method in interface jadex.future.IIntermediateResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(E) - Method in class jadex.future.IntermediateDefaultResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(E) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(E) - Method in class jadex.future.IntermediateEmptyResultListener
- intermediateResultAvailable(E) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(E) - Method in interface jadex.future.IOnIntermediateResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(E) - Method in class jadex.future.UnlimitedIntermediateDelegationResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailable(TupleResult) - Method in class jadex.future.DefaultTuple2ResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailableIfUndone(E) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailableIfUndone(E) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when an intermediate result is available.
- intermediateResultAvailableIfUndone(E) - Method in interface jadex.future.IUndoneIntermediateResultListener
-
Called when an intermediate result is available.
- IOnIntermediateResultListener<E> - Interface in jadex.future
-
Callback interface for methods that should operate decoupled from caller thread.
- IPullIntermediateFuture<E> - Interface in jadex.future
-
Intermediate future with pull mechanism.
- IPullSubscriptionIntermediateFuture<E> - Interface in jadex.future
-
Intermediate future with pull mechanism.
- IRemoteResultListener<E> - Interface in jadex.future
-
Remoteable version of the result listener interface.
- IResultListener<E> - Interface in jadex.future
-
Callback interface for methods that should operate decoupled from caller thread.
- irlistener - Variable in class jadex.future.IntermediateExceptionDelegationResultListener
-
Custom functional result listener
- isDone() - Method in class jadex.future.Future
-
Test if done, i.e.
- isDone() - Method in interface jadex.future.IFuture
-
Test if done, i.e.
- isNotified() - Method in class jadex.future.Future
-
Was the result/exception (scheduled to be) notified to some listener/blocked caller?
- ISubscriptionIntermediateFuture<E> - Interface in jadex.future
-
The subscription intermediate future does not save the results but instead uses a fire and forget semantics.
- isUndone() - Method in class jadex.future.CollectionResultListener
-
Get the undone.
- isUndone() - Method in class jadex.future.CounterResultListener
-
Get the undone.
- isUndone() - Method in class jadex.future.DelegationResultListener
-
Get the undone.
- isUndone() - Method in class jadex.future.ExceptionDelegationResultListener
-
Get the undone.
- isUndone() - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Get the undone.
- ISuspendable - Interface in jadex.future
-
Interface for suspendable entities.
- ITerminableFuture<E> - Interface in jadex.future
-
Interface for a future that can be terminated from caller side.
- ITerminableIntermediateFuture<E> - Interface in jadex.future
-
Interface for an intermediate future that can be terminated from caller side.
- ITerminationCommand - Interface in jadex.future
-
A command to customize termination of a terminable future.
- ITuple2Future<E,
F> - Interface in jadex.future -
A tuple future has a defined number of results of possibly different types.
- ITuple2ResultListener<E,
F> - Interface in jadex.future -
Listener for tuple2 futures.
- IUndoneIntermediateResultListener<E> - Interface in jadex.future
- IUndoneResultListener<E> - Interface in jadex.future
J
- jadex.future - package jadex.future
L
- listeners - Variable in class jadex.future.Future
-
The listeners, mapped to current notification thread (if any).
- lock - Variable in class jadex.future.ThreadSuspendable
-
Use reentrant lock/condition instead of synchronized/wait/notify to avoid pinning when using virtual threads.
M
- max(Consumer<Integer>) - Method in interface jadex.future.IIntermediateFuture
-
Called when the maximum number of results is available.
- max(Consumer<Integer>) - Method in class jadex.future.IntermediateFuture
-
Called when the maximum number of results is available.
- max(Consumer<Integer>) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Called when the maximum number of results is available.
- max(Consumer<Integer>) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Called when the maximum number of results is available.
- maxresultcnt - Variable in class jadex.future.IntermediateFuture
-
The max result count (if given by the producer).
- maxResultCountAvailable(int) - Method in class jadex.future.DefaultTuple2ResultListener
-
Declare that the future result count is available.
- maxResultCountAvailable(int) - Method in interface jadex.future.IIntermediateResultListener
-
Declare that the future result count is available.
- maxResultCountAvailable(int) - Method in class jadex.future.IntermediateDefaultResultListener
- maxResultCountAvailable(int) - Method in class jadex.future.IntermediateDelegationResultListener
-
Declare that the future result count is available.
- maxResultCountAvailable(int) - Method in class jadex.future.IntermediateEmptyResultListener
- maxResultCountAvailable(int) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
- maxResultCountAvailable(int) - Method in class jadex.future.UnlimitedIntermediateDelegationResultListener
-
Declare that the future result count is available.
N
- next() - Method in class jadex.future.IntermediateFutureIterator
-
Get next result.
- next(Consumer<? super E>) - Method in interface jadex.future.IIntermediateFuture
-
Called when the next intermediate value is available.
- next(Consumer<? super E>) - Method in class jadex.future.IntermediateFuture
-
Called when the next intermediate value is available.
- NO_STACK_COMPACTION - Static variable in class jadex.future.Future
-
Disable Stack unfolding for easier debugging.
- NONE - Static variable in class jadex.future.Future
-
Constant for no timeout.
- notcommand - Variable in class jadex.future.Future
- notcommand - Variable in class jadex.future.IntermediateFuture
- NOTIFICATIONS - Static variable in class jadex.future.Future
-
Notification queues for active notification threads.
- notificount - Variable in class jadex.future.Future
-
The listeners, mapped to current notification count (if any).
- notified - Variable in class jadex.future.CollectionResultListener
-
Flag to indicate that the delegate already has been notified.
- notified - Variable in class jadex.future.CounterResultListener
-
Flag to indicate that the delegate already has been notified.
- notified - Variable in class jadex.future.Future
- notified - Variable in class jadex.future.FutureFinishChecker
-
Flag to remember that delegate was notified.
- notifyDelegate(Exception) - Method in class jadex.future.CollectionResultListener
-
Notify the delegate.
- notifyIntermediateResult(IIntermediateResultListener<E>, E) - Method in class jadex.future.IntermediateFuture
-
Notify a result listener.
- notifyIntermediateResult(IIntermediateResultListener<TupleResult>, TupleResult) - Method in class jadex.future.Tuple2Future
-
Notify a result listener.
- notifyStackedListeners() - Static method in class jadex.future.FutureHelper
-
Process all collected listener notifications for the current thread, i.e.
- NULL - Static variable in class jadex.future.CollectionResultListener
-
Null object.
- num - Variable in class jadex.future.CollectionResultListener
-
The number of sub listeners to wait for.
- num - Variable in class jadex.future.CounterResultListener
-
The number of sub listeners to wait for.
- num - Variable in class jadex.future.TupleResult
-
The number.
O
- objectToByteArray(Object) - Method in class jadex.future.DuplicateRemovalIntermediateResultListener
-
Convert a value to a byte array.
- ownresults - Variable in class jadex.future.SubscriptionIntermediateDelegationFuture
-
The local results for a single thread.
- ownresults - Variable in class jadex.future.SubscriptionIntermediateFuture
-
The local results for a single thread.
P
- printOnEx() - Method in class jadex.future.Future
-
Print an exception.
- printOnEx() - Method in interface jadex.future.IFuture
-
Print an exception.
- printStackTrace() - Method in exception class jadex.future.DuplicateResultException
-
Prints also stack trace of first exception, if available.
- proceed() - Method in class jadex.future.CallSequentializer
-
Called when a command returns.
- producers - Variable in class jadex.future.FutureBlockingQueue
- pullcmd - Variable in class jadex.future.PullIntermediateFuture
-
The pull command.
- pullcmd - Variable in class jadex.future.PullSubscriptionIntermediateFuture
-
The pull command.
- pullcnt - Variable in class jadex.future.TerminableDelegationFutureHandler
-
The number of intermediate pulls to be performed, when the source is connected.
- PullIntermediateDelegationFuture<E> - Class in jadex.future
-
Delegation future for pull future.
- PullIntermediateDelegationFuture() - Constructor for class jadex.future.PullIntermediateDelegationFuture
-
Create a new future.
- PullIntermediateDelegationFuture(IPullIntermediateFuture<E>) - Constructor for class jadex.future.PullIntermediateDelegationFuture
-
Create a new future.
- PullIntermediateFuture<E> - Class in jadex.future
-
Intermediate future with pull mechanism.
- PullIntermediateFuture() - Constructor for class jadex.future.PullIntermediateFuture
-
Create a new future.
- PullIntermediateFuture(ICommand<PullIntermediateFuture<E>>) - Constructor for class jadex.future.PullIntermediateFuture
-
Create a new future.
- PullIntermediateFuture(ICommand<PullIntermediateFuture<E>>, ITerminationCommand) - Constructor for class jadex.future.PullIntermediateFuture
-
Create a new future.
- PullIntermediateFuture(Exception) - Constructor for class jadex.future.PullIntermediateFuture
-
Create a future that is already done (failed).
- pullIntermediateResult() - Method in interface jadex.future.IPullIntermediateFuture
-
Pull an intermediate result.
- pullIntermediateResult() - Method in interface jadex.future.IPullSubscriptionIntermediateFuture
-
Pull an intermediate result.
- pullIntermediateResult() - Method in class jadex.future.PullIntermediateDelegationFuture
-
Pull an intermediate result.
- pullIntermediateResult() - Method in class jadex.future.PullIntermediateFuture
-
Pull an intermediate result.
- pullIntermediateResult() - Method in class jadex.future.PullSubscriptionIntermediateDelegationFuture
-
Pull an intermediate result.
- pullIntermediateResult() - Method in class jadex.future.PullSubscriptionIntermediateFuture
-
Pull an intermediate result.
- pullIntermediateResult() - Method in class jadex.future.TerminableDelegationFutureHandler
-
Pull an intermediate result.
- PullSubscriptionIntermediateDelegationFuture<E> - Class in jadex.future
-
Delegation future for pull future.
- PullSubscriptionIntermediateDelegationFuture() - Constructor for class jadex.future.PullSubscriptionIntermediateDelegationFuture
-
Create a new future.
- PullSubscriptionIntermediateDelegationFuture(IPullSubscriptionIntermediateFuture<E>) - Constructor for class jadex.future.PullSubscriptionIntermediateDelegationFuture
-
Create a new future.
- PullSubscriptionIntermediateFuture<E> - Class in jadex.future
-
Intermediate future that can be terminated from caller side.
- PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>>) - Constructor for class jadex.future.PullSubscriptionIntermediateFuture
-
Create a new future.
- PullSubscriptionIntermediateFuture(ICommand<PullSubscriptionIntermediateFuture<E>>, ITerminationCommand) - Constructor for class jadex.future.PullSubscriptionIntermediateFuture
-
Create a new future.
- PullSubscriptionIntermediateFuture(Exception) - Constructor for class jadex.future.PullSubscriptionIntermediateFuture
-
Create a future that is already done (failed).
Q
- queue - Variable in class jadex.future.FutureBlockingQueue
R
- reason - Variable in class jadex.future.TerminableDelegationFutureHandler
-
Exception used for termination.
- RemoteDelegationResultListener<E> - Class in jadex.future
-
Result listener that delegates calls to a future and can be called from remote.
- RemoteDelegationResultListener(Future<E>) - Constructor for class jadex.future.RemoteDelegationResultListener
-
Create a new listener.
- remove() - Method in class jadex.future.IntermediateFutureIterator
-
Not supported.
- removeBackwardCommand(ICommand<Object>) - Method in class jadex.future.TerminableFuture
-
Add a command with a filter.
- removeBackwardCommand(ICommand<Object>) - Method in class jadex.future.TerminableIntermediateFuture
-
Add a command with a filter.
- removeThreadLocal(ThreadLocal<?>) - Static method in class jadex.future.ThreadLocalTransferHelper
-
Add a thread local that will be automatically copied on thread resumption.
- restoreValues(Map<ThreadLocal<Object>, Object>) - Static method in class jadex.future.ThreadLocalTransferHelper
-
Method to be called on new thread on resumption.
- result - Variable in class jadex.future.Future
-
The result.
- result - Variable in class jadex.future.TupleResult
-
The result.
- resultavailable - Variable in class jadex.future.Future
-
Flag indicating if result is available.
- resultAvailable(E) - Method in class jadex.future.CollectionResultListener
-
Called when some result is available.
- resultAvailable(E) - Method in class jadex.future.CounterResultListener
-
Called when the result is available.
- resultAvailable(E) - Method in class jadex.future.DelegationResultListener
-
Called when the result is available.
- resultAvailable(E) - Method in class jadex.future.ExceptionDelegationResultListener
-
Called when the result is available.
- resultAvailable(E) - Method in class jadex.future.ExceptionResultListener
-
Called when the result is available, ignore.
- resultAvailable(E) - Method in interface jadex.future.IResultListener
-
Called when the result is available.
- resultAvailable(E) - Method in class jadex.future.RemoteDelegationResultListener
-
Called when the result is available.
- resultAvailable(Collection<E>) - Method in class jadex.future.CollectingIntermediateResultListener
-
Called when the result is available.
- resultAvailable(Collection<E>) - Method in class jadex.future.IntermediateDefaultResultListener
-
Called when the result is available.
- resultAvailable(Collection<E>) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when the result is available.
- resultAvailable(Collection<E>) - Method in class jadex.future.IntermediateEmptyResultListener
- resultAvailable(Collection<E>) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when the result is available.
- resultAvailable(Collection<E>) - Method in class jadex.future.UnlimitedIntermediateDelegationResultListener
-
Called when the result is available.
- resultAvailable(Collection<TupleResult>) - Method in class jadex.future.DefaultTuple2ResultListener
-
Called when the result is available.
- resultAvailableIfUndone(E) - Method in class jadex.future.CollectionResultListener
-
Called when the result is available.
- resultAvailableIfUndone(E) - Method in class jadex.future.CounterResultListener
-
Called when the result is available.
- resultAvailableIfUndone(E) - Method in class jadex.future.DelegationResultListener
-
Called when the result is available.
- resultAvailableIfUndone(E) - Method in class jadex.future.ExceptionDelegationResultListener
-
Called when the result is available.
- resultAvailableIfUndone(E) - Method in interface jadex.future.IUndoneResultListener
-
Called when the result is available.
- resultAvailableIfUndone(Collection<E>) - Method in class jadex.future.IntermediateDelegationResultListener
-
Called when the result is available.
- resultAvailableIfUndone(Collection<E>) - Method in class jadex.future.IntermediateExceptionDelegationResultListener
-
Called when the result is available.
- results - Variable in class jadex.future.CollectingIntermediateResultListener
-
The results.
- results - Variable in class jadex.future.CollectionResultListener
-
The original result collection.
- results - Variable in class jadex.future.IntermediateFuture
-
The intermediate results.
- resultssize - Variable in class jadex.future.SubscriptionIntermediateDelegationFuture
-
The number of results.
- resultssize - Variable in class jadex.future.SubscriptionIntermediateFuture
-
The number of results.
- resume() - Method in class jadex.future.Future
-
Resume after result or exception has been set.
- resume() - Method in class jadex.future.IntermediateFuture
-
Resume also intermediate waiters.
- resume(Future<?>) - Method in interface jadex.future.ISuspendable
-
Resume the execution of the suspendable.
- resume(Future<?>) - Method in class jadex.future.ThreadSuspendable
-
Resume the execution of the suspendable.
- resumed - Variable in class jadex.future.ThreadSuspendable
-
The resumed flag to differentiate from timeout.
- resumeIntermediate() - Method in class jadex.future.IntermediateFuture
-
Resume after intermediate result.
S
- saveValues() - Static method in class jadex.future.ThreadLocalTransferHelper
-
Method to be called on old thread before thread switch.
- scheduleMaxNotification(IResultListener<Collection<E>>) - Method in class jadex.future.IntermediateFuture
-
Schedule max notification
- scheduleNotification(IFilter<IResultListener<E>>, ICommand<IResultListener<E>>) - Method in class jadex.future.Future
-
Schedule a notification for selected listeners.
- scheduleNotification(IResultListener<E>, ICommand<IResultListener<E>>) - Method in class jadex.future.Future
-
Schedule a listener notification for a specific listener to be executed outside the synchronized block.
- second - Variable in exception class jadex.future.DuplicateResultException
-
The second result.
- secondResultAvailable(F) - Method in interface jadex.future.ITuple2ResultListener
-
Called when the first result is available.
- sendBackwardCommand(Object) - Method in interface jadex.future.IBackwardCommandFuture
-
Send a backward command in direction of the source.
- sendBackwardCommand(Object) - Method in class jadex.future.TerminableDelegationFuture
-
Send a backward command in direction of the source.
- sendBackwardCommand(Object) - Method in class jadex.future.TerminableDelegationFutureHandler
-
Send a backward command in direction of the source.
- sendBackwardCommand(Object) - Method in class jadex.future.TerminableFuture
-
Send a backward command in direction of the source.
- sendBackwardCommand(Object) - Method in class jadex.future.TerminableIntermediateDelegationFuture
-
Send a backward command in direction of the source.
- sendBackwardCommand(Object) - Method in class jadex.future.TerminableIntermediateFuture
-
Send a backward command in direction of the source.
- sendForwardCommand(Object) - Method in class jadex.future.Future
-
Send a (forward) command to the listeners.
- sendForwardCommand(Object) - Method in interface jadex.future.IForwardCommandFuture
-
Send a command to the listeners.
- serializer - Variable in class jadex.future.DuplicateRemovalIntermediateResultListener
-
The serializer function.
- setBloomFilter(BloomFilter) - Method in class jadex.future.DuplicateRemovalIntermediateResultListener
-
Set the bloom filter used to find duplicates.
- setException(Exception) - Method in class jadex.future.Future
-
Set the exception.
- setExceptionIfUndone(Exception) - Method in class jadex.future.Future
-
Set the exception.
- setFinished() - Method in class jadex.future.IntermediateFuture
-
Declare that the future is finished.
- setFinishedIfUndone() - Method in class jadex.future.IntermediateFuture
-
Declare that the future is finished.
- setFirstResult(E) - Method in class jadex.future.Tuple2Future
-
Set the result.
- setFirstResultIfUndone(E) - Method in class jadex.future.Tuple2Future
-
Set the result.
- setMaxResultCount(int) - Method in class jadex.future.IntermediateFuture
-
Set the maximum number of results.
- setNum(int) - Method in class jadex.future.TupleResult
-
Set the num.
- setNumber(int) - Method in class jadex.future.CollectionResultListener
-
Set the expected number of results.
- setNumber(int) - Method in class jadex.future.CounterResultListener
-
Set the number.
- setResult(E) - Method in class jadex.future.Future
-
Set the result.
- setResult(Object) - Method in class jadex.future.TupleResult
-
Set the result.
- setResultIfUndone(E) - Method in class jadex.future.Future
-
Set the result.
- setSecondResult(F) - Method in class jadex.future.Tuple2Future
-
Set the result.
- setSecondResultIfUndone(F) - Method in class jadex.future.Tuple2Future
-
Set the result.
- setTerminationCommand(ITerminationCommand) - Method in class jadex.future.TerminableFuture
-
Set the termination command.
- setTerminationCommand(ITerminationCommand) - Method in class jadex.future.TerminableIntermediateFuture
-
Set the terminate.
- setTerminationSource(ITerminableFuture<E>) - Method in class jadex.future.TerminableDelegationFuture
-
Set the termination source.
- setTerminationSource(ITerminableFuture<E>) - Method in class jadex.future.TerminableDelegationFutureHandler
-
Set the termination source.
- setTerminationSource(ITerminableFuture<Collection<E>>) - Method in class jadex.future.TerminableIntermediateDelegationFuture
-
Set the source.
- setXResult(int, Object) - Method in class jadex.future.Tuple2Future
-
Set the xth result.
- setXResultIfUndone(int, Object) - Method in class jadex.future.Tuple2Future
-
Set the xth result.
- size() - Method in class jadex.future.FutureBlockingQueue
- src - Variable in class jadex.future.TerminableDelegationFutureHandler
-
The termination source.
- startScheduledNotifications() - Static method in class jadex.future.Future
-
Start scheduled listener notifications using stack compaction, if desired.
- storedcmds - Variable in class jadex.future.TerminableDelegationFutureHandler
-
The list of stored backward commands, to be sent when src is connected.
- storeforfirst - Variable in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Flag if results should be stored till first listener is.
- storeforfirst - Variable in class jadex.future.SubscriptionIntermediateFuture
-
Flag if results should be stored till first listener is added.
- storeResult(E, boolean) - Method in class jadex.future.IntermediateFuture
-
Add a result.
- storeResult(E, boolean) - Method in class jadex.future.SubscriptionIntermediateDelegationFuture
-
Add a result.
- storeResult(E, boolean) - Method in class jadex.future.SubscriptionIntermediateFuture
-
Add a result.
- SubscriptionIntermediateDelegationFuture<E> - Class in jadex.future
- SubscriptionIntermediateDelegationFuture() - Constructor for class jadex.future.SubscriptionIntermediateDelegationFuture
-
Create a new future.
- SubscriptionIntermediateDelegationFuture(ITerminableIntermediateFuture<E>) - Constructor for class jadex.future.SubscriptionIntermediateDelegationFuture
-
Create a new future.
- SubscriptionIntermediateFuture<E> - Class in jadex.future
-
Implementation of the subscription intermediate future.
- SubscriptionIntermediateFuture() - Constructor for class jadex.future.SubscriptionIntermediateFuture
-
Create a new future.
- SubscriptionIntermediateFuture(ITerminationCommand) - Constructor for class jadex.future.SubscriptionIntermediateFuture
-
Create a new future.
- SubscriptionIntermediateFuture(ITerminationCommand, boolean) - Constructor for class jadex.future.SubscriptionIntermediateFuture
-
Create a new future.
- SubscriptionIntermediateFuture(Exception) - Constructor for class jadex.future.SubscriptionIntermediateFuture
-
Create a future that is already done (failed).
- suspend(Future<?>, long, boolean) - Method in interface jadex.future.ISuspendable
-
Suspend the execution of the suspendable.
- suspend(Future<?>, long, boolean) - Method in class jadex.future.ThreadSuspendable
-
Suspend the execution of the suspendable.
- SUSPENDABLE - Static variable in interface jadex.future.ISuspendable
-
The component suspendable for a component thread.
T
- tasks - Variable in class jadex.future.FutureFinishChecker
-
The list of future tasks to observe.
- TerminableDelegationFuture<E> - Class in jadex.future
-
A terminable delegation future can be used when a termination future should be delegated.
- TerminableDelegationFuture() - Constructor for class jadex.future.TerminableDelegationFuture
-
Create a new future.
- TerminableDelegationFuture(ITerminableFuture<E>) - Constructor for class jadex.future.TerminableDelegationFuture
-
Create a new future.
- TerminableDelegationFutureHandler<E> - Class in jadex.future
-
Handler for common code of (non) intermediate terminable delegation future.
- TerminableDelegationFutureHandler() - Constructor for class jadex.future.TerminableDelegationFutureHandler
-
Create a new future.
- TerminableFuture<E> - Class in jadex.future
-
Future that can be terminated from caller side.
- TerminableFuture() - Constructor for class jadex.future.TerminableFuture
-
Create a new future.
- TerminableFuture(ITerminationCommand) - Constructor for class jadex.future.TerminableFuture
-
Create a future that is already done.
- TerminableIntermediateDelegationFuture<E> - Class in jadex.future
-
A terminable intermediate delegation future can be used when a termination intermediate future should be delegated.
- TerminableIntermediateDelegationFuture() - Constructor for class jadex.future.TerminableIntermediateDelegationFuture
-
Create a new future.
- TerminableIntermediateDelegationFuture(ITerminableIntermediateFuture<E>) - Constructor for class jadex.future.TerminableIntermediateDelegationFuture
-
Create a new future.
- TerminableIntermediateFuture<E> - Class in jadex.future
-
Intermediate future that can be terminated from caller side.
- TerminableIntermediateFuture() - Constructor for class jadex.future.TerminableIntermediateFuture
-
Create a new future.
- TerminableIntermediateFuture(ITerminationCommand) - Constructor for class jadex.future.TerminableIntermediateFuture
-
Create a new future.
- TerminableIntermediateFuture(Exception) - Constructor for class jadex.future.TerminableIntermediateFuture
-
Create a future that is already done (failed).
- terminate - Variable in class jadex.future.TerminableDelegationFutureHandler
-
Flag if source has to be terminated.
- terminate - Variable in class jadex.future.TerminableFuture
-
The termination code.
- terminate - Variable in class jadex.future.TerminableIntermediateFuture
-
The termination code.
- terminate() - Method in interface jadex.future.ITerminableFuture
-
Terminate the future.
- terminate() - Method in class jadex.future.TerminableDelegationFuture
-
Terminate the future.
- terminate() - Method in class jadex.future.TerminableDelegationFutureHandler
-
Terminate the future.
- terminate() - Method in class jadex.future.TerminableFuture
-
Terminate the future.
- terminate() - Method in class jadex.future.TerminableIntermediateDelegationFuture
-
Terminate the future.
- terminate() - Method in class jadex.future.TerminableIntermediateFuture
-
Terminate the future.
- terminate(Exception) - Method in interface jadex.future.ITerminableFuture
-
Terminate the future and supply a custom reason.
- terminate(Exception) - Method in class jadex.future.TerminableDelegationFuture
-
Terminate the future and supply a custom reason.
- terminate(Exception) - Method in class jadex.future.TerminableDelegationFutureHandler
-
Terminate the future and supply a custom reason.
- terminate(Exception) - Method in class jadex.future.TerminableFuture
-
Terminate the future and supply a custom reason.
- terminate(Exception) - Method in class jadex.future.TerminableIntermediateDelegationFuture
-
Terminate the future and supply a custom reason.
- terminate(Exception) - Method in class jadex.future.TerminableIntermediateFuture
-
Terminate the future and supply a custom reason.
- terminated - Variable in class jadex.future.TerminableDelegationFutureHandler
-
Flag if source has been terminated.
- terminated(Exception) - Method in interface jadex.future.ITerminationCommand
-
Called after termination was performed.
- terminated(Exception) - Method in class jadex.future.TerminationCommand
-
Called after termination was performed.
- TerminationCommand - Class in jadex.future
-
Base implementation of termination command to be used for sub-classing.
- TerminationCommand() - Constructor for class jadex.future.TerminationCommand
- then(Consumer<? super E>) - Method in class jadex.future.Future
- then(Consumer<? super E>) - Method in interface jadex.future.IFuture
-
Applies a function after the result is available, using the result of this Future as input.
- then(Consumer<? super Collection<E>>) - Method in class jadex.future.IntermediateFuture
- thenAccept(Consumer<? super E>) - Method in class jadex.future.Future
- thenAccept(Consumer<? super E>, Class<?>) - Method in class jadex.future.Future
- thenApply(Function<? super E, ? extends T>) - Method in class jadex.future.Future
- thenApply(Function<? super E, ? extends T>) - Method in interface jadex.future.IFuture
-
Applies a function after the result is available, using the result of this Future as input.
- thenApply(Function<? super E, ? extends T>, Class<?>) - Method in class jadex.future.Future
- thenApply(Function<? super E, ? extends T>, Class<?>) - Method in interface jadex.future.IFuture
-
Applies a function after the result is available, using the result of this Future as input.
- thenCombine(IFuture<U>, BiFunction<? super E, ? super U, ? extends V>, Class<?>) - Method in class jadex.future.Future
- thenCompose(Function<? super E, IFuture<T>>) - Method in class jadex.future.Future
- thenCompose(Function<? super E, IFuture<T>>) - Method in interface jadex.future.IFuture
-
The result of this future is delegated to the given (future-returning) function.
- thenCompose(Function<? super E, IFuture<T>>, Class<?>) - Method in class jadex.future.Future
- thenCompose(Function<? super E, IFuture<T>>, Class<?>) - Method in interface jadex.future.IFuture
-
The result of this future is delegated to the given (future-returning) function.
- THREADLOCALS - Static variable in class jadex.future.ThreadLocalTransferHelper
-
The registered thread locals.
- ThreadLocalTransferHelper - Class in jadex.future
-
Helps to transfer registered thread local values between different threads.
- ThreadLocalTransferHelper() - Constructor for class jadex.future.ThreadLocalTransferHelper
-
Create a new transfer helper.
- ThreadLocalTransferHelper(boolean) - Constructor for class jadex.future.ThreadLocalTransferHelper
-
Create a new transfer helper.
- ThreadSuspendable - Class in jadex.future
-
Suspendable for threads.
- ThreadSuspendable() - Constructor for class jadex.future.ThreadSuspendable
- throwException(Throwable) - Static method in class jadex.future.Future
-
Throw an exception but include the current stack trace.
- toString() - Method in exception class jadex.future.DuplicateResultException
-
Get a string representation.
- toString() - Method in class jadex.future.TupleResult
-
Get the string representation.
- TRUE - Static variable in interface jadex.future.IFuture
-
A future representing a true result.
- Tuple2Future<E,
F> - Class in jadex.future -
Implementation of tuple2 future.
- Tuple2Future() - Constructor for class jadex.future.Tuple2Future
-
Create a future that is already done.
- Tuple2Future(E, F) - Constructor for class jadex.future.Tuple2Future
-
Create a future that is already done.
- Tuple2Future(Exception) - Constructor for class jadex.future.Tuple2Future
-
Create a future that is already done (failed).
- TupleResult - Class in jadex.future
-
Used by tuple futures as internal result wrappers.
- TupleResult() - Constructor for class jadex.future.TupleResult
-
Create a new TupleResult.
- TupleResult(int, Object) - Constructor for class jadex.future.TupleResult
-
Create a new SequenceResult.
- type - Variable in exception class jadex.future.DuplicateResultException
-
The type.
- TYPE_EXCEPTION_EXCEPTION - Static variable in exception class jadex.future.DuplicateResultException
-
Two exceptions.
- TYPE_EXCEPTION_RESULT - Static variable in exception class jadex.future.DuplicateResultException
-
First exception then result.
- TYPE_RESULT_EXCEPTION - Static variable in exception class jadex.future.DuplicateResultException
-
First result then exception.
- TYPE_RESULT_RESULT - Static variable in exception class jadex.future.DuplicateResultException
-
Two results.
U
- undone - Variable in class jadex.future.CollectionResultListener
-
The undone flag.
- undone - Variable in class jadex.future.CounterResultListener
-
The undone flag.
- undone - Variable in class jadex.future.DelegationResultListener
-
Flag if undone methods should be used.
- undone - Variable in class jadex.future.ExceptionDelegationResultListener
-
Flag if undone methods should be used.
- undone - Variable in class jadex.future.Future
-
The undone flag.
- undone - Variable in class jadex.future.IntermediateDelegationResultListener
-
Flag if undone methods should be used.
- undone - Variable in class jadex.future.IntermediateExceptionDelegationResultListener
-
The undone flag.
- UnlimitedIntermediateDelegationResultListener<E> - Class in jadex.future
-
Listener that forwards results but not finished events.
- UnlimitedIntermediateDelegationResultListener(IntermediateFuture<E>) - Constructor for class jadex.future.UnlimitedIntermediateDelegationResultListener
-
Create a new UnlimitedIntermediateDelegationResultListener.
- UNSET - Static variable in class jadex.future.Future
-
Constant for unset.
- UPDATETIMER - Enum constant in enum class jadex.future.IForwardCommandFuture.Type
V
- vals - Variable in class jadex.future.ThreadLocalTransferHelper
-
The thread locals.
- valueOf(String) - Static method in enum class jadex.future.IForwardCommandFuture.Type
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class jadex.future.IForwardCommandFuture.Type
-
Returns an array containing the constants of this enum class, in the order they are declared.
W
- wait - Variable in class jadex.future.ThreadSuspendable
- waitFor() - Method in class jadex.future.FutureBarrier
-
Wait for all added futures being finished.
- waitForIgnoreFailures(ICommand<Exception>) - Method in class jadex.future.FutureBarrier
-
Wait for all added futures being finished.
- waitForResults() - Method in class jadex.future.FutureBarrier
-
Wait for all added futures being finished and collect the results.
- waitForResultsIgnoreFailures(ICommand<Exception>) - Method in class jadex.future.FutureBarrier
-
Wait for all added futures being finished and collect the results.
- WAITING_THREADS - Static variable in class jadex.future.ThreadSuspendable
-
Threads waiting due to thread suspendable.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form