Package edu.jas.util
Class Broadcaster
- java.lang.Object
-
- java.lang.Thread
-
- edu.jas.util.Broadcaster
-
- All Implemented Interfaces:
java.lang.Runnable
class Broadcaster extends java.lang.Thread
Thread for broadcasting all incoming objects to the list clients.
-
-
Constructor Summary
Constructors Constructor Description Broadcaster(SocketChannel s, java.util.List p, Counter le, java.util.SortedMap<Counter,java.lang.Object> sm)
Broadcaster.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
broadcast(java.lang.Object o)
broadcast.void
closeChannel()
closeChannel.void
run()
run.void
sendChannel(java.lang.Object n, java.lang.Object o)
sendChannel.java.lang.String
toString()
toString.-
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, yield
-
-
-
-
Field Detail
-
logger
private static final org.apache.logging.log4j.Logger logger
-
channel
private final SocketChannel channel
-
bcaster
private final java.util.List bcaster
-
listElem
private Counter listElem
-
theList
private final java.util.SortedMap<Counter,java.lang.Object> theList
-
-
Constructor Detail
-
Broadcaster
public Broadcaster(SocketChannel s, java.util.List p, Counter le, java.util.SortedMap<Counter,java.lang.Object> sm)
Broadcaster.- Parameters:
s
- SocketChannel to use.p
- list of broadcasters.le
- countersm
- SortedMap with counter value pairs.
-
-
Method Detail
-
closeChannel
public void closeChannel()
closeChannel.
-
sendChannel
public void sendChannel(java.lang.Object n, java.lang.Object o) throws java.io.IOException
sendChannel.- Parameters:
n
- counter.o
- value.- Throws:
java.io.IOException
-
broadcast
public void broadcast(java.lang.Object o)
broadcast.- Parameters:
o
- object to store and send.
-
run
public void run()
run.- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
toString
public java.lang.String toString()
toString.- Overrides:
toString
in classjava.lang.Thread
- Returns:
- a string representation of this.
-
-