首页  思维笔记  详情





线程池源码学习

2025-02-25 23:25:19   0  举报





线程池源码学习

线程池

模板推荐

作者其他创作

大纲/内容

FutureTask：封装Callable和有返回结果

Executor：接口，执行器，里面有个执行方法，执行Runnable线程

ExecutorService子类ThreadPoolExecutor

Callable：类似Runnable，有返回值

CompletableFuture：首先它是一个Future，会存一个返回结果

可以对多个任务进行多种操作的管理

为什么使用线程池

线程池的底层原理是什么

线程池的源码中有哪些重要内容

①private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0)); //ctl属性：包含两个属性workerCount（后29）、runState（高三位）

runState：

五种状态

RUNNING：接受新的任务以及处理队列中的任务

SHUTDOWN：不接受新的任务，但是处理队列中的任务

STOP：不接受新的任务也不处理队列中的任务，以及中断正在执行中的任务

TIDYING：所有的任务已经结束，工作线程数量为0，线程状态为TIDYING，然后调用terminated结束线程的过渡状态

TERMINATED：terminated()，已经完全终止了

运行状态的流转

②线程池中重点参数

一些参数说明

线程池构造函数

七大核心参数

参数如何设置？

corePoolSize：核心线程数如何设置？

maximumPoolSize:最大核心线程数如何设置？

workQueue：如何选择合适的队列？

线程池重点方法

①执行任务void execute

具体方法如下：

执行流程

②将任务添加到队列中  boolean addWorker

具体代码如下

③运行任务

具体代码如下

③线程终止 

具体代码如下

④线程立即终止

具体代码如下

⑤Worker类

代码如下

⑥线程执行异常，线程池如何处理的？

代码如下

线程池拒绝策略有哪些？

AbortPolicy：直接抛异常

public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {<br> throw new RejectedExecutionException("Task " + r.toString() +<br> " rejected from " +e.toString());<br> }

CallerRunsPolicy：线程池无法处理，将任务交给调用者处理任务，如主线程，即同步处理，不异步处理了

拒绝策略如下：

DiscardPolicy：线程池无法处理任务时，将任务丢弃掉，不处理

public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {<br> }

DiscardOldestPolicy：意思是当线程池无法处理任务时，将队列中队首任务拉取并删除掉，然后再执行当前任务

拒绝策略如下：

如何自定义一个线程池？

线程池中有哪些设计模式？

 Collect

Get Started

线程池源码

 Collect

Get Started

线程池

 Collect

Get Started

线程池源码剖析-execute方法

 Collect

Get Started

线程池源码





0 条评论

下一页