org.epics.pvmanager.timecache

Class DataRequestThread

java.lang.Object

java.lang.Thread

org.epics.pvmanager.timecache.DataRequestThread

All Implemented Interfaces:

Runnable

public class DataRequestThread
extends Thread

Retrieves chunks from the specified DataSource, channel name and TimeInterval. Polls chunks from the source until the Timestamp of the last received Data is superior to the end of the defined TimeInterval.

Author:

Fred Arnaud (Sopra Group) - ITER

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
DataRequestThread(String channelName, DataSource source, org.epics.util.time.TimeInterval interval)

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(DataRequestListener l) Add a DataRequestListener.
String	getChannelName()
org.epics.util.time.TimeInterval	getInterval()
org.epics.util.time.Timestamp	getLastReceived()
DataSource	getSource()
void	removeListener(DataRequestListener l) Remove a DataRequestListener.
void	run()

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

DataRequestThread

public DataRequestThread(String channelName,
                 DataSource source,
                 org.epics.util.time.TimeInterval interval)
                  throws Exception

Throws:

Exception

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

addListener

public void addListener(DataRequestListener l)

Add a DataRequestListener.

removeListener

public void removeListener(DataRequestListener l)

Remove a DataRequestListener.

getChannelName

public String getChannelName()

getSource

public DataSource getSource()

getInterval

public org.epics.util.time.TimeInterval getInterval()

getLastReceived

public org.epics.util.time.Timestamp getLastReceived()