Package de.aristaflow.adept2.util.threading

Class CachedThreadPoolExecutor

java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
de.aristaflow.adept2.util.threading.AFThreadPoolExecutor
de.aristaflow.adept2.util.threading.CachedThreadPoolExecutor
All Implemented Interfaces:
Executor, ExecutorService
Direct Known Subclasses:
AbstractObjectSpecificExecutor
public class CachedThreadPoolExecutor extends AFThreadPoolExecutor
A ThreadPoolExecutor which comes in two flavours:
    • Creates new threads to run a new task, if the amount of threads is less than the corePoolSize. Core pool threads will be reused and will live until the thread pool is shutdown.
    • Creates new threads, if the amount of threads is less than the maxPoolSize. These threads will terminate after 60 seconds, if the workload reduces.
    • If there is more work than the amount of maximum threads, the tasks will be put into an unbounded queue.
    • Creates new threads to run a new task, if the amount of threads is less than the pool size. Pool threads will terminate after being idle for 60 seconds.
    • If there is more work than the pool size, the tasks will be put into an unbounded queue.
    • The queue is a priority queue which sorts based on a specific comparator.

  • Field Details

    • realCoreSize

      protected final int realCoreSize
      The normal core size of the pool.

    • realMaxSize

      protected final int realMaxSize
      The maximum size of the pool.

    • fullSize

      protected final AtomicBoolean fullSize
      Whether the pool (its amount of core threads) is set to the maximum size.

    • workSize

      protected final AtomicInteger workSize
      The amount of work currently in the pool. If this exceeds the normal core pool size, the core pool size is increased to the maximum size of the pool. If the amount of work goes below the normal core pool size, the core pool size will be reduced again.

  • Constructor Details

    • CachedThreadPoolExecutor

      public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory)
      Creates a new CachedThreadPoolExecutor with the given initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      threadFactory - The factory to use when the executor creates a new thread.

    • CachedThreadPoolExecutor

      @Deprecated(since="14.4.0", forRemoval=true) public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Use CachedThreadPoolExecutor(int, int, Adept2ThreadFactory) instead.
      Creates a new CachedThreadPoolExecutor with the given initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      prestart - Whether all core threads should be prestarted.
      threadFactory - The factory to use when the executor creates a new thread.

    • CachedThreadPoolExecutor

      public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics)
      Creates a new CachedThreadPoolExecutor with the designated initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value, idle threads will terminate after 60 seconds. If the work load exceeds the pool size, work will be put into a queue.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      threadFactory - The factory to use when the executor creates a new thread.
      queueLimitPoolStatistics - The amount of tasks in the queue before warnings will be logged. Use -1 to use the default limits.
      minLogLevelPoolStatistics - The log level which need to be reached for logging pool statistics. Pool statistics logs with a lower log level will be ignored.

    • CachedThreadPoolExecutor

      @Deprecated(since="14.4.0", forRemoval=true) public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Use CachedThreadPoolExecutor(int, int, Adept2ThreadFactory, int, Level) instead.
      Creates a new CachedThreadPoolExecutor with the designated initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value, idle threads will terminate after 60 seconds. If the work load exceeds the pool size, work will be put into a queue.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      prestart - Whether all core threads should be prestarted.
      threadFactory - The factory to use when the executor creates a new thread.
      queueLimitPoolStatistics - The amount of tasks in the queue before warnings will be logged. Use -1 to use the default limits.
      minLogLevelPoolStatistics - The log level which need to be reached for logging pool statistics. Pool statistics logs with a lower log level will be ignored.

    • CachedThreadPoolExecutor

      public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics)
      Creates a new CachedThreadPoolExecutor with the designated initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value, idle threads will terminate after 60 seconds. If the work load exceeds the pool size, work will be put into a queue. The queue itself prioritises work using the designated comparator.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      comparator - The comparator used to determine the priority of work.
      threadFactory - The factory to use when the executor creates a new thread.
      minLogLevelPoolStatistics - The log level which need to be reached for logging pool statistics. Pool statistics logs with a lower log level will be ignored.

    • CachedThreadPoolExecutor

      @Deprecated(since="14.4.0", forRemoval=true) public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, Level minLogLevelPoolStatistics)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Use CachedThreadPoolExecutor(int, int, Comparator, Adept2ThreadFactory, Level) instead.
      Creates a new CachedThreadPoolExecutor with the designated initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value, idle threads will terminate after 60 seconds. If the work load exceeds the pool size, work will be put into a queue. The queue itself prioritises work using the designated comparator.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      prestart - Whether all core threads should be prestarted.
      comparator - The comparator used to determine the priority of work.
      threadFactory - The factory to use when the executor creates a new thread.
      minLogLevelPoolStatistics - The log level which need to be reached for logging pool statistics. Pool statistics logs with a lower log level will be ignored.

    • CachedThreadPoolExecutor

      public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics)
      Creates a new CachedThreadPoolExecutor with the designated initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value, idle threads will terminate after 60 seconds. If the work load exceeds the pool size, work will be put into a queue. The queue itself prioritises work using the designated comparator.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      comparator - The comparator used to determine the priority of work.
      threadFactory - The factory to use when the executor creates a new thread.
      queueLimitPoolStatistics - The amount of tasks in the queue before warnings will be logged. Use -1 to use the default limits.
      minLogLevelPoolStatistics - The log level which need to be reached for logging pool statistics. Pool statistics logs with a lower log level will be ignored.

    • CachedThreadPoolExecutor

      @Deprecated(since="14.4.0", forRemoval=true) public CachedThreadPoolExecutor(int corePoolSize, int maxPoolSize, boolean prestart, Comparator<? super Runnable> comparator, Adept2ThreadFactory threadFactory, int queueLimitPoolStatistics, Level minLogLevelPoolStatistics)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Use CachedThreadPoolExecutor(int, int, Comparator, Adept2ThreadFactory, int, Level) instead.
      Creates a new CachedThreadPoolExecutor with the designated initial parameters and default rejected execution handler. The cached thread pool executor increases the corePoolSize to the maxPoolSize if the work load exceeds the amount of core threads. If the work load declines, the corePoolSize will be reduced to the original value, idle threads will terminate after 60 seconds. If the work load exceeds the pool size, work will be put into a queue. The queue itself prioritises work using the designated comparator.
      Parameters:
      corePoolSize - The number of threads to keep in the pool, even if they are idle.
      maxPoolSize - The maximum number of threads to allow in the pool.
      prestart - Whether all core threads should be prestarted.
      comparator - The comparator used to determine the priority of work.
      threadFactory - The factory to use when the executor creates a new thread.
      queueLimitPoolStatistics - The amount of tasks in the queue before warnings will be logged. Use -1 to use the default limits.
      minLogLevelPoolStatistics - The log level which need to be reached for logging pool statistics. Pool statistics logs with a lower log level will be ignored.

  • Method Details