博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java并发之ExecutorService
阅读量:6486 次
发布时间:2019-06-23

本文共 1165 字,大约阅读时间需要 3 分钟。

  hot3.png

概述

juc包中引入了ExecutorService的概念,用来方便我们处理异步任务,不用直接创建Thread对象,并且能管理线程池,不用自己去创建线程,当一个任务执行完之后,这些池里的线程能够复用。JDK里的线程池对象都是实现了ExecutorService接口。

构建

JDK提供了Executors工具类能够让我们方便快捷的创建不同类型不同功能的ExecutorService实例,比如:

关闭

ExecutorService是不会自动关闭的,每当里面的任务被执行完之后,这些线程就会空出来等待新的任务到来。因此我们需要手动调用执行关闭方法。ExecutorService为我们提供了两种关闭的方法,showdownshowdownNow。这两个方法调用之后,isShutdown返回true,返回这个ExecutorService此时为关闭状态,而isTerminated方法不会马上返回true,只有当ExecutorService中的任务执行完了之后才会返回true

  • showdown,表示这个executor 为关闭状态,不再接收新任务,当执行中的任务都结束之后ExecutorService会自己关闭
  • showdownNow,表示这个executor 为关闭状态,不再接收新任务,会想办法终止正在执行中的任务(一般是Thread.interupt()),但是只是想办法不能保证真的能终止
  • awaitTermination,会阻塞一段时间,直到ExecutorService 终止,或者超时,或者当前线程被打断

showdownshowdownNow都会变成关闭状态,再接收任务会抛错。

关闭ExecutorService的示例

 

invokeAll 方法表示批量提交任务,并且返回future的list

带timeout参数的invokeAll 方法表示批量提交任务,在timeout时间内的任务会被执行完,超过时间的会被取消执行,如果使用future.get()  会报CancellationException 错误

invokeAny 方法表示批量提交任务,并且返回最先执行结束的任务的结果,未执行完的任务会被取消

带timeout参数的invokeAny 方法表示批量提交任务,返回最先执行结束的任务的结果,未执行完的任务会被取消,如果在timeout时间内没有任务执行完,所有任务都会取消,返回null,并且抛错TimeoutException,最快的任务和timeout谁先到,谁先返回,如果最快的任务小于timeout则返回任务结果,如果timeout先到就抛TimeoutException,返回null
 

 

转载于:https://my.oschina.net/cregu/blog/2262656

你可能感兴趣的文章
桌面环境与桌面搜索Desktop Search tools
查看>>
与众不同 windows phone (40) - 8.0 媒体: 音乐中心的新增功能, 图片中心的新增功能, 后台音乐播放的新增功能...
查看>>
Jenkins学习七:Jenkins的授权和访问控制
查看>>
PowerDesigner将PDM导出生成WORD文档(转)
查看>>
路由器扫描的Java源码
查看>>
Android经常使用的五种弹出对话框
查看>>
经常使用命令 echo、@、call、pause、rem
查看>>
Activity的启动模式详解
查看>>
[改善Java代码]构造函数尽量简化
查看>>
优化PHP程序的方法(温故知新)
查看>>
阿里开源Mysql分布式中间件:Cobar
查看>>
JavaScript对数组的处理(一)
查看>>
[iBoard 电子学堂][第八卷 设计任意波发生器]第一篇 iBoard 任意波发生器简介
查看>>
[iBoard 电子学堂][第〇卷 电子基础]第二篇 电路图与印刷电路板
查看>>
配置JAVA环境
查看>>
java环境变量
查看>>
浅谈API设计
查看>>
java----OO的概念和设计原则(转)
查看>>
Java 实现 淘宝秒杀 聚划算 自己主动提醒 源代码
查看>>
如何下载一个物种的全部EST序列 | NCBI | 表达序列标签
查看>>