Package org.threadly.concurrent.processing
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 throughputBlockingQueue
.FlowControlledNoFailureProcessor<T> Implementation ofFlowControlledProcessor
which assumes all exceptions are unexpected.FlowControlledNoResultProcessor Implementation ofFlowControlledProcessor
which 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.