Class 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.
    • Nested Class Summary

      • Nested classes/interfaces inherited from class java.lang.Thread

        java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
    • 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 queue
      protected int n
      This is the number of entries we want to stuff at any one time.
      protected java.lang.String processID
      Process ID
      protected WorkerResetManager resetManager
      Worker thread pool reset manager
      • Fields inherited from class java.lang.Thread

        MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
    • 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
      • Methods inherited from class java.lang.Object

        equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Field Detail

      • 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
    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
        Overrides:
        run in class java.lang.Thread