Package de.uni_kiel.rz.fdr.repl

Class REPLJobCallbackAutoTune

java.lang.Object

de.uni_kiel.rz.fdr.repl.REPLJobCallbackAutoTune

All Implemented Interfaces:

Consumer<REPLJob.JobEvent>

public class REPLJobCallbackAutoTune
extends Object
implements Consumer<REPLJob.JobEvent>

A Callback that you can use for your jobs; it automatically adjusts its concurrency to tune it for maximum throughput.

Constructor Summary

Constructors

Constructor	Description
REPLJobCallbackAutoTune(int minConcurrency, int maxConcurrency)	Create a new AutoTune job callback.

Method Summary

Modifier and Type	Method	Description
void	accept(REPLJob.JobEvent ev)	For internal use only.
int	getMaxConcurrency()	Get the current maximum concurrency limit.
int	getMinConcurrency()	Get the current minimum concurrency limit.
void	setMaxConcurrency(int maxConcurrency)	Set a new maximum concurrency limit.
void	setMinConcurrency(int minConcurrency)	Set a new minimum concurrency limit.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Details

REPLJobCallbackAutoTune

public REPLJobCallbackAutoTune(int minConcurrency,
 int maxConcurrency)

Create a new AutoTune job callback. Each instance should only be used once, with a single job.

Parameters:

minConcurrency - The minimum concurrency level this callback will ever set.

maxConcurrency - The maximum concurrency level this callback will ever set.

Method Details

accept

public void accept(REPLJob.JobEvent ev)

For internal use only.

Specified by:

accept in interface Consumer<REPLJob.JobEvent>

Parameters:

ev - A new job event.

getMinConcurrency

public int getMinConcurrency()

Get the current minimum concurrency limit.

Returns:

The current minimum concurrency limit.

setMinConcurrency

public void setMinConcurrency(int minConcurrency)

Set a new minimum concurrency limit. Must be bigger than 0 and can not be greater then the maximum concurrency limit. You can safely invoke this method while the associated job is active.

Parameters:

minConcurrency - The new minimum concurrency limit.

getMaxConcurrency

public int getMaxConcurrency()

Get the current maximum concurrency limit.

Returns:

The current maximum concurrency limit.

setMaxConcurrency

public void setMaxConcurrency(int maxConcurrency)

Set a new maximum concurrency limit. Must not be smaller than the minimum concurrency limit. You can safely invoke this method while the associated job is active.

Parameters:

maxConcurrency - The new maximum concurrency limit.