stella.net.gregor

Class CommunicationHandler.SenderThread

java.lang.Object

java.lang.Thread

stella.net.gregor.CommunicationHandler.SenderThread

All Implemented Interfaces:

Runnable

Enclosing class:

CommunicationHandler

private class CommunicationHandler.SenderThread
extends Thread

This thread performs the sending of a message. As soon as a message has been entered in the enclosing class's dequeue, this thread is notified and transfers the message to the packet output.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	cancel If true, we cancel on next invocation.
private PacketOutputStream	out This is the output stream to serialize the messages to.
private long	wakeup This is the regular time interval we wake up checking for cancel.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SenderThread(PacketOutputStream socket, long vulture)

Method Summary

Modifier and Type	Method and Description
void	cancel() We set the cancel flag to true, this will terminate the sender thread on next wakeup.
void	run() While alive, the sender permanently watches the parental queue for element insertion.

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

cancel

private boolean cancel

If true, we cancel on next invocation.

out

private final PacketOutputStream out

This is the output stream to serialize the messages to.

wakeup

private final long wakeup

This is the regular time interval we wake up checking for cancel.

Constructor Detail

SenderThread

private SenderThread(PacketOutputStream socket,
                     long vulture)

Method Detail

run

public void run()

While alive, the sender permanently watches the parental queue for element insertion.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

cancel

public void cancel()

We set the cancel flag to true, this will terminate the sender thread on next wakeup.