Package edu.jas.util
Class DHTBroadcaster<K>
- java.lang.Object
-
- java.lang.Thread
-
- edu.jas.util.DHTBroadcaster<K>
-
- All Implemented Interfaces:
java.lang.Runnable
class DHTBroadcaster<K> extends java.lang.Thread
Thread for broadcasting all incoming objects to the list clients.
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.List<DHTBroadcaster<K>>
bcaster
private SocketChannel
channel
private static boolean
debug
(package private) boolean
goon
private static org.apache.logging.log4j.Logger
logger
private java.util.SortedMap<K,DHTTransport>
theList
-
Constructor Summary
Constructors Constructor Description DHTBroadcaster(SocketChannel s, java.util.List<DHTBroadcaster<K>> bc, java.util.SortedMap<K,DHTTransport> sm)
DHTBroadcaster.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
broadcast(DHTTransport o)
broadcast.void
closeChannel()
closeChannel.void
run()
run.void
sendChannel(DHTTransport tc)
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
-
debug
private static final boolean debug
-
channel
private final SocketChannel channel
-
bcaster
private final java.util.List<DHTBroadcaster<K>> bcaster
-
theList
private final java.util.SortedMap<K,DHTTransport> theList
-
goon
volatile boolean goon
-
-
Constructor Detail
-
DHTBroadcaster
public DHTBroadcaster(SocketChannel s, java.util.List<DHTBroadcaster<K>> bc, java.util.SortedMap<K,DHTTransport> sm)
DHTBroadcaster.- Parameters:
s
- SocketChannel to use.bc
- list of broadcasters.sm
- SortedMap with key value pairs.
-
-
Method Detail
-
closeChannel
public void closeChannel()
closeChannel.
-
sendChannel
public void sendChannel(DHTTransport tc) throws java.io.IOException
sendChannel.- Parameters:
tc
- DHTTransport.- Throws:
java.io.IOException
-
broadcast
public void broadcast(DHTTransport o)
broadcast.- Parameters:
o
- DHTTransport element to broadcast.
-
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.
-
-