Package org.threadly.concurrent.processing

Class FlowControlledNoResultProcessor

java.lang.Object

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

org.threadly.concurrent.processing.FlowControlledNoFailureProcessor<java.lang.Object>

org.threadly.concurrent.processing.FlowControlledNoResultProcessor

public abstract class FlowControlledNoResultProcessor
extends FlowControlledNoFailureProcessor<java.lang.Object>

Implementation of FlowControlledProcessor which reduces boiler plate code when no result is expected. Instead all logic should be done in the future returned by next().

To further minimize code this extends FlowControlledNoFailureProcessor where by default all exceptions are considered failures. If you want to handle some failures you can override FlowControlledNoFailureProcessor.handleFailure(Throwable) returning true to indicate an exception as expected.

Since:

5.37

Constructor Summary

Constructors

Constructor	Description
FlowControlledNoResultProcessor(int maxRunningTasks)	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

FlowControlledNoResultProcessor

public FlowControlledNoResultProcessor(int maxRunningTasks)

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

Parameters:

maxRunningTasks - Maximum number of concurrent running tasks