JUC 默认的线程池 ThreadPoolExecutor 默认是不会预热线程,用时才会创建。
1、核心参数(corePoolSize、拒绝策略、keepAliveTime、核心/最大线程数,队列)
2、创建线程池(guava、commons-lang3、线程池)
3、why先加队列(缓冲[避免损耗、oom],避免获取全局锁)
一、线程池重要参数&拒绝策略
1、小于 corePoolSize (核心线程数),无论已创建线程是否空闲,都建新线程
2、等于:
1)任务队列未满,放入
2)已满,未超过最大线程数,建新,等于执行拒绝策略。
1)AbortPolicy(默认)拒绝,直接抛出 RejectedExecutionException,默认值。
2)CallerRunsPolicy(意义不大,)调用线程直接运行任务的 run 方法,即异步转同步(增加负载)。
3)DiscardOldestPolicy丢弃任务队列中最新进入(记录轨迹,偶尔丢失点没关系,保存新数据)
4)DiscardPolicy拒绝不执行(异步打印日志,直接忽略不执行,期望保存旧的数据)
阻塞队列:禁止用无界,造成内存溢出。最大线程数参数失效
ThreadFactory 为线程命名,方便跟踪, RocketMQ 源码org.apache.rocketmq.common. ThreadFactoryImpl 实现。
keepAliveTime
最大空闲时间,没执行任务,的存活时间。
默认只对corePoolSize,allowCoreThreadTimeOut 为 ture ,核心线程数空闲关闭。
如何设置 keepAliveTime
keepAliveTime 不设置(流量是一波波)。一般corePoolSize 与 maxPoolSize 相等,不通业务对应不同线程池
场景:每隔 10分钟一波洪峰,每波处理3分钟, keepAliveTime 5分钟,核心线程10,最大100,流量来,10个处理不过来,创建线程,处理后空闲,关闭,又流量,又创建,线程池意义不大
例:核心线程池20,最大线程池200,工作队列2000,DiscardPolicy拒绝策略,qps从1线性涨到5000,用arrayblockingquene?
线程池中最小会创建20个线程,至于会不会大于20个线程,就要看单个处理任务的快慢了,即,如果任务队列中 arrayblockingquene 积压了 2000 个任务,即处理不过来了,则会创建新的线程(不超过200),如果不会积压,或者任务队列未满,则只会创建20个线程。
核心大小进最大,队列满了再用线程数,核心数字要考虑cpu,io密集,还是计算运行。否则品
二、创建线程池
ThreadPoolExecutor创建,禁用Executors,规避资源耗尽:
1、newFixedThreadPool和newSingleThreadExecutor: 允许的请求队列长度为 Integer.MAX_VALUE,会耗费大内存,甚至OOM
2、CachedThreadPool:允许创建线程数Integer.MAX_VALUE,可能创建大量线程,导致 OOM
根据阿里巴巴java开发规范,推荐了3种线程池创建方式
1.com.google.guava包
2.用commons-lang3包
3.spring配置线程池:自定义线程工厂bean实现ThreadFactory,使用方式直接注入bean。调用execute(Runnable task)方法即可
三、为什么先加队列,再增加最大线程数
1、缓冲,1)不轻易创建线程。创建损耗很大,要拿mainlock全局锁,通过系统调用的JNI切换到内核态进行创建。影响并发效率,队列把创建核心线程与最大线程隔离 2)承担业务压力,但要考虑积累太多务导致 OOM
2、执行execute()时,尽可能的避免获取全局锁
例 ArrayBlockingQueue,调size、offer入队都要获取锁,这些封装在ArrayBlockingQueue方法内部。积压一定阈值时创建新线程,要获取Queue锁,先count再offer,获取三次锁,虽然是同一锁重入(Queue锁进入1 -> Queue锁进入2-> count -> Queue锁释放2 -> Queue锁进入2-> offer -> Queue锁释放2 -> Queue锁释放1)。实现最大值释放,只用 offer 方法判断返回值是否为true就ok