Package org.epics.archiverappliance.engine.pv

Class JCACommandThread

java.lang.Object

java.lang.Thread

org.epics.archiverappliance.engine.pv.JCACommandThread

All Implemented Interfaces:

Runnable

public class JCACommandThread
extends Thread

Version:

Initial version:CSS, 4-Jun-2012, Luofeng Li:added codes to support for the new archiver

Author:

Kay Kasemir

Nested Class Summary

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
JCACommandThread(int commandThreadId)	Construct, but don't start the thread.

Method Summary

Modifier and Type	Method	Description
void	addCommand(Runnable command)	Add a command to the queue.
gov.aps.jca.Channel	createChannel(String name, gov.aps.jca.event.ConnectionListener conn_callback)
boolean	doesChannelContextMatchThreadContext(gov.aps.jca.Channel channel)
List<gov.aps.jca.Channel>	getAllChannelsForPV(String pvNameOnly)
int	getChannelsWithPendingSearchRequests()
List<Map<String,String>>	getCommandThreadDetails()
int	getTotalChannelCount()
boolean	hasContextBeenInitialized()
void	run()
void	shutdown()	Stop the thread and wait for it to finish
void	start()	Version of start that may be called multiple times.

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, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Details

JCACommandThread

public JCACommandThread(int commandThreadId)
                 throws ConfigException

Construct, but don't start the thread.

Throws:

ConfigException

See Also:

• start()

Method Details

start

public void start()

Version of start that may be called multiple times.

The thread must only be started after the first PV has been created. Otherwise, if flush is called without PVs, JNI JCA reports pthread errors.

NOP when already running

Overrides:

start in class Thread

shutdown

public void shutdown()
              throws InterruptedException

Stop the thread and wait for it to finish

Throws:

InterruptedException -  

createChannel

public gov.aps.jca.Channel createChannel(String name,
 gov.aps.jca.event.ConnectionListener conn_callback)
                                  throws IllegalStateException,
gov.aps.jca.CAException

Throws:

IllegalStateException

gov.aps.jca.CAException

hasContextBeenInitialized

public boolean hasContextBeenInitialized()

doesChannelContextMatchThreadContext

public boolean doesChannelContextMatchThreadContext(gov.aps.jca.Channel channel)

getAllChannelsForPV

public List<gov.aps.jca.Channel> getAllChannelsForPV(String pvNameOnly)

getTotalChannelCount

public int getTotalChannelCount()

getChannelsWithPendingSearchRequests

public int getChannelsWithPendingSearchRequests()

addCommand

public void addCommand(Runnable command)

Add a command to the queue. add some cap on the command queue? At least for value updates?

Parameters:

command - Runnable

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

getCommandThreadDetails

public List<Map<String,String>> getCommandThreadDetails()