Class StandardThreadExecutor

    • Field Detail

      • threadPriority

        protected int threadPriority
        Default thread priority
      • daemon

        protected boolean daemon
        Run threads in daemon or non-daemon state
      • namePrefix

        protected String namePrefix
        Default name prefix for the thread name
      • maxThreads

        protected int maxThreads
        max number of threads
      • minSpareThreads

        protected int minSpareThreads
        min number of threads
      • maxIdleTime

        protected int maxIdleTime
        idle time in milliseconds
      • name

        protected String name
        the name of this thread pool
      • maxQueueSize

        protected int maxQueueSize
        The maximum number of elements that can queue up before we reject them
      • threadRenewalDelay

        protected long threadRenewalDelay
        After a context is stopped, threads in the pool are renewed. To avoid renewing all threads at the same time, this delay is observed between 2 threads being renewed.
    • Constructor Detail

      • StandardThreadExecutor

        public StandardThreadExecutor()
    • Method Detail

      • contextStopping

        public void contextStopping()
      • getThreadPriority

        public int getThreadPriority()
      • isDaemon

        public boolean isDaemon()
      • getNamePrefix

        public String getNamePrefix()
      • getMaxIdleTime

        public int getMaxIdleTime()
      • getMinSpareThreads

        public int getMinSpareThreads()
      • setThreadPriority

        public void setThreadPriority​(int threadPriority)
      • setDaemon

        public void setDaemon​(boolean daemon)
      • setNamePrefix

        public void setNamePrefix​(String namePrefix)
      • setMaxIdleTime

        public void setMaxIdleTime​(int maxIdleTime)
      • setMaxThreads

        public void setMaxThreads​(int maxThreads)
      • setMinSpareThreads

        public void setMinSpareThreads​(int minSpareThreads)
      • setName

        public void setName​(String name)
      • setMaxQueueSize

        public void setMaxQueueSize​(int size)
      • getMaxQueueSize

        public int getMaxQueueSize()
      • getThreadRenewalDelay

        public long getThreadRenewalDelay()
      • setThreadRenewalDelay

        public void setThreadRenewalDelay​(long threadRenewalDelay)
      • getActiveCount

        public int getActiveCount()
        Description copied from interface: ResizableExecutor
        Returns the approximate number of threads that are actively executing tasks.
        Specified by:
        getActiveCount in interface ResizableExecutor
        Returns:
        the number of threads
      • getCompletedTaskCount

        public long getCompletedTaskCount()
      • getCorePoolSize

        public int getCorePoolSize()
      • getLargestPoolSize

        public int getLargestPoolSize()
      • getPoolSize

        public int getPoolSize()
        Description copied from interface: ResizableExecutor
        Returns the current number of threads in the pool.
        Specified by:
        getPoolSize in interface ResizableExecutor
        Returns:
        the number of threads
      • getQueueSize

        public int getQueueSize()
      • resizePool

        public boolean resizePool​(int corePoolSize,
                                  int maximumPoolSize)
        Specified by:
        resizePool in interface ResizableExecutor
      • getDomainInternal

        protected String getDomainInternal()
        Description copied from class: LifecycleMBeanBase
        Method implemented by sub-classes to identify the domain in which MBeans should be registered.
        Specified by:
        getDomainInternal in class LifecycleMBeanBase
        Returns:
        The name of the domain to use to register MBeans.