seda.sandStorm.internal
Class TPSThreadManager
java.lang.Object
seda.sandStorm.internal.TPSThreadManager
- All Implemented Interfaces:
- sandStormConst, ThreadManagerIF
- Direct Known Subclasses:
- AFileTPTM
- public class TPSThreadManager
- extends java.lang.Object
- implements ThreadManagerIF, sandStormConst
TPSThreadManager provides a threadpool-per-source-per-stage thread
manager implementation.
- Author:
- Matt Welsh
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
mgr
protected ManagerIF mgr
config
protected SandstormConfig config
srTbl
protected java.util.Hashtable srTbl
sizeController
protected ThreadPoolController sizeController
TPSThreadManager
public TPSThreadManager(ManagerIF mgr)
TPSThreadManager
public TPSThreadManager(ManagerIF mgr,
boolean initialize)
register
public void register(StageWrapperIF stage)
- Register a stage with this thread manager.
- Specified by:
register
in interface ThreadManagerIF
deregister
public void deregister(StageWrapperIF stage)
- Deregister a stage with this thread manager.
- Specified by:
deregister
in interface ThreadManagerIF
deregisterAll
public void deregisterAll()
- Stop the thread manager and all threads managed by it.
- Specified by:
deregisterAll
in interface ThreadManagerIF