com.inductiveautomation.ignition.common.execution.impl

Class BasicExecutionEngine.SelfSchedulingRunner

java.lang.Object

com.inductiveautomation.ignition.common.execution.impl.BasicExecutionEngine.SelfSchedulingRunner

All Implemented Interfaces:

SchedulingController, java.lang.Runnable

Enclosing class:

BasicExecutionEngine

protected class BasicExecutionEngine.SelfSchedulingRunner
extends java.lang.Object
implements java.lang.Runnable, SchedulingController

Constructor Summary

Constructors

Constructor and Description
SelfSchedulingRunner(java.lang.String owner, java.lang.String name, SelfSchedulingRunnable run) Wraps a self-scheduling runnable in another runnable that re-schedules after each successful run.

Method Summary

Modifier and Type	Method and Description
long	getDelayMS()
java.lang.String	getName()
java.lang.String	getOwner()
void	requestReschedule(SelfSchedulingRunnable source) Immediately call getNextExecDelayMillis() on the source and reschedule as appropriate.
void	run()
void	setFuture(java.util.concurrent.Future<?> future)

Methods inherited from class java.lang.Object

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

Constructor Detail

SelfSchedulingRunner

public SelfSchedulingRunner(java.lang.String owner,
                            java.lang.String name,
                            SelfSchedulingRunnable run)

Wraps a self-scheduling runnable in another runnable that re-schedules after each successful run.

Method Detail

getOwner

public java.lang.String getOwner()

getName

public java.lang.String getName()

getDelayMS

public long getDelayMS()

run

public void run()

Specified by:

run in interface java.lang.Runnable

requestReschedule

public void requestReschedule(SelfSchedulingRunnable source)

Description copied from interface: SchedulingController

Immediately call getNextExecDelayMillis() on the source and reschedule as appropriate.

Specified by:

requestReschedule in interface SchedulingController

setFuture

public void setFuture(java.util.concurrent.Future<?> future)