public class MessageDrivenThread extends CloseableThread
closing
Constructor and Description |
---|
MessageDrivenThread(java.lang.ThreadGroup group,
java.lang.String threadName) |
MessageDrivenThread(java.lang.ThreadGroup group,
java.lang.String threadName,
MessageDrivenThreadListener listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
doMessageReceived(java.lang.Object o)
subclass should override to do message processing.
|
void |
post(java.lang.Object msg) |
void |
run() |
void |
setListener(MessageDrivenThreadListener listener) |
close, isClosed, isClosing, setClosed, setClosing, waitUntilClosed
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
public MessageDrivenThread(java.lang.ThreadGroup group, java.lang.String threadName, MessageDrivenThreadListener listener)
public MessageDrivenThread(java.lang.ThreadGroup group, java.lang.String threadName)
public void setListener(MessageDrivenThreadListener listener)
public void post(java.lang.Object msg) throws java.lang.InterruptedException
java.lang.InterruptedException
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
protected void doMessageReceived(java.lang.Object o)