faust.sacha.web.bot.spider.event
Class QueueManager

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--faust.sacha.web.bot.spider.event.ThreadEventManager
              |
              +--faust.sacha.web.bot.spider.event.QueueManager
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
GetDataManager, GetInfoManager

public abstract class QueueManager
extends ThreadEventManager


Field Summary
protected  ProcessBroker m_broker
           
protected  UrlQInt m_queue
           
 
Fields inherited from class faust.sacha.web.bot.spider.event.ThreadEventManager
m_state
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
QueueManager(java.lang.String name, UrlQInt queue, ProcessBroker broker)
           
 
Method Summary
protected  void addThread()
           
 int getNbThreads()
           
protected abstract  void process(URLData url)
           
 void receiveEvent(ThreadEvent event)
           
protected  void removeThread()
           
 void run()
           
 
Methods inherited from class faust.sacha.web.bot.spider.event.ThreadEventManager
addToListeners, getState, sendEvent, sendEventAll, setState, stopAllListenningThreads
 
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

m_queue

protected UrlQInt m_queue

m_broker

protected ProcessBroker m_broker
Constructor Detail

QueueManager

public QueueManager(java.lang.String name,
                    UrlQInt queue,
                    ProcessBroker broker)
Method Detail

run

public void run()
Specified by:
run in interface java.lang.Runnable
Overrides:
run in class ThreadEventManager

process

protected abstract void process(URLData url)

addThread

protected void addThread()

removeThread

protected void removeThread()

getNbThreads

public int getNbThreads()

receiveEvent

public void receiveEvent(ThreadEvent event)
Overrides:
receiveEvent in class ThreadEventManager