Package com.inductiveautomation.perspective.gateway.threading

Class PollingTaskManager

java.lang.Object

com.inductiveautomation.ignition.common.lifecycle.AbstractLifecycle

com.inductiveautomation.perspective.gateway.threading.PollingTaskManager

public class PollingTaskManager
extends AbstractLifecycle

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	PollingTaskManager.State

Constructor Summary

Constructors

Constructor	Description
PollingTaskManager(PerspectiveContext context, PropertyTree props, java.lang.String refreshRatePath, long defaultRate, java.lang.Runnable task)
PollingTaskManager(java.util.concurrent.ScheduledExecutorService scheduler, java.util.concurrent.ExecutorService executor, PropertyTree props, java.lang.String refreshRatePath, long defaultRate, java.lang.Runnable task)

Method Summary

Modifier and Type	Method	Description
protected long	getRefreshRateFromProps()
protected void	onRefreshRateChange(PropertyTreeChangeEvent event)
protected void	onShutdown()
protected void	onStartup()
protected java.util.Optional<java.lang.Long>	parseLong(QualifiedValue qv)
void	submitIfIdle()	Submits the task immediately if currently idle or scheduled.

Methods inherited from class com.inductiveautomation.ignition.common.lifecycle.AbstractLifecycle

isRunning, shutdown, startup

Methods inherited from class java.lang.Object

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

Constructor Detail

PollingTaskManager

public PollingTaskManager(PerspectiveContext context,
                          PropertyTree props,
                          java.lang.String refreshRatePath,
                          long defaultRate,
                          java.lang.Runnable task)

PollingTaskManager

public PollingTaskManager(java.util.concurrent.ScheduledExecutorService scheduler,
                          java.util.concurrent.ExecutorService executor,
                          PropertyTree props,
                          java.lang.String refreshRatePath,
                          long defaultRate,
                          java.lang.Runnable task)

Method Detail

submitIfIdle

public void submitIfIdle()

Submits the task immediately if currently idle or scheduled.

onStartup

protected void onStartup()

Specified by:

onStartup in class AbstractLifecycle

onShutdown

protected void onShutdown()

Specified by:

onShutdown in class AbstractLifecycle

onRefreshRateChange

protected void onRefreshRateChange(PropertyTreeChangeEvent event)

getRefreshRateFromProps

protected long getRefreshRateFromProps()

parseLong

protected java.util.Optional<java.lang.Long> parseLong(QualifiedValue qv)