| Interface | Description |
|---|---|
| ArgumentIterator<E> |
This is a marker interface.
|
| AsynchronousProcessor |
Synchronization interface.
|
| CallableListener<V> |
Callback interface for callable execution.
|
| FireAndForgetInvocable<C,K> | |
| Invocable<C,R,K,E extends Exception> |
Something that can be invoked.
|
| Invocation<K> | |
| Invoker<C,R,K,E extends Exception> |
Invo
|
| Logger |
Logger for concurrent/distributed operations where logging along the execution path
is more convenient than traditional class-based logging.
|
| NotifyingFuture<V> |
Notifies callable listeners about callable invocation.
|
| PropertySet<KP> | |
| Synapse<C,R,K,E extends Exception> |
Synapse is a liaison between invoker and invocable.
|
| TaskCounter |
Callback interface for tasks created by synapses.
|
| TrackingExecutorService |
Executor service which keeps track of tasks submitted to it.
|
| Versionable<T> |
Interface for efficient forward-only change propagation.
|
| Versioner |
Interface for efficient forward-only change propagation.
|
| Class | Description |
|---|---|
| AbstractPropertySet<KP,KE> | |
| AbstractSubSet<KP> | |
| ArgumentIteratorAdapter<E> |
Adapts iterator to argument iterator.
|
| CallerThreadExecutorService |
Executes all tasks in the current thread.
|
| CompositeLogger |
Dispatches logging to several loggers.
|
| CountedRunnable |
This class increments counter when created and
decrements when run() method exits.
|
| CountedRunnable.Counter |
Counter to use with CounterRunnable.
|
| DelegatingRunnableFuture<V> | |
| InvocationImpl<K> | |
| LocalAbstractPropertySet<KP,KE> |
Property set which uses in-memory collections and reentrant read-write lock
|
| LocalStringPropertySet | |
| LocalSynapse<C,R,E extends Exception> |
Synapse which operates within JVM.
|
| LocalTrackingExecutorService |
In-JMV tracking executor service.
|
| LoggerWrapper |
A wrapper for java.util.logging.Logger
|
| MethodInvocable<C> |
Adapts java.lang.reflect.Method to Invocable.
|
| NonBlockingExecutorService | |
| NonBlockingFutureTask<V> |
Future task which cannot block in get() indefinitely.
|
| NonBlockingNotifyingFutureTask<V> |
Future task which cannot block in get() indefinitely.
|
| NonQueueingThreadPoolExecutorService |
This class does not queue jobs - it either executes them immediately in a background thread
or in a caller thread if all background threads are busy.
|
| OneOffCallable<T> |
Callable which callInternal() method is invoked only once.
|
| PropertySetConvertersBundle | |
| StringSubSet | |
| SynapseChain<C,R,K,E extends Exception> |
| Exception | Description |
|---|---|
| ConflictResolutionException | |
| InvocationException | |
| PropertySetException |
| Annotation Type | Description |
|---|---|
| Immutable |
Marker annotation to indicate that annotated class is immutable.
|