ArtifactProducer |
Component responsible for continuously filling a work queue with bundles containing Cas'es.
|
BoundedWorkQueue |
Implementation of a Bounded Queue, a queue with a fixed number of slots.
|
ConsumerCasUtils |
|
CPECasPool |
Implements object pooling mechanism to limit number of CAS instances.
|
CPMEngine |
Responsible for creating and initializing processing threads.
|
CPMThreadGroup |
This component catches uncaught errors in the CPM.
|
DebugControlThread |
|
EOFToken |
Special class interpreted by the CPM's ProcessingUnit as the end of processing.
|
NonThreadedProcessingUnit |
|
ProcessingUnit |
This component executes the processing pipeline.
|
SequencedQueue |
This component extends the Bound Queue by guaranteeing delivery of CASes in sequential order.
|
WorkUnit |
|