org.qi4j.library.scheduler.slaves
Class SchedulerPulse

java.lang.Object
  org.qi4j.library.scheduler.slaves.SchedulerPulse

All Implemented Interfaces:

Runnable

public class SchedulerPulse
extends Object

Heartbeat of the Scheduler, load runnable Tasks and enqueue them in the SchedulerWorkQueue.

Field Summary

protected Boolean	commitSuicide
protected static org.slf4j.Logger	LOGGER
protected Long	rhythm

Constructor Summary

SchedulerPulse(Long rhythm, SchedulerWorkQueue workQueue)

Method Summary

protected void	onRun()
void	run()
void	suicideAfterCurrentCycle()

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

rhythm

protected final Long rhythm

commitSuicide

protected Boolean commitSuicide

Constructor Detail

SchedulerPulse

public SchedulerPulse(@Uses
                      Long rhythm,
                      @Uses
                      SchedulerWorkQueue workQueue)

Method Detail

onRun

protected void onRun()

run

public void run()

Specified by:

run in interface Runnable

suicideAfterCurrentCycle

public final void suicideAfterCurrentCycle()