Package uk.ac.ebi.utils.runcontrol

Class StatsExecutor

java.lang.Object

uk.ac.ebi.utils.runcontrol.StatsExecutor

All Implemented Interfaces:

Executor

public class StatsExecutor
extends Object
implements Executor

An executor that logs statistics on the executions it receives to run.

Author:

brandizi

Date:

5 Oct 2015

Constructor Summary

Constructors

Constructor	Description
StatsExecutor(String serviceName)
StatsExecutor(String serviceName, long samplingTime)

Method Summary

Modifier and Type	Method	Description
protected boolean	doStats()	Checks if getSamplingTime() has passed.
void	execute(Runnable action)	Runs the action, intercepts any Exception it generates. increase getTotalCalls() and, if there is an exception, getFailedCalls() too.
protected int	getFailedCalls()	This is reset every getSamplingTime() ms.
int	getLastFailedCalls()	This is updated every getSamplingTime()
int	getLastTotalCalls()	This is updated every getSamplingTime()
long	getSamplingTime()	Statistics are logged and then reset every this amount of time, in ms.
protected int	getTotalCalls()	This is reset every getSamplingTime() ms.
boolean	isPopUpExceptions()
StatsExecutor	setPopUpExceptions(boolean popUpExceptions)
void	setSamplingTime(long samplingTime)

Methods inherited from class java.lang.Object

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

Constructor Details

StatsExecutor

public StatsExecutor(String serviceName,
 long samplingTime)

StatsExecutor

public StatsExecutor(String serviceName)

Method Details

execute

public void execute(Runnable action)

Runs the action, intercepts any Exception it generates. increase getTotalCalls() and, if there is an exception, getFailedCalls() too. Eventually invokes doStats(). If isPopUpExceptions() exceptions are let to reach the invoker.

Specified by:

execute in interface Executor

doStats

protected boolean doStats()

Checks if getSamplingTime() has passed. If yes, logs statistics on recorded calls/min and failed calls.

getTotalCalls

protected int getTotalCalls()

This is reset every getSamplingTime() ms.

getFailedCalls

protected int getFailedCalls()

This is reset every getSamplingTime() ms.

getLastTotalCalls

public int getLastTotalCalls()

This is updated every getSamplingTime()

getLastFailedCalls

public int getLastFailedCalls()

This is updated every getSamplingTime()

isPopUpExceptions

public boolean isPopUpExceptions()

See Also:

• If true, exceptions are let to reach the invoker. If you have a service that is known to fail, you may want to just record failures and let your program to continue, e.g., with null result.

setPopUpExceptions

public StatsExecutor setPopUpExceptions(boolean popUpExceptions)

getSamplingTime

public long getSamplingTime()

Statistics are logged and then reset every this amount of time, in ms.

setSamplingTime

public void setSamplingTime(long samplingTime)