| Class | Description |
|---|---|
| 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 |
| Exception | Description |
|---|---|
| CPMChunkTimeoutException |
Copyright © 2018. All rights reserved.