线程池主要包括以下参数:
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2,//核心线程数
2,//最大线程数
60L,//空闲线程存活时间
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(2),//任务队列
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.CallerRunsPolicy() //拒绝策略
);
线程池内部流程:
线上问题排查思路:
- dump出线程文件,分析出发生线程阻塞的代码位置
- 分析出线程阻塞的原因
- 修改线程池的配置参数,核心线程数基于线上接口的QPS计算,最大线程数参考线上tomcat的最大线程数配置,能够cover住高峰流量,队列设置的尽量小,避免造成任务挤压
- 扩展线程池,封装原生JDK线程池ThreadPoolExecutor,增加对线程池各项指标的监控,包括线程池运行状态、核心线程数、最大线程数、任务等待数、已完成任务数、线程池异常关闭等信息,便于实时监控和定位问题。
- 重写线程池拒绝策略,主要也是记录超出线程池负载情况下的各项指标情况,以及调用线程的堆栈信息,便于排查分析,通过抛出异常方式中断执行,避免引用的future不为null的问题。
- 合理调整future.get超时时间,防止阻塞主线程时间过长。