线程池常见参数

/**
 * 用给定的初始参数创建一个新的ThreadPoolExecutor。
 */
public ThreadPoolExecutor(int corePoolSize,//线程池的核心线程数量
                          int maximumPoolSize,//线程池的最大线程数
                          long keepAliveTime,//当线程数大于核心线程数时，多余的空闲线程存活的最长时间
                          TimeUnit unit,//时间单位
                          BlockingQueue<Runnable> workQueue,//任务队列，用来储存等待执行任务的队列
                          ThreadFactory threadFactory,//线程工厂，用来创建线程，一般默认即可
                          RejectedExecutionHandler handler//拒绝策略，当提交的任务过多而不能及时处理时，我们可以定制策略来处理任务
                           ) {
    if (corePoolSize < 0 ||
        maximumPoolSize <= 0 ||
        maximumPoolSize < corePoolSize ||
        keepAliveTime < 0)
        throw new IllegalArgumentException();
    if (workQueue == null || threadFactory == null || handler == null)
        throw new NullPointerException();
    this.corePoolSize = corePoolSize;
    this.maximumPoolSize = maximumPoolSize;
    this.workQueue = workQueue;
    this.keepAliveTime = unit.toNanos(keepAliveTime);
    this.threadFactory = threadFactory;
    this.handler = handler;
}

• ThreadPoolExecutor3个最重要参数：

  • corePoolSize：任务队列未达到队列容量时，最大可以同时运行的线程数量
  • maximumPoolSize：任务队列达到队列容量时，当前可以同时运行的线程数量变为最大线程数
  • workQueue：新任务来的时候会先判断是否达到核心线程数，如果达到，新任务就会被存放在队列中

• ThreadPoolExecutor其他参数：

  • keepAliveTime：当线程池中的线程数量大于corePoolSize，即有非核心线程（线程池中核心线程以外的线程）时，这些非核心线程空闲后不会立即销毁，而是会等待，直到等待的时间超过了keepAliveTime才会被回收销毁
  • unit：keepAliveTime的时间单位
  • threadFactory：线程工厂，用来创建线程，一般默认即可
  • handler：拒绝策略，当提交的任务过多而不能及时处理时，我们可以定制策略来处理任务

• 线程池默认不会回收核心线程，但是如果线程池被用于周期性使用的场景，且频率不高，可以考虑使用allowCoreThreadTimeOut(boolean value)参数设置为true，这样就会回收空闲的核心线程，时间间隔为keepAliveTime

  public void allowCoreThreadTimeOut(boolean value) {
      // 核心线程的 keepAliveTime 必须大于 0 才能启用超时机制
      if (value && keepAliveTime <= 0) {
          throw new IllegalArgumentException("Core threads must have nonzero keep alive times");
      }
      // 设置 allowCoreThreadTimeOut 的值
      if (value != allowCoreThreadTimeOut) {
          allowCoreThreadTimeOut = value;
          // 如果启用了超时机制，清理所有空闲的线程，包括核心线程
          if (value) {
              interruptIdleWorkers();
          }
      }
  }