| AbstractObjectOneWorkExecutor |
A one work executor allows for an arbitrary amount of objects having work, but only one piece of
work is allowed for each object at a time.
|
| AbstractObjectOneWorkExecutor.RuntimeData |
This class represents runtime data for an one work executor.
|
| AbstractObjectRunnable |
An abstract implementation for an ObjectRunnable including some lifecycle management
like being active and termination.
|
| AbstractObjectSpecificExecutor |
A thread pool executor that accepts work for specific objects.
|
| AbstractPipeliningExecutor |
A pipelining executor handles work in pipelines.
|
| ObjectOneWorkRunnable |
A runnable for having exactly one runnable per object.
|
| ObjectRunnable |
This interface represents a runnable that is identified via a specific object.
|
| PipelineRunnable |
A runnable that executes all runnables that are present for a specific
object.
|
| ScheduledObjectOneWorkExecutor |
This scheduled one work executor handles the usual pending work for before and after a flush.
|
| ScheduledObjectOneWorkExecutor.ScheduledRuntimeData |
This class extends RuntimeData by a runnable which will be delayed and the
corresponding future stemming from scheduling the runnable in the scheduling executor.
|
| ScheduledObjectOneWorkRunnable |
A runnable that will enqueue a delayed object runnable as soon as the delay elapsed.
|