Package deltix.qsrv.hf.pub.util
Class LiveCursorWatcher
- java.lang.Object
-
- java.lang.Thread
-
- deltix.qsrv.hf.pub.util.LiveCursorWatcher
-
- All Implemented Interfaces:
deltix.util.lang.Disposable
,java.io.Closeable
,java.lang.AutoCloseable
,java.lang.Runnable
- Direct Known Subclasses:
LiveCursorWatcherEx
public class LiveCursorWatcher extends java.lang.Thread implements deltix.util.lang.Disposable
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
LiveCursorWatcher.MessageListener
-
Field Summary
Fields Modifier and Type Field Description protected TickCursor
cursor
-
Constructor Summary
Constructors Constructor Description LiveCursorWatcher(TickCursor cursor, LiveCursorWatcher.MessageListener listener)
LiveCursorWatcher(TickCursor cursor, LiveCursorWatcher.MessageListener listener, boolean startThread)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
interrupt()
void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
cursor
protected final TickCursor cursor
-
-
Constructor Detail
-
LiveCursorWatcher
public LiveCursorWatcher(TickCursor cursor, LiveCursorWatcher.MessageListener listener)
-
LiveCursorWatcher
public LiveCursorWatcher(TickCursor cursor, LiveCursorWatcher.MessageListener listener, boolean startThread)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
interrupt
public void interrupt()
- Overrides:
interrupt
in classjava.lang.Thread
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfacedeltix.util.lang.Disposable
-
-