|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--java.lang.Thread | +--jclass.SleepingThread | +--jvm.entity.TCPIPWriteThread
A thread that reads Messages from a SimpleQueue and writes them
to a stream through a SmartObjectOutputStream AFTER timestamping them
using a internal settable timer.
It blocks if the queue becomes empty and waits for some queue
Messages to appear.
Written: Radu Sion
Version: 1.17x
Source: TCPIPWriteThread.java
Visit
Smart Software
Message
,
SimpleQueue
,
FullException
,
EmptyException
,
TCPIPReadThread
,
SleepingThread
Field Summary | |
Timer |
timestampBase
This timer is used in timestamping the outgoing messages. |
Fields inherited from class jclass.SleepingThread |
DEFAULT_SLEEP |
Fields inherited from class java.lang.Thread |
MAX_PRIORITY,
MIN_PRIORITY,
NORM_PRIORITY |
Constructor Summary | |
TCPIPWriteThread(SmartObjectOutputStream os,
SimpleQueue queue,
int max_messages,
long sleep,
long timestart)
Creates a new TCPIPWriteThread. |
Method Summary | |
protected void |
finalize()
|
boolean |
getActive()
Gets the thread's current status. |
void |
run()
|
void |
setActive(boolean how)
nbsp; Sets the thread's status. |
Methods inherited from class jclass.SleepingThread |
getSleep,
mysleep,
pause,
pause,
setSleep |
Methods inherited from class java.lang.Thread |
activeCount,
checkAccess,
countStackFrames,
currentThread,
destroy,
dumpStack,
enumerate,
getContextClassLoader,
getName,
getPriority,
getThreadGroup,
interrupt,
interrupted,
isAlive,
isDaemon,
isInterrupted,
join,
join,
join,
resume,
setContextClassLoader,
setDaemon,
setName,
setPriority,
sleep,
sleep,
start,
stop,
stop,
suspend,
toString,
yield |
Methods inherited from class java.lang.Object |
clone,
equals,
getClass,
hashCode,
notify,
notifyAll,
wait,
wait,
wait |
Field Detail |
public Timer timestampBase
Constructor Detail |
public TCPIPWriteThread(SmartObjectOutputStream os, SimpleQueue queue, int max_messages, long sleep, long timestart)
os
- The SmartObjectOutputStream to which to writequeue
- The SimpleQueue from which to readmax_messages
- The maximum number of Messages to read (if -1 then reading infinitely)timestart
- The initialization value for the internal timer.Method Detail |
public void setActive(boolean how)
public boolean getActive()
setActive(boolean)
public void run()
protected void finalize()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |