1. 介绍

线程的池化技术，减少线程在创建和销毁的资源消耗；节约内存、避免“过渡切换问题”；

1.1 重要参数介绍

  1. // 线程池构造方法
  2. public ThreadPoolExecutor(int corePoolSize,
  3.                           int maximumPoolSize,
  4.                           long keepAliveTime,
  5.                           TimeUnit unit,
  6.                           BlockingQueue<Runnable> workQueue,
  7.                           ThreadFactory threadFactory
  8.                           ) {
  • coreSize: 核心线程数，线程池默认的线程数量，达到此数量后，新线程将加入等待队列；
  • maximumPoolSize: 最大线程数，JDK自带线程池，队列满了后，新增线程的最大数目；
  • keepAliveTime： 与unit 一同使用，线程达到最大线程数后，无活跃线程回收的时间；
  • unit：
  • workQueue：线程等待队列；
  • ThreadFactory: 执行器创建新线程时使用的工厂;

1.2 线程池生命周期

假设有持续不断的任务一直入队列，队列的生命周期如下：

线程池 - 图1

第一阶段：线程池预热，将线程数创建至coreSize数量， 任务不断进来，达到coreSize数量后，新进来任务移入等待队列，进入第二阶段，当队列已满，仍有任务加进来，开始新增线程数至maxSize数量；此时进入第三阶段，此时还有任务进来；执行失败处理策略；

2. 使用推荐

阿里开发手册

线程池 - 图2

线程个数设置推荐

按照任务的类型设置如下：

N:cpu核心数

CPU密集型：N+1

IO密集型：2N+1

3. 自带线程池介绍

名称 特点
newCachedThreadPool 如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程
newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
newScheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

阻塞队列：

线程池 - 图3

4. 常用线程池

newFixedThreadPool

newScheduledThreadPool

newSingleThreadExecutor

newCachedThreadPool

创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。

5. 使用案例

【自我使用案例】：视频渲染服务的资源获取整合json, 通过自定义线程池 + CounttDownLatch 性能提升明显；时间整体下降为原有时间的1/3;

线程池配置代码如下：

  2.  /**
  3.   * CPU核心数
  4.   */
  5. private static int CPU_CORE_SIZE = Runtime.getRuntime().availableProcessors();
  7. ExecutorService threadPool = new ThreadPoolExecutor(CPU_CORE_SIZE * 2 ,CPU_CORE_SIZE * 2,0L,TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(CAPACITY));

时间对比如下：

线程池 - 图4

参见