

首页  流程图  详情



ThreadPoolExecutor源码

2021-08-18 10:01:28   4  举报





ThreadPoolExecutor

模版推荐

作者其他创作

大纲/内容

循环从从阻塞队列中取任务

释放锁

判断线程是否执行出现异常

线程池线程复用的逻辑，通过把任务和线程封成worker一个对象通过启动每个woeker对象，内部一个while循环获取任务，执行任务的run方法达到线程复用

Runnable task = w.firstTask

workers.remove(w);非核心线程数回收完成

根据线程池状态进行判断是否结束线程池

如果出现异常 workerCount减1没出现异常就不用操作 getTask已减1

task.run()执行提交任务的run方法

成功

 workQueue.poll(keepAliveTime

创建线程池

workQueue.offer(command)

执行woker对象的 t.start()调用run方法

if (workerCountOf(c) < corePoolSize)

while (task != null || (task = getTask()) != null)

Worker.run添加完后，启动任务

new Worker(firstTask)创建对象

worker对象

reject(command)执行拒绝策略

tryTerminate

提交任务

创建非核心线程

小于核心线程数

firstTask新增线程的第一个任务

获取独占锁 ReentrantLock把worker放入集合中

如果task为null则跳出循环执行非核心线程回收工作默认核心线程不允许回收

 getTask()

threadFactory线程池工厂创建线线程

队列未满放入成功

从线程池中移除了一个工作线程

先workerCount数减1（CAS）在指定等待时间没有从队列中获取到任务task就返回null

thread线程

队列已满，放入失败

核心线程数已满放入阻塞队列

completedAbruptly=true

查询线程池数量

 runWorker(this)

当线程池是RUNNING或SHUTDOWN状态时，如果worker是异常结束，那么会直接addWorker

HashSet<Worker>workers.add(w)

线程池中的每一个线程被封装成一个Worker对象

判断核心线程数是否已满

获取firstTask新创建线程的第一个任务

 decrementWorkerCount()

execute(Runnable command)

cas+1更新线程池数量失败则重试

workerCountOf(recheck) == 0

 Collect

Get Started

spark wordcount源码分析

 Collect

Get Started

SparkEnv 源码分析

 Collect

Get Started

ThreadPoolExecutor

 Collect

Get Started

ThreadPoolExecutor 源码





0 条评论

下一页