Class FlowControlledNoFailureProcessor<T>

  • Type Parameters:
    T - The type of result produced / accepted
    Direct Known Subclasses:

    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.
    • Constructor Summary

      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.
        maxRunningTasks - Maximum number of concurrent running tasks
        provideResultsInOrder - If true completed results will be provided in the order they are submitted