Package com.inductiveautomation.ignition.common.execution.impl

Class BasicExecutionEngine

java.lang.Object

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

All Implemented Interfaces:

ExecutionManager

public class BasicExecutionEngine
extends Object
implements ExecutionManager

The ExecutionEngine is a wrapper around a scheduled executor service. Callers are able to create named tasks, and this class keeps track of associating those names with the ScheduledFutures that represent the actual execution tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BasicExecutionEngine.SelfSchedulingRunner
class	BasicExecutionEngine.ThrowableCatchingRunnable

Constructor Summary

Constructors

Constructor	Description
BasicExecutionEngine()
BasicExecutionEngine(int threadCount, String name)
BasicExecutionEngine(int threadCount, String name, boolean daemon)
BasicExecutionEngine(int threadCount, String name, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
void	executeOnce(Runnable command)	Executes a runnable one time as soon as possible.
void	executeOnce(Runnable command, long delay)	Excutes a runnable one time after a delay, specified in milliseconds
ScheduledFuture<?>	executeOnce(Runnable command, long delay, TimeUnit unit)	Executes a runnable after a fixed delay
String	getName()
List<String>	getTaskOwners()
List<TaskStats>	getTasks(String owner)
void	modify(String owner, String name, Runnable command, int newRate, TimeUnit newUnit)	Modifies the execution rate of the given execution unit.
void	modifyFixedRate(String owner, String name, Runnable command, int newRate, TimeUnit newUnit)
void	register(String owner, String name, SelfSchedulingRunnable command)	Registers a self scheduling command to be executed.
void	register(String owner, String name, Runnable command, int rate)	Registers a command to be executing repeatedly at the specified rate.
void	register(String owner, String name, Runnable command, int rate, TimeUnit unit)	Registers a command to be executing repeatedly at the specified rate.
void	registerAtFixedRate(String owner, String name, Runnable command, int rate, TimeUnit unit)	Registers a command to be executed with a fixed rate rather than a fixed delay.
void	registerAtFixedRateWithInitialDelay(String owner, String name, Runnable command, int rate, TimeUnit unit, int initialDelay)	Registers a command to be executed with a fixed rate after some initial delay.
void	registerWithInitialDelay(String owner, String name, Runnable command, int rate, int initialDelay)	Registers a command to be executing repeatedly at the specified rate with an initial delay.
void	registerWithInitialDelay(String owner, String name, Runnable command, int rate, TimeUnit unit, int initialDelay)	Registers a command to be executing repeatedly at the specified rate with an initial delay.
String	schedule(String taskName, Runnable task, String cronPattern)
protected void	scheduleNext(BasicExecutionEngine.SelfSchedulingRunner ssr)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)	Schedules a runnable to execute with a fixed delay, and after an initial delay, much like ExecutionManager.registerWithInitialDelay(String, String, Runnable, int, TimeUnit, int).
void	shutdown()	Stops all execution gracefully.
protected void	synchedUpdateTaskMap(String owner, String name, ScheduledFuture<?> future)	Updates the task map.
String	toString()
void	unRegister(String owner, String name)	De-registers the execution unit.
void	unRegister(String owner, String name, boolean interrupt)	De-registers the execution unit.
void	unRegisterAll(String owner)	Unregisters all tasks for a given owner.
void	unSchedule(String taskId)

Methods inherited from class java.lang.Object

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

Constructor Details

BasicExecutionEngine

public BasicExecutionEngine()

BasicExecutionEngine

public BasicExecutionEngine(int threadCount,
 String name)

BasicExecutionEngine

public BasicExecutionEngine(int threadCount,
 String name,
 boolean daemon)

BasicExecutionEngine

public BasicExecutionEngine(int threadCount,
 String name,
 ThreadFactory threadFactory)

Method Details

getName

public String getName()

shutdown

public void shutdown()

Description copied from interface: ExecutionManager

Stops all execution gracefully.

Specified by:

shutdown in interface ExecutionManager

schedule

public String schedule(String taskName,
 Runnable task,
 String cronPattern)
                throws it.sauronsoftware.cron4j.InvalidPatternException

Throws:

it.sauronsoftware.cron4j.InvalidPatternException

unSchedule

public void unSchedule(String taskId)

register

public void register(String owner,
 String name,
 Runnable command,
 int rate)

Description copied from interface: ExecutionManager

Registers a command to be executing repeatedly at the specified rate. If the name is already registered, the existing execution unit will be modified.

Specified by:

register in interface ExecutionManager

Parameters:

owner - name of the "owner"- just a string qualifier for the command name.

name - identifier used in conjunction with the owner to identify the command.

command - Runnable to be called at the specified rate.

rate - The amount of time to wait in between invocations of the command, in milliseconds.

register

public void register(String owner,
 String name,
 Runnable command,
 int rate,
 TimeUnit unit)

Description copied from interface: ExecutionManager

Registers a command to be executing repeatedly at the specified rate. If the name is already registered, the existing execution unit will be modified.

Specified by:

register in interface ExecutionManager

Parameters:

owner - name of the "owner"- just a string qualifier for the command name.

name - identifier used in conjunction with the owner to identify the command.

command - Runnable to be called at the specified rate.

registerAtFixedRate

public void registerAtFixedRate(String owner,
 String name,
 Runnable command,
 int rate,
 TimeUnit unit)

Description copied from interface: ExecutionManager

Registers a command to be executed with a fixed rate rather than a fixed delay.

Specified by:

registerAtFixedRate in interface ExecutionManager

registerAtFixedRateWithInitialDelay

public void registerAtFixedRateWithInitialDelay(String owner,
 String name,
 Runnable command,
 int rate,
 TimeUnit unit,
 int initialDelay)

Description copied from interface: ExecutionManager

Registers a command to be executed with a fixed rate after some initial delay.

Specified by:

registerAtFixedRateWithInitialDelay in interface ExecutionManager

synchedUpdateTaskMap

protected void synchedUpdateTaskMap(String owner,
 String name,
 ScheduledFuture<?> future)

Updates the task map. Task map MUST be synchronized before calling this.

registerWithInitialDelay

public void registerWithInitialDelay(String owner,
 String name,
 Runnable command,
 int rate,
 int initialDelay)

Description copied from interface: ExecutionManager

Registers a command to be executing repeatedly at the specified rate with an initial delay.

Specified by:

registerWithInitialDelay in interface ExecutionManager

registerWithInitialDelay

public void registerWithInitialDelay(String owner,
 String name,
 Runnable command,
 int rate,
 TimeUnit unit,
 int initialDelay)

Description copied from interface: ExecutionManager

Registers a command to be executing repeatedly at the specified rate with an initial delay.

Specified by:

registerWithInitialDelay in interface ExecutionManager

modify

public void modify(String owner,
 String name,
 Runnable command,
 int newRate,
 TimeUnit newUnit)

Modifies the execution rate of the given execution unit. Basically just unregisters and registers. Can also be used to modify the Runnable associated with the name.

modifyFixedRate

public void modifyFixedRate(String owner,
 String name,
 Runnable command,
 int newRate,
 TimeUnit newUnit)

unRegister

public void unRegister(String owner,
 String name)

De-registers the execution unit. If the unit is in the process of running, it will be interrupted.

Specified by:

unRegister in interface ExecutionManager

unRegister

public void unRegister(String owner,
 String name,
 boolean interrupt)

De-registers the execution unit.

Specified by:

unRegister in interface ExecutionManager

Parameters:

interrupt - Interrupts the execution if it is currently occurring. If false, waits for completion.

unRegisterAll

public void unRegisterAll(String owner)

Unregisters all tasks for a given owner.

Specified by:

unRegisterAll in interface ExecutionManager

executeOnce

public void executeOnce(Runnable command)

Executes a runnable one time as soon as possible.

Specified by:

executeOnce in interface ExecutionManager

executeOnce

public void executeOnce(Runnable command,
 long delay)

Description copied from interface: ExecutionManager

Excutes a runnable one time after a delay, specified in milliseconds

Specified by:

executeOnce in interface ExecutionManager

executeOnce

public ScheduledFuture<?> executeOnce(Runnable command,
 long delay,
 TimeUnit unit)
                               throws RejectedExecutionException

Executes a runnable after a fixed delay

Specified by:

executeOnce in interface ExecutionManager

Throws:

RejectedExecutionException

register

public void register(String owner,
 String name,
 SelfSchedulingRunnable command)

Description copied from interface: ExecutionManager

Registers a self scheduling command to be executed. Self scheduling commands provide their own execution delay, which can change from exec to exec.

Specified by:

register in interface ExecutionManager

scheduleNext

protected void scheduleNext(BasicExecutionEngine.SelfSchedulingRunner ssr)

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
 long initialDelay,
 long delay,
 TimeUnit unit)

Description copied from interface: ExecutionManager

Schedules a runnable to execute with a fixed delay, and after an initial delay, much like ExecutionManager.registerWithInitialDelay(String, String, Runnable, int, TimeUnit, int). The difference is that this method returns a ScheduledFuture that can be used to cancel the task.

Specified by:

scheduleWithFixedDelay in interface ExecutionManager

getTaskOwners

public List<String> getTaskOwners()

getTasks

public List<TaskStats> getTasks(String owner)

toString

public String toString()

Overrides:

toString in class Object