Package com.illumon.iris.db.plot.util.governor

Class BatchedLambdaGovernor

java.lang.Object

com.illumon.iris.db.plot.util.governor.BatchedLambdaGovernor

All Implemented Interfaces:

LambdaGovernor

public class BatchedLambdaGovernor
extends Object
implements LambdaGovernor

Executes all scheduled tasks at the fixed update interval.

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.plot.util.governor.LambdaGovernor

LambdaGovernor.ErrorListener

Constructor Summary

Constructors

Constructor	Description
BatchedLambdaGovernor(long updateIntervalMillis)

Method Summary

Modifier and Type	Method	Description
void	addErrorListener(LambdaGovernor.ErrorListener l)	Add a listener to handle errors from events within a scheduled job.
List<RunnableFuture>	getAndClearCallbacks(Object key)	Get the callbacks for a given task.
void	pause()	Pauses this governor's execution schedule.
void	removeErrorListener(LambdaGovernor.ErrorListener l)	Remove an error listener.
void	schedule(Object key, Runnable task)	Schedules when the task will run.
void	schedule(Object key, Runnable task, RunnableFuture callback)	Schedules when the task will run.
void	shutDown()	Shuts down this governor.
void	start()	Starts this governor's execution schedule.

Methods inherited from class java.lang.Object

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

Constructor Details

BatchedLambdaGovernor

public BatchedLambdaGovernor(long updateIntervalMillis)

Method Details

addErrorListener

public void addErrorListener(LambdaGovernor.ErrorListener l)

Description copied from interface: LambdaGovernor

Add a listener to handle errors from events within a scheduled job.

Specified by:

addErrorListener in interface LambdaGovernor

Parameters:

l - the listener to add

removeErrorListener

public void removeErrorListener(LambdaGovernor.ErrorListener l)

Description copied from interface: LambdaGovernor

Remove an error listener.

Specified by:

removeErrorListener in interface LambdaGovernor

Parameters:

l - the listener to remove

start

public void start()

Description copied from interface: LambdaGovernor

Starts this governor's execution schedule.

Specified by:

start in interface LambdaGovernor

pause

public void pause()

Description copied from interface: LambdaGovernor

Pauses this governor's execution schedule. Tasks can still be added to the work queue.

Specified by:

pause in interface LambdaGovernor

shutDown

public void shutDown()

Description copied from interface: LambdaGovernor

Shuts down this governor. Tasks can no longer be added to the work queue. The currently running task will be allowed to execute until completion. This LambdaGovernor can not be restarted once shutDown is called.

Specified by:

shutDown in interface LambdaGovernor

schedule

public void schedule(Object key,
 Runnable task)

Description copied from interface: LambdaGovernor

Schedules when the task will run.

Specified by:

schedule in interface LambdaGovernor

Parameters:

key - task identifier

task - Runnable task

schedule

public void schedule(Object key,
 Runnable task,
 RunnableFuture callback)

Description copied from interface: LambdaGovernor

Schedules when the task will run. Adds the callback for the given key

Specified by:

schedule in interface LambdaGovernor

Parameters:

key - task identifier

task - Runnable task

callback - Runnable run once task is complete.

getAndClearCallbacks

public List<RunnableFuture> getAndClearCallbacks(Object key)

Description copied from interface: LambdaGovernor

Get the callbacks for a given task. Allows all callbacks to run after governor choking.

Specified by:

getAndClearCallbacks in interface LambdaGovernor

Parameters:

key - task identifier

Returns:

callbacks for the given key.