Package one.nio.server

Class CleanupThread

  • All Implemented Interfaces:
    java.lang.Runnable
    public class CleanupThread
extends BatchThread

    • 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
      private long keepAlive  
      private static org.slf4j.Logger log  
      private SelectorThread[] selectors  

      • 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
      long getKeepAlive()  
      void run()  
      void setKeepAlive​(long keepAlive)  
      void shutdown()  
      void update​(SelectorThread[] selectors, long keepAlive)  
      private long waitKeepAlive()  

      • 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

      • log

        private static final org.slf4j.Logger log

      • keepAlive

        private volatile long keepAlive

    • Constructor Detail

      • CleanupThread

        public CleanupThread​(SelectorThread[] selectors,
                     long keepAlive)

    • Method Detail

      • shutdown

        public void shutdown()

      • getKeepAlive

        public long getKeepAlive()

      • setKeepAlive

        public void setKeepAlive​(long keepAlive)

      • update

        public void update​(SelectorThread[] selectors,
                   long keepAlive)

      • waitKeepAlive

        private long waitKeepAlive()
                    throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException

      • run

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