Package com.inductiveautomation.perspective.gateway.threading

Class PerspectivePollingBlockingTask

java.lang.Object

com.inductiveautomation.ignition.common.lifecycle.AbstractLifecycle

com.inductiveautomation.ignition.common.execution.PollingBlockingTask

com.inductiveautomation.perspective.gateway.threading.PerspectivePollingBlockingTask

public class PerspectivePollingBlockingTask
extends PollingBlockingTask

A polling blocking task that looks up its rate from a property tree and is reactive to the rate changing.

Nested Class Summary

Nested classes/interfaces inherited from class com.inductiveautomation.ignition.common.execution.PollingBlockingTask

PollingBlockingTask.State

Field Summary

Fields inherited from class com.inductiveautomation.ignition.common.execution.PollingBlockingTask

LOG

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected long	getInitialRate()	Default implementation returns the rate from the constructor, but provides a place for subclasses to re-define the rate on startup if necessary.
protected long	getRefreshRateFromProps()
protected void	onRefreshRateChange(PropertyTreeChangeEvent event)
protected void	onShutdown()
protected java.util.Optional<java.lang.Long>	parseLong(QualifiedValue qv)

Methods inherited from class com.inductiveautomation.ignition.common.execution.PollingBlockingTask

onStartup, setRate, submitIfIdle

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

PerspectivePollingBlockingTask

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

PerspectivePollingBlockingTask

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

Method Detail

getInitialRate

protected long getInitialRate()

Description copied from class: PollingBlockingTask

Default implementation returns the rate from the constructor, but provides a place for subclasses to re-define the rate on startup if necessary.

Overrides:

getInitialRate in class PollingBlockingTask

onShutdown

protected void onShutdown()

Overrides:

onShutdown in class PollingBlockingTask

onRefreshRateChange

protected void onRefreshRateChange(PropertyTreeChangeEvent event)

getRefreshRateFromProps

protected long getRefreshRateFromProps()

parseLong

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