ThresholdTimeoutService (ChRL

public abstract class ThresholdTimeoutService<T>
extends Object

Constructors
Constructor and Description
`ThresholdTimeoutService(int threshold, int timeout)` fires `processBeforeAll(Object)`, `processAll(Collection)` and `processAfterAll(Object)` when threshold or timeout is reached
`ThresholdTimeoutService(int threshold, int timeout, Comparator<T> cmp)`

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`addToQueue(Iterable<T> data)`
`boolean`	`addToQueue(T... data)`
`int`	`getProcessesRunning()`
`int`	`getThreshold()`
`int`	`getTimeout()`
`abstract void`	`processAfterAll(T arg)` post processing
`abstract boolean`	`processAll(Collection<T> args)` main processing
`abstract boolean`	`processBeforeAll(T arg)` pre processing
`void`	`setThreshold(int threshold)`
`void`	`setTimeout(int timeout)`

public ThresholdTimeoutService(int threshold,
                               int timeout,
                               Comparator<T> cmp)

@SafeVarargs
public final boolean addToQueue(T... data)

public final boolean addToQueue(Iterable<T> data)

public abstract void processAfterAll(T arg)
                              throws Exception

post processing

public final void setTimeout(int timeout)

public final void setThreshold(int threshold)

Class ThresholdTimeoutService<T>