Package org.threadly.concurrent.processing

Class 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 Description
      FlowControlledNoFailureProcessor​(int maxRunningTasks, boolean provideResultsInOrder)
      Construct a new processor.

    • Method Summary

      • 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