早安打工人-——Executor框架详解
目录
- 前言
- Executor框架的两级调度模型
- Executor框架的结构与成员
- Executor框架的结构
- Executor框架的成员
- (1)ThreadPoolExecutor
- (2)ScheduledThreadPoolExecutor
- (3)Future接口
- (4)Runnable接口和Callable接口
前言
在Java中,使用线程来异步执行任务。Java线程的创建与销毁需要一定的开销,如果我们 为每一个任务创建一个新线程来执行,这些线程的创建与销毁将消耗大量的计算资源。同时, 为每一个任务创建一个新线程来执行,这种策略可能会使处于高负荷状态的应用最终崩溃。 Java的线程既是工作单元,也是执行机制。从JDK 5开始,把工作单元与执行机制分离开 来。工作单元包括Runnable和Callable,而执行机制由Executor框架提供。
Executor框架的两级调度模型
在HotSpot VM的线程模型中,Java线程(java.lang.Thread)被一对一映射为本地操作系统线 程。Java线程启动时会创建一个本地操作系统线程;当该Java线程终止时,这个操作系统线程 也会被回收。操作系统会调度所有线程并将它们分配给可用的CPU。
在上层,Java多线程程序通常把应用分解为若干个任务,然后使用用户级的调度器 (Executor框架)将这些任务映射为固定数量的线程;在底层,操作系统内核将这些线程映射到 硬件处理器上。应用程序通过Executor框架控制上层的调度;而下层的调度由操作系统 内核控制,下层的调度不受应用程序的控制。
Executor框架的结构与成员
Executor框架的结构
Executor框架主要由3大部分组成如下。
·任务。包括被执行任务需要实现的接口:Runnable接口或Callable接口。
·任务的执行。包括任务执行机制的核心接口Executor,以及继承自Executor的
ExecutorService接口。Executor框架有两个关键类实现了ExecutorService接口(ThreadPoolExecutor和ScheduledThreadPoolExecutor)。
·异步计算的结果。包括接口Future和实现Future接口的FutureTask类。
Executor框架包含的主要的类与接口。
·Executor是一个接口,它是Executor框架的基础,它将任务的提交与任务的执行分离开 来。
·ThreadPoolExecutor是线程池的核心实现类,用来执行被提交的任务。
·ScheduledThreadPoolExecutor是一个实现类,可以在给定的延迟后运行命令,或者定期执 行命令。ScheduledThreadPoolExecutor比Timer更灵活,功能更强大。
·Future接口和实现Future接口的FutureTask类,代表异步计算的结果。
·Runnable接口和Callable接口的实现类,都可以被ThreadPoolExecutor或Scheduled- ThreadPoolExecutor执行。
主线程首先要创建实现Runnable或者Callable接口的任务对象。工具类Executors可以把一 个Runnable对象封装为一个Callable对象(Executors.callable(Runnable task)或 Executors.callable(Runnable task,Object resule))。
然后可以把Runnable对象直接交给ExecutorService执行(ExecutorService.execute(Runnable command));或者也可以把Runnable对象或Callable对象提交给ExecutorService执行(Executor- Service.submit(Runnable task)或ExecutorService.submit(Callabletask))。
如果执行ExecutorService.submit(…),ExecutorService将返回一个实现Future接口的对象 (到目前为止的JDK中,返回的是FutureTask对象)。由于FutureTask实现了Runnable,程序员也可 以创建FutureTask,然后直接交给ExecutorService执行。
最后,主线程可以执行FutureTask.get()方法来等待任务执行完成。主线程也可以执行FutureTask.cancel(boolean mayInterruptIfRunning)来取消此任务的执行。
Executor框架的成员
Executor框架的主要成员:ThreadPoolExecutor、ScheduledThreadPoolExecutor、 Future接口、Runnable接口、Callable接口和Executors。
(1)ThreadPoolExecutor
ThreadPoolExecutor通常使用工厂类Executors来创建。Executors可以创建3种类型的ThreadPoolExecutor:
1)FixedThreadPool。下面是Executors提供的,创建使用固定线程数的FixedThreadPool的 API。
阻塞队列为⽆界队列LinkedBlockingQueue
适⽤于处理CPU密集型的任务,适⽤执⾏⻓期的任务
public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactorythreadFactory)
2)SingleThreadExecutor。下面是Executors提供的,创建使用单个线程的SingleThread-Executor的API。
阻塞队列是LinkedBlockingQueue
适⽤于串⾏执⾏任务的场景,⼀个任务⼀个任务地执⾏
SingleThreadExecutor适用于需要保证顺序地执行各个任务;并且在任意时间点,不会有多个线程是活动的应用场景。
public static ExecutorService newSingleThreadExecutor()
public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory)
3)CachedThreadPool。下面是Executors提供的,创建一个会根据需要创建新线程的CachedThreadPool的API。
阻塞队列是SynchronousQueue
适⽤于并发执⾏⼤量短期的⼩任务
CachedThreadPool是大小无界的线程池,适用于执行很多的短期异步任务的小程序,或者 是负载较轻的服务器。
public static ExecutorService newCachedThreadPool()
public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory)
FixedThreadPool和SingleThreadPool:
允许的请求队列长度为Integer.MAX_VALUE,可能会堆积大量的请求,从而导致OOM。
CachedThreadPool:
允许的创建线程数量为Integer.MAX_VALUE,可能会创建大量的线程,从而导致OOM。
(2)ScheduledThreadPoolExecutor
ScheduledThreadPoolExecutor通常使用工厂类Executors来创建。Executors可以创建2种类 型的ScheduledThreadPoolExecutor:
·ScheduledThreadPoolExecutor。包含若干个线程的ScheduledThreadPoolExecutor。
·SingleThreadScheduledExecutor。只包含一个线程的ScheduledThreadPoolExecutor。
下面是工厂类Executors提供的,创建固定个数线程的ScheduledThreadPoolExecutor的API。
ScheduledThreadPoolExecutor适用于需要多个后台线程执行周期任务,同时为了满足资源 管理的需求而需要限制后台线程的数量的应用场景。
阻塞队列是DelayedWorkQueue
周期性执⾏任务的场景,需要限制线程数量的场景
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize,ThreadFactory threadFactory)
下面是Executors提供的,创建单个线程 的SingleThreadScheduledExecutor的API。
SingleThreadScheduledExecutor适用于需要单个后台线程执行周期任务,同时需要保证顺 序地执行各个任务的应用场景。
public static ScheduledExecutorService newSingleThreadScheduledExecutor()
public static ScheduledExecutorService newSingleThreadScheduledExecutor (ThreadFactory threadFactory)
(3)Future接口
Future接口和实现Future接口的FutureTask类用来表示异步计算的结果。
当我们把Runnable 接口或Callable接口的实现类提交(submit)给ThreadPoolExecutor或 ScheduledThreadPoolExecutor时,ThreadPoolExecutor或ScheduledThreadPoolExecutor会向我们 返回一个FutureTask对象。
(4)Runnable接口和Callable接口
Runnable接口和Callable接口的实现类,都可以被ThreadPoolExecutor或Scheduled- ThreadPoolExecutor执行。它们之间的区别是Runnable不会返回结果,而Callable可以返回结 果。 除了可以自己创建实现Callable接口的对象外,还可以使用工厂类Executors来把一个 Runnable包装成一个Callable。
下面是Executors提供的,把一个Runnable包装成一个Callable的API。
public static Callable<Object> callable(Runnable task) // 假设返回对象Callable1
下面是Executors提供的,把一个Runnable和一个待返回的结果包装成一个Callable的API。
public static <T> Callable<T> callable(Runnable task, T result) // 假设返回对象Callable2
当我们把一个Callable对象(比如上面的Callable1或Callable2)提交给 ThreadPoolExecutor或ScheduledThreadPoolExecutor执行时,submit(…)会向我们返回一个 FutureTask对象。我们可以执行FutureTask.get()方法来等待任务执行完成。当任务成功完成后 FutureTask.get()将返回该任务的结果。
例如,如果提交的是对象Callable1,FutureTask.get()方法 将返回null;如果提交的是对象Callable2,FutureTask.get()
public static void main(String[] args) throws Exception {ExecutorService executor = Executors.newFixedThreadPool(2);Runnable runnable = () -> System.out.println(1);Callable callable = () -> {System.out.println(1);return "1111";};Future<?> submit = executor.submit(callable);System.out.println(submit.get());Callable<Integer> callable1 = Executors.callable(runnable, 22);Future<Integer> submit1 = executor.submit(callable1);System.out.println(submit1.get());
}
早安打工人-——Executor框架详解相关推荐
- 一文搞懂线程池原理——Executor框架详解
文章目录 1 使用线程池的好处 2 Executor 框架 2.1 Executor 框架结构 2.2 Executor 框架使用示意图 2.3 Executor 框架成员 2.3.1 Executo ...
- 线程池框架_Java并发——Executor框架详解(Executor框架结构与框架成员)
一.什么是Executor框架? 我们知道线程池就是线程的集合,线程池集中管理线程,以实现线程的重用,降低资源消耗,提高响应速度等.线程用于执行异步任务,单个的线程既是工作单元也是执行机制,从JDK1 ...
- 【高并发】JUC中的Executor框架详解1
文章目录 1.Executors框架介绍 1.1 Excecutor框架主要包含3部分的内容 1.2 Executors框架包括: 1.2.1 Executor接口 1.2.2 ExecutorSer ...
- Java并发——Executor框架详解(Executor框架结构与框架成员)
一.什么是Executor框架? 我们知道线程池就是线程的集合,线程池集中管理线程,以实现线程的重用,降低资源消耗,提高响应速度等.线程用于执行异步任务,单个的线程既是工作单元也是执行机制,从JDK1 ...
- Executor框架详解
java的线程既是工作单元,也是执行机制.从jdk5开始,把工作单元与执行机制分离开来.工作单元包括Runnable和Callable,而执行机制由Executor框架提供. Executor框架的两 ...
- 【高并发】JUC中的Executor框架详解2
1.概述 转载:添加链接描述 1.1 本文内容 ExecutorCompletionService出现的背景介绍CompletionService接口及常用的方法介绍ExecutorCompletio ...
- shiro放行_Shiro框架详解 tagline
部分面试资料链接:https://pan.baidu.com/s/1qDb2YoCopCHoQXH15jiLhA 密码:jsam 想获得全部面试必看资料,关注公众号,大家可以在公众号后台回复" ...
- Qt图形视图框架详解-安晓辉-专题视频课程
Qt图形视图框架详解-12227人已学习 课程介绍 介绍Qt中的Graphics View Framework,涉及View.Scene.Item的关系,如何自定义QGraphicsI ...
- 双目视觉集合框架详解
双目视觉几何框架详解 一.图像坐标:我想和世界坐标谈谈(A) 玉米竭力用轻松具体的描述来讲述双目三维重建中的一些数学问题.希望这样的方式让大家以一个轻松的心态阅读玉米的<计算机视觉学习笔记> ...
最新文章
- MySQL ERROR 1878 解决办法
- 递归系列之一_南诺塔问题
- 2017年第八届蓝桥杯C/C++ A组国赛 —— 第一题:平方十位数
- Excel多条件求和 SUMPRODUCT函数用法详解
- j@2ff4f00f_J4F的完整形式是什么?
- excel记账本模板_原来这才是老板最喜欢看的财务报表!这些模板送你,录入自动生成...
- java反编译工具_JDA Java反编译工具的下载和使用手册
- 禁止进入activity后EditText自动获得焦点的方法
- vba自动生成html,动态生成嵌入在VBA电子邮件生成中的HTML表
- Spring.NET学习笔记8——集合类型的注入(基础篇) Level 200
- Oracle 11g的下载与安装
- c语言面试100问题及答案,【编程C语言面试题】面试问题:C语言面试大全… - 看准网...
- 微信小程序 选项卡设置
- GNSS定位系统开发
- opencv-python的颜色检测追踪
- 程序员,被代码耽误的段子手!
- vue3.0+vite跑项目遇到的问题
- python软件和rost软件哪个更好_ROST-CM软件分词和词频统计用法体验
- 2D变形:平移、旋转、缩放、倾斜
- 前端·在线随机生成图片 免费 API
热门文章
- python2 和 python3中bytes和str的数据类型以及p32和u32
- 统计|假设检验中的P值(pvalue)如何看/怎样理解
- 聊一聊平时常用的加密算法
- python类中包含类_彻底搞懂Python中的类
- 数组业务场景,算卦程序入门测试
- 中年微软从创新转向管理和控制的平衡术
- 解决vant有赞Coupon优惠券选择器组件Bug
- python爬虫爬取图片代码_python爬虫-20行代码爬取王者荣耀所有英雄图片,小白也轻轻松松...
- 合伙做生意,如何转让份额
- (转)农村生活的可行性分析报告!