线程池工作机制

 我来答
清宁时光17
2022-06-09 · TA获得超过1.4万个赞
知道大有可为答主
回答量:7105
采纳率:100%
帮助的人:41万
展开全部

ThreadPoolExecutor 是线程池的核心实现类,用来执行被提交的任务

corePoolSize 核心线程数

maximumPoolSize 最大线程数

线程池中允许的最大线程数。

keepAliveTime 线程空闲时的存活时间

当线程没有执行任务时,继续存活的时间。当线程池中的线程数量大于核心线程数时,即时没有新任务提交,核心线程外的线程也不会立即销毁,而是等待keepAliveTime才会销毁。

unit 线程空闲时的存活时间单位

workQueue 阻塞队列

阻塞队列:1)支持阻塞的插入方法:当队列满时,队列会阻塞插入元素的线程,直到队列不满;2)支持阻塞的移除方法:在队列为空时,获取元素的线程会等待队列变为非空

生产者和消费者模式 能够解决并发问题,通过平衡生产线程和消费线程的工作能力来提高程序整体处理数据的速度。通过阻塞队列来进行通信,生产者生产完数据不用等待消费者处理,直接扔给阻塞队列,消费者也直接从阻塞队列中取数据,既能够解耦,又平衡两者的处理能力。

常用阻塞队列:

threadFactory 创建线程的工厂

handler 拒绝策略

当阻塞队列满了,且没有空闲的工作线程,继续提交任务会采取一种策略处理新任务。线程池提供了4中策略:

1)AbortPolicy:直接抛出异常,默认策略

2)CallerRunsPolicy:用调用者所在的线程来执行任务

3)DiscardPolicy:直接丢弃任务

4)DiscardOldestPolicy:丢弃阻塞队列中最靠前的任务

也可以自己根据应用场景(如记录日志或持久化储存不能处理的任务)实现RejectedExecutionHandler接口,自定义拒绝策略。

看下ThreadPoolExecutor的execute方法:

流程图:

提交任务:

关闭线程池:遍历线程池中的工作线程,然后逐个调用interrupt方法来中断线程。

已赞过 已踩过<
你对这个回答的评价是?
评论 收起
推荐律师服务: 若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询

为你推荐:

下载百度知道APP,抢鲜体验
使用百度知道APP,立即抢鲜体验。你的手机镜头里或许有别人想知道的答案。
扫描二维码下载
×

类别

我们会通过消息、邮箱等方式尽快将举报结果通知您。

说明

0/200

提交
取消

辅 助

模 式