edu.dmi
Class GenericMessageBroadcaster
java.lang.Object
|
+--edu.dmi.GenericMessageBroadcaster
- Direct Known Subclasses:
- UpdateBroadcaster
- public class GenericMessageBroadcaster
- extends java.lang.Object
Methods inherited from class java.lang.Object |
,
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
registerNatives,
toString,
wait,
wait,
wait |
fNumInvokers
private int fNumInvokers
fPriority
private int fPriority
invokerPool
private java.util.Vector invokerPool
invokerPoolB
private java.util.Vector invokerPoolB
invokerPoolLock
private java.lang.Object invokerPoolLock
invokerPoolBLock
private java.lang.Object invokerPoolBLock
fMaxProcesstime
private long fMaxProcesstime
fControl
private java.lang.Thread fControl
vGenericMessages
private java.util.Vector vGenericMessages
TEN_SECONDS
public static final long TEN_SECONDS
THIRTY_SECONDS
public static final long THIRTY_SECONDS
SIXTY_SECONDS
public static final long SIXTY_SECONDS
SWEEP_RATE
public static int SWEEP_RATE
vGenericMessageLock
java.lang.Object vGenericMessageLock
listeners
java.util.Vector listeners
listenersLock
java.lang.Object listenersLock
GenericMessageBroadcaster
public GenericMessageBroadcaster(int priority,
int num)
start
public void start()
stop
public void stop()
broadcastGenericMessage
public void broadcastGenericMessage(GenericMessage gm)
- Parameters:
GenericMessage
-
waitForBroadcast
public void waitForBroadcast(Invoker n)
throws java.lang.InterruptedException
addListener
public void addListener(java.lang.Object l)
removeListener
public void removeListener(java.lang.Object l)
getListeners
public java.util.Enumeration getListeners()
getNumberOfListeners
public int getNumberOfListeners()
getFirstListener
public java.lang.Object getFirstListener()
getNumThreads
public int getNumThreads()
setMaxProcesstime
public void setMaxProcesstime(long t)
getMaxProcesstime
public long getMaxProcesstime()
checkForTimeout
void checkForTimeout(long curr,
long max)