org.threadly.concurrent.processing

Class FlowControlledNoFailureProcessor<T>

java.lang.Object

org.threadly.concurrent.processing.FlowControlledProcessor<T>

org.threadly.concurrent.processing.FlowControlledNoFailureProcessor<T>

Type Parameters:

T - The type of result produced / accepted

Direct Known Subclasses:

FlowControlledNoResultProcessor

public abstract class FlowControlledNoFailureProcessor<T>
extends FlowControlledProcessor<T>

Implementation of FlowControlledProcessor which assumes all exceptions are unexpected. Since this is a common condition this class can help reduce some boiler plate code.

Since:

5.37

Constructor Summary

Constructors

Constructor and Description
FlowControlledNoFailureProcessor(int maxRunningTasks, boolean provideResultsInOrder) Construct a new processor.

Method Summary

Methods inherited from class org.threadly.concurrent.processing.FlowControlledProcessor

start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowControlledNoFailureProcessor

public FlowControlledNoFailureProcessor(int maxRunningTasks,
                                        boolean provideResultsInOrder)

Construct a new processor. You must invoke FlowControlledProcessor.start() once constructed to start processing.

Parameters:

maxRunningTasks - Maximum number of concurrent running tasks

provideResultsInOrder - If true completed results will be provided in the order they are submitted