Java线程池--ThreadPoolExecutor
一、线程池的处理流程
向线程池提交一个任务后,它的主要处理流程如下图所示:
一个线程从被提交(submit)到执行共经历以下流程:
- 线程池判断核心线程池里的线程是否都在执行任务,如果不是,则创建一个新的工作线程来执行任务。如果核心线程池里的线程都在执行任务,则进入下一个流程;
- 线程池判断工作队列是否已满。如果工作队列没有满,则将新提交的任务储存在这个工作队列里。如果工作队列满了,则进入下一个流程;
- 线程池判断其内部线程是否都处于工作状态。如果没有,则创建一个新的工作线程来执行任务。如果已满了,则交给饱和策略来处理这个任务。
线程池在执行excute方法时,主要有以下四种情况:
举例说明:并不是先加入任务就一定会先执行。
假设队列大小为 10,corePoolSize 为 3,maximumPoolSize 为 6,那么当加入 20 个任务时,执行的顺序就是这样的:首先执行任务 1、2、3,然后任务 4~13 被放入队列。这时候队列满了,任务 14、15、16 会被马上执行,而任务 17~20 则会抛出异常。最终顺序是:1、2、3、14、15、16、4、5、6、7、8、9、10、11、12、13。
排队
所有BlockingQueue 都可用于传输和保持提交的任务。可以使用此队列与池大小进行交互:
- 如果运行的线程少于 corePoolSize,则 Executor 始终首选添加新的线程,而不进行排队;
- 如果运行的线程等于或多于 corePoolSize,则 Executor 始终首选将请求加入队列,而不添加新的线程;
- 如果无法将请求加入队列,则创建新的线程,除非创建此线程超出 maximumPoolSize,在这种情况下,任务将被拒绝
排队有三种通用策略:
1、直接提交
工作队列的默认选项是 SynchronousQueue,它将任务直接提交给线程而不保持它们。在此,如果不存在可用于立即运行任务的线程,则试图把任务加入队列将失败,因此会构造一个新的线程。此策略可以避免在处理可能具有内部依赖性的请求集时出现锁。直接提交通常要求无界 maximumPoolSizes 以避免拒绝新提交的任务。当命令以超过队列所能处理的平均数连续到达时,此策略允许无界线程具有增长的可能性。
2、无界队列
使用无界队列(例如,不具有预定义容量的LinkedBlockingQueue)将导致在所有 corePoolSize 线程都忙时新任务在队列中等待。这样,创建的线程就不会超过 corePoolSize(因此,maximumPoolSize 的值也就无效了).当每个任务完全独立于其他任务,即任务执行互不影响时,适合于使用无界队列;例如,在 Web 页服务器中。这种排队可用于处理瞬态突发请求,当命令以超过队列所能处理的平均数连续到达时,此策略允许无界线程具有增长的可能性。
3、有界队列
当使用有限的 maximumPoolSizes 时,有界队列(如ArrayBlockingQueue)有助于防止资源耗尽,但是可能较难调整和控制。队列大小和最大池大小可能需要相互折衷:使用大型队列和小型池可以最大限度地降低 CPU 使用率、操作系统资源和上下文切换开销,但是可能导致人工降低吞吐量。如果任务频繁阻塞(例如,如果它们是 I/O 边界),则系统可能为超过您许可的更多线程安排时间。使用小型队列通常要求较大的池大小,CPU 使用率较高,但是可能遇到不可接受的调度开销,这样也会降低吞吐量
4、被拒绝的任务
当 Executor 已经关闭,并且 Executor 将有限边界用于最大线程和工作队列容量,且已经饱和时,在方法execute(java.lang.Runnable)中提交的新任务将被拒绝。在以上两种情况下execute方法都将调用其RejectedExecutionHandler的RejectedExecutionHandler.rejectedExecution(java.lang.Runnable,java.util.concurrent.ThreadPoolExecutor) 方法。下面提供了四种预定义的处理程序策略:
- 在默认的 ThreadPoolExecutor.AbortPolicy中,处理程序遭到拒绝将抛出运行时RejectedExecutionException;
- 在 ThreadPoolExecutor.CallerRunsPolicy中,线程调用运行该任务的execute本身。此策略提供简单的反馈控制机制,能够减缓新任务的提交速度;
- 在ThreadPoolExecutor.DiscardPolicy 中,不能执行的任务将被删除;
- 在 ThreadPoolExecutor.DiscardOldestPolicy中,如果执行程序尚未关闭,则位于工作队列头部的任务将被删除,然后重试执行程序(如果再次失败,则重复此过程)
参见:http://blog.csdn.net/longeremmy/article/details/8231184
http://blog.csdn.net/shixing_11/article/details/7109471
http://blog.csdn.net/linghu_java/article/details/17123057
转载于:https://www.cnblogs.com/moonandstar08/p/5612473.html
Java线程池--ThreadPoolExecutor相关推荐
- Java线程池ThreadPoolExecutor使用和分析
Java线程池ThreadPoolExecutor使用和分析(一) Java线程池ThreadPoolExecutor使用和分析(二) Java线程池ThreadPoolExecutor使用和分析(三 ...
- java线程池ThreadPoolExecutor类详解
线程池有哪些状态 1. RUNNING: 接收新的任务,且执行等待队列中的任务 Accept new tasks and process queued tasks 2. SHUTDOWN: 不接收 ...
- Java线程池ThreadPoolExecutor使用和分析(三) - 终止线程池原理
相关文章目录: Java线程池ThreadPoolExecutor使用和分析(一) Java线程池ThreadPoolExecutor使用和分析(二) - execute()原理 Java线程池Thr ...
- Java 线程池(ThreadPoolExecutor)原理分析与使用 – 码农网
线程池的详解 Java 线程池(ThreadPoolExecutor)原理分析与使用 – 码农网 http://www.codeceo.com/article/java-threadpool-exec ...
- JAVA线程池ThreadPoolExecutor与阻塞队列BlockingQueue .
2019独角兽企业重金招聘Python工程师标准>>> 从Java5开始,Java提供了自己的线程池.每次只执行指定数量的线程,java.util.concurrent.Thread ...
- java 线程池ThreadPoolExecutor
线程池 线程池的作用: 线程池作用就是限制系统中执行线程的数量. 根 据系统的环境情况,可以自动或手动设置线程数量,达到运行的最佳效果:少了浪费了系统资源,多了造成系统拥挤效率不高.用线程池控制线程数 ...
- JAVA线程池(ThreadPoolExecutor)源码分析
JAVA5提供了多种类型的线程池,如果你对这些线程池的特点以及类型不太熟悉或者非常熟悉,请帮忙看看这篇文章(顺便帮忙解决里面存在的问题,谢谢!): http://xtu-xiaoxin.ite ...
- Java 线程池(ThreadPoolExecutor)原理分析与使用
ThreadPoolExecutor原理概述 在我们的开发中"池"的概念并不罕见,有数据库连接池.线程池.对象池.常量池等等.下面我们主要针对线程池来一步一步揭开线程池的面纱. 使 ...
- 转:JAVA线程池ThreadPoolExecutor与阻塞队列BlockingQueue
从Java5开始,Java提供了自己的线程池.每次只执行指定数量的线程,java.util.concurrent.ThreadPoolExecutor 就是这样的线程池.以下是我的学习过程. 首先是构 ...
- Java线程池ThreadPoolExecutor
2019独角兽企业重金招聘Python工程师标准>>> 本文首发于个人微信公众号<andyqian>, 关注免费获取Java学习资料 前言 多线程一直是Java进阶的必修 ...
最新文章
- Nginx搭建负载均衡集群
- HDOJ2270(How Many Friends Will Be Together With You)
- 手工纸盒子_【创意手工】怒赞!如此有趣的儿童折纸,你不学我学!
- 利用键盘钩子捕获Windows键盘动作
- js将9999以内的值的个位改为0
- Transformer 杀疯了,图像去雨、人脸幻构、风格迁移、语义分割等通通上分
- 内网通不用软件改积分_软件项目为什么不能够如期交付?
- linux tomcat 进程杀掉_Linux下启动停止查看杀死Tomcat进程
- ENVI5.3.1高分2号影像预处理流程
- 咸鱼Maya笔记—NURBS放样成型法
- 漏洞篇(SQL注入一)
- 使用scp传输文件 Host key verification failed.解决
- win10不用虚拟机部署伪分布式集群(服务部署+客户端访问)
- python二维数组求和_Python如何对二维数组求和
- C++中四种类型转换运算符的使用方法
- 软件和硬件的质量曲线
- Spark运行环境之SparkEnv和通信工具RpcEnv
- Filezilla+花生壳内网穿透实现外网可以访问 避坑指南
- 【SpringBoot】51、Spring-Boot-Admin搭建服务监控系统
- amd显卡驱动目录linux,安装ATI Linux显卡驱动
热门文章
- Qt读取ini配置文件
- 串行端口 linux,规范模式Linux串行端口
- 心电图心电轴怎么计算_浅谈心电图
- Maven 多模块项目,多个root解决方法
- 007_Spring Data JPA JPQL
- 027_自己实现一个ArrayList
- eclipse未能识别我的手机
- android 融云会话列表,为什么切换账号之后会话列表不刷新,还显示上一个帐号的内容?...
- python获取一个模块的路径_如何获取 Python 模块的路径
- python实现md5加密_Python实现md5加密验证访问接口总结