JAVA 线程池的正确打开方式

JAVA 线程池的正确打开方式

摘要：本文属于原创，欢迎转载，转载请保留出处： https://github.com/jasonGeng88/blog

当前环境

1. jdk == 1.8

Executors 使用的隐患

先来看一段代码，咱们要建立一个固定线程池，假设固定线程数是4。代码以下：

Executors是JAVA并发包中提供的，用来快速建立不一样类型的线程池。

是否是很简单，建立线程池只需一行代码。对于一些我的项目或临时性的项目，这样写确实没什么问题，并且开发速度很快。但在一些大型项目中，这种作法通常是禁止的。

WHY？？？

由于用Executors建立的线程池存在性能隐患，咱们看一下源码就知道，用Executors建立线程池时，使用的队列是new LinkedBlockingQueue<Runnable>()，这是一个无边界队列，若是不断的往里加任务时，最终会致使内存问题，也就是说在项目中因为使用了无边界队列，致使的内存占用的不可控性。下图是不断添加线程任务致使老年代被占满的状况：

固然，除了内存问题，它还存在一些其余的问题，在下面对线程池参数的介绍中会具体说明。

线程池的正确建立方式

其实，问题很好解决。提供的简便方式有局限性，那咱们本身new一个ThreadPoolExecutor，无非多写几行代码而已。

关于ThreadPoolExecutor的具体代码以下：

参数说明：

• corePoolSize：核心线程数；
• maximumPoolSize：最大线程数，即线程池中容许存在的最大线程数；
• keepAliveTime：线程存活时间，对于超过核心线程数的线程，当线程处理空闲状态下，且维持时间达到keepAliveTime时，线程将被销毁；
• unit：keepAliveTime的时间单位
• workQueue：工做队列，用于存在待执行的线程任务；
• threadFactory：建立线程的工厂，用于标记区分不一样线程池所建立出来的线程；
• handler：当到达线程数上限或工做队列已满时的拒绝处理逻辑；

具体代码

• 自定义threadFactory。除了能够自定义建立的线程名称，方便问题排查，在newThread(Runnable r)建立线程的方法中，还能够进行定制化设置，如为线程设置特定上下文等。

• 自定义RejectedExecutionHandler。记录异常信息，选择不一样处理逻辑，有交由当前线程执行任务，有直接抛出异常，再或者等待后继续添加任务等。

• 建立自定义线程池

线程池内在处理逻辑

咱们经过一些例子，来观察一下其内部的处理逻辑。基于上述具体代码，咱们已经建立了一个核心线程数4，最大线程数8，线程存活时间10s，工做队列最大容量为10的一个线程池。

• 初始化线程池：未添加线程任务

  • 这时，线程池中不会建立任何线程，存活线程为0，工做队列为0.

• 未达核心线程数：添加4个线程任务

  • 因为当前存活线程数 <= 核心线程数，因此会建立新的线程。即存活线程为4，工做队列为0.

• 核心线程数已满：添加第5个线程任务

  • 若当前线程池中存在空闲线程，则交由该线程处理。即存活线程为4，工做队列为0.
  • 若当前全部线程处理运行状态，加入工做队列。即存活线程为4，工做队列为1.（注意：此时工做队列中的任务不会被执行，直到有线程空闲后，才能被处理）

• 工做队列未满：假设添加的任务都是耗时操做（短期不会结束），再添加9个耗时任务

  • 即存活线程为4，工做队列为10.

• 工做队列已满 & 未达最大线程数：再添加4个任务

  • 当工做队列已满，且不存在空闲线程，此时会建立额外线程来处理当前任务。此时存活线程为8，工做队列为10.

• 工做队列已满 & 且最大线程数已满：再添加1个任务

  • 触发RejectedExecutionHandler，将当前任务交由本身设置的执行句柄进行处理。此时存活线程为8，工做队列为10.
• 当任务执行完后，没有新增的任务，临时扩充的线程（大于核心线程数的）将在10s（keepAliveTime）后被销毁。

总结

最后，咱们在使用线程池的时候，须要根据使用场景来自行选择。经过corePoolSize和maximumPoolSize的搭配，存活时间的选择，以及改变队列的实现方式，如：选择延迟队列，来实现定时任务的功能。并发包Executors中提供的一些方法确实好用，但咱们仍需有保留地去使用，这样在项目中就不会挖太多的坑。

扩展

对于一些耗时的IO任务，盲目选择线程池每每不是最佳方案。经过异步+单线程轮询，上层再配合上一个固定的线程池，效果可能更好。相似与Reactor模型中selector轮询处理