Classes that assist with processing batches or streams of data. These are utilities for organizing and managing execution for efficient processing.
Class Summary Class Description BlockingQueueConsumer<T>This class is designed for handling the threading and consumption of a high throughput
FlowControlledProcessorwhich assumes all exceptions are unexpected.
FlowControlledProcessorwhich reduces boiler plate code when no result is expected.
FlowControlledProcessor<T>Abstract implementation which will do async processing, but only submit a limited number of tasks processing concurrently.