seda.sandStorm.lib.aDisk
Class AFileTPTM
java.lang.Object
seda.sandStorm.internal.TPSThreadManager
seda.sandStorm.lib.aDisk.AFileTPTM
- All Implemented Interfaces:
- ThreadManagerIF, ProfilableIF, sandStormConst
class AFileTPTM
- extends TPSThreadManager
- implements ThreadManagerIF, ProfilableIF
This is the ThreadManager implementation for AFileTPImpl.
It manages a pool of threads which perform blocking I/O
on disk files; this is a portable implementation and is not
meant to be high performance.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEBUG
private static final boolean DEBUG
- See Also:
- Constant Field Values
fileQ
private FiniteQueue fileQ
numOutstandingRequests
private int numOutstandingRequests
MAX_REQUESTS_PER_FILE
private static final int MAX_REQUESTS_PER_FILE
- See Also:
- Constant Field Values
QUEUE_BLOCK_TIME
private static final int QUEUE_BLOCK_TIME
- See Also:
- Constant Field Values
AFileTPTM
AFileTPTM(ManagerIF mgr,
SystemManagerIF sysmgr)
throws java.lang.Exception
- Throws:
java.lang.Exception
register
public void register(StageWrapperIF stage)
- Register a stage with this thread manager.
- Specified by:
register
in interface ThreadManagerIF
- Overrides:
register
in class TPSThreadManager
fileReady
public void fileReady(AFileTPImpl impl)
- Indicate that a file has pending events.
profileSize
public int profileSize()
- Description copied from interface:
ProfilableIF
- Return the size of the object being profiled.
- Specified by:
profileSize
in interface ProfilableIF