Interface | Description |
---|---|
IBackwardCommandFuture | |
ICommandFuture | |
IForwardCommandFuture | |
IFunctionalExceptionListener |
Callback interface for methods that should operate decoupled from caller thread.
|
IFunctionalResultListener<E> |
Callback interface for methods that should operate decoupled from caller thread.
|
IFuture<E> |
Interface for futures.
|
IFutureCommandListener |
Additional interface for result listeners that are
able to process commands from the source future.
|
IFutureCommandResultListener<E> |
Interface that extends both, result listener and future command.
|
IIntermediateFuture<E> |
Future that support intermediate results.
|
IIntermediateFutureCommandResultListener<E> |
Interface that extends both, result listener and future command.
|
IIntermediateResultListener<E> |
Result listener with additional notifications in case of intermediate results.
|
IOnIntermediateResultListener<E> |
Callback interface for methods that should operate decoupled from caller thread.
|
IPullIntermediateFuture<E> |
Intermediate future with pull mechanism.
|
IPullSubscriptionIntermediateFuture<E> |
Intermediate future with pull mechanism.
|
IRemoteResultListener<E> |
Remoteable version of the result listener interface.
|
IResultListener<E> |
Callback interface for methods that should operate decoupled from caller thread.
|
ISubscriptionIntermediateFuture<E> |
The subscription intermediate future does not save the results but
instead uses a fire and forget semantics.
|
ISuspendable |
Interface for suspendable entities.
|
ITerminableFuture<E> |
Interface for a future that can be terminated
from caller side.
|
ITerminableIntermediateFuture<E> |
Interface for an intermediate future that can be terminated
from caller side.
|
ITerminationCommand |
A command to customize termination of a terminable future.
|
ITuple2Future<E,F> |
A tuple future has a defined number of results of possibly different types.
|
ITuple2ResultListener<E,F> |
Listener for tuple2 futures.
|
IUndoneIntermediateResultListener<E> | |
IUndoneResultListener<E> |
Class | Description |
---|---|
CallMultiplexer |
The CallMultiplexer unifies multiple executions of "similar" commands to a single execution.
|
CollectingIntermediateResultListener<E> |
A listener that collects intermediate results and calls resultAvailable() on setFinished().
|
CollectionResultListener<E> |
Collection result listener collects a number of results and return a collection.
|
CounterResultListener<E> |
Counter result listener for counting a specified number of resultAvailable calls.
|
DefaultResultListener<E> |
The default listener for logging exceptions as warning.
|
DefaultTuple2ResultListener<E,F> |
Default tuple2 result listener that implements the
(obsolete) methods
- resultAvailable
- intermediateResultAvailable
- finished
|
DelegationResultListener<E> |
Result listener that delegates calls to a future.
|
ExceptionDelegationResultListener<E,T> |
Result listener that delegates calls to a future.
|
ExceptionResultListener<E> |
The exception listener is used for intercepting exceptions while ignoring results.
|
Future<E> |
Future that includes mechanisms for callback notification.
|
FutureBarrier<E> |
A future barrier allows for waiting for a variable number
of futures.
|
FutureFinishChecker |
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).
|
FutureHelper |
Helper class to access future notification stack
|
IntermediateDefaultResultListener<E> |
The default listener for just printing out result information.
|
IntermediateDelegationResultListener<E> |
Intermediate version of the delegation result listener.
|
IntermediateExceptionDelegationResultListener<E,T> | |
IntermediateFuture<E> |
Default implementation of an intermediate future.
|
IntermediateFutureIterator<E> |
Helper class for iterating over the results of an intermediate future.
|
PullIntermediateDelegationFuture<E> |
Delegation future for pull future.
|
PullIntermediateFuture<E> |
Intermediate future that can be terminated from caller side.
|
PullSubscriptionIntermediateDelegationFuture<E> |
Delegation future for pull future.
|
PullSubscriptionIntermediateFuture<E> |
Intermediate future that can be terminated from caller side.
|
ReadWriteLock |
Locking class implementing RX-style operation:
Multiple reads are allowed to be performed at the same time
but write operations are exclusive.
|
RemoteDelegationResultListener<E> |
Result listener that delegates calls to a future
and can be called from remote.
|
SResultListener |
Static helper class for creating result listeners.
|
SubscriptionIntermediateDelegationFuture<E> | |
SubscriptionIntermediateFuture<E> |
Implementation of the subscription intermediate future.
|
TerminableDelegationFuture<E> |
A terminable delegation future can be used when a termination future
should be delegated.
|
TerminableDelegationResultListener<E> |
Result listener for terminable futures.
|
TerminableFuture<E> |
Future that can be terminated from caller side.
|
TerminableIntermediateDelegationFuture<E> |
A terminable intermediate delegation future can be used when a termination intermediate future
should be delegated.
|
TerminableIntermediateDelegationResultListener<E> |
Result listener for terminable intermediate futures.
|
TerminableIntermediateFuture<E> |
Intermediate future that can be terminated from caller side.
|
TerminationCommand |
Base implementation of termination command to be used for sub-classing.
|
ThreadLocalTransferHelper |
Helps to transfer registered thread local values between different threads.
|
ThreadSuspendable |
Suspendable for threads.
|
Tuple2Future<E,F> |
Implementation of tuple2 future.
|
TupleResult |
Used by tuple futures as internal result wrappers.
|
Enum | Description |
---|---|
ICommandFuture.Type |
The available commands.
|
IForwardCommandFuture.Type |
The available commands.
|
Exception | Description |
---|---|
DuplicateResultException |
Exception indicating that the result of a future was set twice.
|
ErrorException |
Wrapper to set errors (e.g.
|
FutureTerminatedException |