没有合适的资源？快使用搜索试试~ 我知道了~

文库首页安全技术网络安全Java线程池浅析1

Java线程池浅析1

java

需积分: 0 0 下载量 91 浏览量 2022-08-08 19:39:41 上传评论收藏 97KB DOCX 举报

温馨提示

试读

16页

}关于FutureTask这个类的实现,我在前面的JAVA LOCK代码浅析有讲过其实现原理,主要的思想就是关注任务完成与未完成的状态,任务提交线程get()结

资源详情

资源评论

1. ExecutorService

Java 从 1.5 开始正式提供了并发包,而这个并发包里面除了原子变量,synchronizer,并发容器,另外

一个非常重要的特性就是线程池.对于线程池的意义,我们这边不再多说.

上图是线程池的主体类图,ThreadPoolExecutor 是应用最为广泛的一个线程池实现(我也将在接下

来的文字中详细描述我对这个类的理解和执行机制),ScheduledThreadPoolExecutor 则在

ThreadPoolExecutor 上提供了定时执行的等附加功能,这个可以从 ScheduledExecutorService 接

口的定义中看出来.Executors 则类似工厂方法,提供了几个非常常用的线程池初始化方法.

ThreadPoolExecutor

这个类继承了 AbstractExecutorService 抽象类, AbstractExecutorService 主要的职责有 2 部分,一

部分定义和实现提交任务的方法(3 个 submit 方法的实现) ,实例化 FutureTask 并且交给子类执

行,另外一部分实现 invokeAny,invokeAll 方法.留给子类的方法为 execute 方法,也就是 Executor

接口定义的方法.

//实例化一个 FutureTask,交给子类的 execute 方法执行.这种设计能够保证

callable 和 runnable 的执行接口方法的一致性(FutureTask 包装了这个差别)

public <T> Future<T> submit(Runnable task, T result) {

if (task

== null) throw new NullPointerException();

RunnableFuture<T> ftask = newTaskFor(task,

result);

execute(fta

sk);

return fta

sk;

}

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value)

{

return new FutureTask<T>(runnable, value);

}

关于 FutureTask 这个类的实现,我在前面的 JAVA LOCK 代码浅析有讲过其实现原理,主要的思想

就是关注任务完成与未完成的状态,任务提交线程 get()结果时被 park 住,等待任务执行完成被唤

醒,任务执行线程在任务执行完毕后设置结果,并且 unpark 对应线程并且让其得到执行结果.

回到 ThreadPoolExecutor 类.ThreadPoolExecutor 需要实现除了我们刚才说的 execute(Runnable

command)方法外,还得实现 ExecutorService 接口定义的部分方法.但 ThreadPoolExecutor 所提

供的不光是这些,以下根据我的理解来列一下它所具有的特性

1. execute 流程

2. 池

3. 工作队列

4. 饱和拒绝策略

5. 线程工厂

6. beforeExecute 和 afterExecute 扩展

execute 方法的实现有个机制非常重要,当当前线程池线程数量小于 corePoolSize,那么生成一个

新的 worker并把提交的任务置为这个工作线程的头一个执行任务,如果大于corePoolSize,那么会

试着将提交的任务塞到 workQueue 里面供线程池里面的 worker 稍后执行,并不是直接再起一个

worker,但是当 workQueue 也满,并且当前线程池小于 maxPoolSize,那么起一个新的 worker 并将

该任务设为该 worker 执行的第一个任务执行,大于 maxPoolSize,workQueue 也满负荷,那么调用

饱和策略里面的行为.

worker 线程在执行完一个任务之后并不会立刻关闭,而是尝试着去 workQueue 里面取任务,如果

取不到,根据策略关闭或者保持空闲状态.所以 submit 任务的时候,提交的顺序为核心线程池——

工作队列——扩展线程池.

池包括核心池,扩展池(2 者的线程在同一个 hashset 中,这里只是为了方便才这么称呼,并不是分

离的),核心池在池内 worker 没有用完的情况下,只要有任务提交都会创建新的线程,其代表线程池

正常处理任务的能力.扩展池,是在核心线程池用完,并且工作队列也已排满任务的情况下才会开

始初始化线程,其代表的是线程池超出正常负载时的解决方案,一旦任务完成,并且试图从

workQueue 取不到任务,那么会比较当前线程池与核心线程池的大小,大于核心线程池数的

worker 将被销毁.

Runnable getTask() {

for (;;) {

try {

int stat

e = runState;

//>SHUTDOWN 就是 STOP 或者

TERMINATED

//直接返回

if (stat

e > SHUTDOWN)

eturn null;

Runnable r;

//如果是 SHUTDOWN 状态,那么取

任务,如果有

//将剩余任务执行完毕,否则就

结束了

if (state == SHUTDOWN) //

剩余15页未读，继续阅读

评论收藏

内容反馈

Java线程池浅析1

评论0

最新资源

Java线程池浅析1

评论0

最新资源

相关推荐

java组件的浅析

JavaNIO浅析IO模型Java开发Java经验技巧共1

java 声音技术浅析

Java内存分配浅析

浅析Java设计模式【1】——观察者

Java 观察者模式的浅析

技术浅析.pdf 知识领域 Javase javaee Java技术浅析 技术关键词 JAVA语言 编程技术框架 原理

基于Java的Web开发技术浅析.pdf

Java语言中This关键字应用浅析

java 虚拟机原理浅析

流行java技术架构浅析借鉴.pdf

Java 集合浅析.txt

浅析Java设计模式【3】——代理.pdf

java数据类型浅析.ppt

深入Java单例模式浅析

JAVA Socket超时浅析 转.doc

Java中文乱码浅析及解决方案

高校Java课程教学浅析.pdf

STM32CubeMX安装包(版本:6.9.0) 附带 Java安装包(版本:371) - -2023年7月14日

基于spring boot的小区物业管理系统源码+论文+答辩ppt

最新Java JDK 8安装版（Windows 64位）

Java实现ocr图片识别（PaddleOCR）飞桨

自主研发的软著申请代码文档整理输出工具

毕业设计-基于JAVA的springboot超市进销存系统(源代码+论文）

Java 面经手册·小傅哥.pdf

java-11 windows-x64 安装包

Java面试八股文2023最新版

2024最强Java面试八股文

Java　观察者模式的浅析

技术浅析.pdf 知识领域 Javase javaee Java技术浅析技术关键词 JAVA语言编程技术框架原理

JAVA Socket超时浅析转.doc