More information: http://www.cs.berkeley.edu/~mdw/proj/seda/

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

Inner Class Summary
 class TPSThreadManager.stageRunnable
          Internal class representing the Runnable for a single stage.
 
Field Summary
protected  SandstormConfig config
           
protected  ManagerIF mgr
           
protected  ThreadPoolController sizeController
           
protected  java.util.Hashtable srTbl
           
 
Fields inherited from interface seda.sandStorm.internal.sandStormConst
MAJOR_VERSION, MINOR_VERSION, VERSION_STRING, WELCOME_STRING
 
Constructor Summary
TPSThreadManager(ManagerIF mgr)
           
TPSThreadManager(ManagerIF mgr, boolean initialize)
           
 
Method Summary
 void deregister(StageWrapperIF stage)
          Deregister a stage with this thread manager.
 void deregisterAll()
          Stop the thread manager and all threads managed by it.
 void register(StageWrapperIF stage)
          Register a stage with this thread manager.
 
Methods inherited from class java.lang.Object
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

mgr

protected ManagerIF mgr

config

protected SandstormConfig config

srTbl

protected java.util.Hashtable srTbl

sizeController

protected ThreadPoolController sizeController
Constructor Detail

TPSThreadManager

public TPSThreadManager(ManagerIF mgr)

TPSThreadManager

public TPSThreadManager(ManagerIF mgr,
                        boolean initialize)
Method Detail

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

More information: http://www.cs.berkeley.edu/~mdw/proj/seda/