Class ExpireStufferThread
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.manifoldcf.crawler.system.ExpireStufferThread
-
- All Implemented Interfaces:
java.lang.Runnable
public class ExpireStufferThread extends java.lang.Thread
This class represents the stuffer thread. This thread's job is to request documents from the database and add them to the document queue. The thread then sleeps until the document queue is empty again.
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
_rcsid
protected DocumentCleanupQueue
documentQueue
This is a reference to the static main document expiration queueprotected int
n
This is the number of entries we want to stuff at any one time.protected java.lang.String
processID
Process IDprotected WorkerResetManager
resetManager
Worker thread pool reset manager
-
Constructor Summary
Constructors Constructor Description ExpireStufferThread(DocumentCleanupQueue documentQueue, int n, WorkerResetManager resetManager, java.lang.String processID)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
_rcsid
public static final java.lang.String _rcsid
- See Also:
- Constant Field Values
-
documentQueue
protected final DocumentCleanupQueue documentQueue
This is a reference to the static main document expiration queue
-
resetManager
protected final WorkerResetManager resetManager
Worker thread pool reset manager
-
n
protected final int n
This is the number of entries we want to stuff at any one time.
-
processID
protected final java.lang.String processID
Process ID
-
-
Constructor Detail
-
ExpireStufferThread
public ExpireStufferThread(DocumentCleanupQueue documentQueue, int n, WorkerResetManager resetManager, java.lang.String processID) throws ManifoldCFException
Constructor.- Parameters:
documentQueue
- is the document queue we'll be stuffing.n
- represents the number of threads that will be processing queued stuff, NOT the number of documents to be done at once!- Throws:
ManifoldCFException
-
-