org.jlab.coda.emu

Class Emu.StatusReportingThread

java.lang.Object

java.lang.Thread

org.jlab.coda.emu.Emu.StatusReportingThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Emu

class Emu.StatusReportingThread
extends java.lang.Thread

Class defining thread which reports the EMU status to Run Control.

Java calls to get the time are notoriously slow - System.currentTimeMillis() and .nanoTime(). We implement a low resolution clock here, for things like flushing output channels when there are low rates, which allows other code to avoid calling these expensive methods directly.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
StatusReportingThread()

Method Summary

Modifier and Type	Method and Description
long	getTime() Get the time from System.currentTimeMillis(), but it's updated only every 1/4 seconds or thereabouts.
void	run() Send a status message every 2 (statusReportingPeriod/1000) seconds.
(package private) void	sendStatusMessage() Send a cMsg message with the status of this EMU to run control's cMsg server.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusReportingThread

StatusReportingThread()

Method Detail

getTime

public long getTime()

Get the time from System.currentTimeMillis(), but it's updated only every 1/4 seconds or thereabouts.

Returns:

time from System.currentTimeMillis()

run

public void run()

Send a status message every 2 (statusReportingPeriod/1000) seconds.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

sendStatusMessage

void sendStatusMessage()

Send a cMsg message with the status of this EMU to run control's cMsg server. cMsg messages are not thread-safe when it comes to adding payloads so synchronize this method.