Package org.threadly.concurrent.processing

Classes that assist with processing batches or streams of data.

See: Description

Class Summary

Class	Description
BlockingQueueConsumer<T>	This class is designed for handling the threading and consumption of a high throughput BlockingQueue.
FlowControlledNoFailureProcessor<T>	Implementation of FlowControlledProcessor which assumes all exceptions are unexpected.
FlowControlledNoResultProcessor	Implementation of FlowControlledProcessor 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.

Package org.threadly.concurrent.processing Description

Classes that assist with processing batches or streams of data. These are utilities for organizing and managing execution for efficient processing.