Index

A B C D E F G H I J L M N O P Q R S T U V W 
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.
A B C D E F G H I J L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form