|
FreeHEP API Version current |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object hep.aida.ref.remote.RemoteServerQueue
This is thread-safe queue for UpdateEvents. Events can be accumulated in the queue and then retrieved in one chunk. Mainly used on the server side. If client != null new thread will be started with this queue to send updates to the client.
Field Summary | |
protected boolean |
blocking
|
protected Object |
blockingLock
|
protected AidaTreeClient |
client
|
protected boolean |
hold
|
protected List |
holdQueue
|
protected boolean |
keepRunning
|
protected List |
queue
|
protected Logger |
remoteLogger
|
Constructor Summary | |
RemoteServerQueue()
Creates a new instance of UpdatableQueue |
|
RemoteServerQueue(AidaTreeClient client)
|
Method Summary | |
protected void |
addToQueue(AidaUpdateEvent event)
This method adds event to the queue and can do some cleanup, like remove multiple update events for the same path (not implemented yet), etc. |
void |
close()
Once the RemoteServerQueue is closed, it can not be restarted again. |
AidaUpdateEvent[] |
getEvents()
Returns the array of events that are currently in the queue. |
boolean |
isBlocking()
|
void |
run()
In Duplex mode sends updates to AidaTreeClient |
void |
schedule(AidaUpdateEvent event)
Add events to the queue. |
void |
setBlocking(boolean b)
|
void |
setHold(boolean h)
|
int |
size()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected AidaTreeClient client
protected List queue
protected List holdQueue
protected boolean keepRunning
protected boolean blocking
protected Object blockingLock
protected boolean hold
protected Logger remoteLogger
Constructor Detail |
public RemoteServerQueue()
public RemoteServerQueue(AidaTreeClient client)
Method Detail |
public void setBlocking(boolean b)
public boolean isBlocking()
public void close()
public void setHold(boolean h)
public int size()
public void schedule(AidaUpdateEvent event)
public AidaUpdateEvent[] getEvents()
protected void addToQueue(AidaUpdateEvent event)
public void run()
run
in interface Runnable
|
FreeHEP API Version current |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |