seda.sandStorm.internal
Class TPSThreadManager

java.lang.Object
  seda.sandStorm.internal.TPSThreadManager

All Implemented Interfaces:

ThreadManagerIF, sandStormConst

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.

Nested Class Summary

class

TPSThreadManager.stageRunnable Internal class representing the Runnable for a single stage.

Field Summary

protected SandstormConfig	config
private static boolean	DEBUG
private static boolean	DEBUG_VERBOSE
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

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

DEBUG_VERBOSE

private static final boolean DEBUG_VERBOSE

See Also:

Constant Field Values

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