ThreadPoolExecutor
2021-08-03 08:51:11 0 举报AI智能生成
ThreadPoolExecutor 主要逻辑源码分析
作者其他创作
大纲/内容
Worker线程开始回收
统计线程池中完成任务的数量--completedTaskCount
移除线程的引用--workers.remove(w);
是，设置为terminated
否，增加线程，维持核心线程数
是否需要设置线程池为terminated(终止)
processWorkerExit
线程池里的核心线程数量
corePoolSize
线程池里最大的线程数量
maximumPoolSize
空闲线程等待时间，线程池中的线程数量比核心数量值大了以后，多出来的线程会等待指定的时间后释放
keepAliveTime
keepAliveTime单位
unit
所有线程都繁忙的时候，任务等待队列
workQueue
如果需要创建新的线程放入线程池的时候，就是通过这个线程工厂来创建的
threadFactory
如果workQueue有固定大小，当任务超过了queue大小，用handler来处理
handler
构造函数
如果任务为null，抛出NPE异常
原子变量ctl共同存储 线程状态+线程个数。说白了就是用一个int型变量存储两个数，高3位表示线程状态，后面29位表示线程的个数
判断当前线程数 是否小于 核心线程数， 如果小于，开启新的线程执行任务
如果线程池处于RUNNING状态，添加任务到阻塞队列
重新获取下ctl的值，因为把任务添加到队列时，线程的状态可能已经改变，这里重新获取下
线程状态不是RUNNING状态，从队列里删除
如果当前线程池一个线程也没有，添加一个线程
如果队列满了，则添加新的线程（非核心线程），如果新增失败，执行拒绝策略
execute
AbstractQueuedSynchronizer
Runnable
workQueue.take()
getTask
runWorker
run
Worker
直接抛出RejectedExecutionException，阻止任务执行
AbortPolicy
方法没有任何实现，会默默的丢弃任务，而不做任何的处理
DiscardPolicy
获取并移除第一个任务--e.getQueue().poll();提交执行最新的任务--e.execute(r);
优先丢弃队列的头部任务，也就是第一个；然后提交执行最新的任务
DiscardOldestPolicy
只要线程未关闭，直接在提交任务的这个线程里执行当前这个任务；这样做不会丢弃任务，但是会阻塞其他任务的执行，造成业务性能下降
CallerRunsPolicy
拒绝策略（RejectedExecutionHandler）
ThreadPoolExecutor
0 条评论
回复 删除
下一页
