org.edg.info
Class TimeoutThread

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.edg.info.TimeoutThread
All Implemented Interfaces:
java.lang.Runnable

public class TimeoutThread
extends java.lang.Thread

Thread to keep track of timeouts for consumers.


Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
TimeoutThread()
          Creates a new TimeoutThread object.
 
Method Summary
 void add(ConsumerInstance consumerInstance, long timeout, int queryNum)
           
 void close()
           
 void remove(ConsumerInstance consumerInstance)
           
 void run()
          Waits for correct time interval then aborts each "registered" consumer.
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

TimeoutThread

public TimeoutThread()
Creates a new TimeoutThread object.

Method Detail

run

public void run()
Waits for correct time interval then aborts each "registered" consumer.


add

public void add(ConsumerInstance consumerInstance,
                long timeout,
                int queryNum)

close

public void close()

remove

public void remove(ConsumerInstance consumerInstance)