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