ThreadPoolExecutor类实现了ExecutorService接口和Executor接口,可以设置线程池corePoolSize,最大线程池大小,AliveTime,拒绝策略等。常用构造方法:

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,

long keepAliveTime, TimeUnit unit,

BlockingQueue<Runnable> workQueue,

RejectedExecutionHandler handler)

corePoolSize: 线程池维护线程的最少数量

maximumPoolSize:线程池维护线程的最大数量

keepAliveTime: 线程池维护线程所允许的空闲时间

unit: 线程池维护线程所允许的空闲时间的单位

workQueue: 线程池所使用的缓冲队列

handler: 线程池对拒绝任务的处理策略

当一个任务通过execute(Runnable)方法欲添加到线程池时:

l  如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。

2  如果此时线程池中的数量等于 corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。

3  如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。

4  如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。也就是:处理任务的优先级为:核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务。

当线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数。

handler有四个选择:

ThreadPoolExecutor.AbortPolicy()

抛出java.util.concurrent.RejectedExecutionException异常 ,示例如下:

private static class Worker implements Runnable {

public void run() {

System.out.println(Thread.currentThread().getName() + " is running");

}

}

public static void main(String[] args) {

int corePoolSize = 5;

int maxPoolSize = 10;

long keepAliveTime = 5;

BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(10);

//拒绝策略1:将抛出 RejectedExecutionException.

RejectedExecutionHandler handler =

new ThreadPoolExecutor.AbortPolicy();

ThreadPoolExecutor executor = new ThreadPoolExecutor

(corePoolSize, maxPoolSize,

keepAliveTime, TimeUnit.SECONDS,

queue, handler);

for(int i=0; i<100; i++) {

executor.execute(new Worker());

}

executor.shutdown();

}

运行结果如下:

pool-1-thread-2 is running

pool-1-thread-3 is running

Exception in thread "main" java.util.concurrent.RejectedExecutionException

pool-1-thread-1 is running

pool-1-thread-7 is running

pool-1-thread-6 is running

pool-1-thread-4 is running

pool-1-thread-9 is running

pool-1-thread-8 is running

pool-1-thread-5 is running

at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)

at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)

at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)

at concurrent.ThreadPoolDemo.main(ThreadPoolDemo.java:33)

pool-1-thread-10 is running

处理源码如下:

public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {

throw new RejectedExecutionException();

}

策略2:ThreadPoolExecutor.CallerRunsPolicy
用于被拒绝任务的处理程序,它直接在 execute 方法的调用线程中运行被拒绝的任务;如果执行程序已关闭,则会丢弃该任务。如下:

RejectedExecutionHandler handler =

new ThreadPoolExecutor.CallerRunsPolicy();

运行如下:

pool-1-thread-7 is running

pool-1-thread-7 is running

pool-1-thread-7 is running

pool-1-thread-7 is running

pool-1-thread-7 is running

pool-1-thread-7 is running

pool-1-thread-2 is running

pool-1-thread-3 is running

pool-1-thread-1 is running

pool-1-thread-8 is running

main is running

main is running

main is running

pool-1-thread-4 is running

pool-1-thread-7 is running

pool-1-thread-7 is running

pool-1-thread-7 is running

处理源码如下:

public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {

if (!e.isShutdown()) {

r.run();

}

}

策略3:

RejectedExecutionHandler handler =

new ThreadPoolExecutor.DiscardOldestPolicy();

这样运行结果就不会有100个线程全部被执行。处理源码如下:

public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {

if (!e.isShutdown()) {

e.getQueue().poll();

e.execute(r);

}

}

策略4:ThreadPoolExecutor.DiscardPolicy
用于被拒绝任务的处理程序,默认情况下它将丢弃被拒绝的任务。

运行结果也不会全部执行100个线程。

源码如下,实际就是对线程不执行操作:

public static class DiscardPolicy implements RejectedExecutionHandler {

/**

* Creates a <tt>DiscardPolicy</tt>.

*/

public DiscardPolicy() { }

/**

* Does nothing, which has the effect of discarding task r.

* @param r the runnable task requested to be executed

* @param e the executor attempting to execute this task

*/

public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {

}

}

这四种策略是独立无关的,是对任务拒绝处理的四中表现形式。最简单的方式就是直接丢弃任务。但是却有两种方式,到底是该丢弃哪一个任务,比如可以丢弃当前将要加入队列的任务本身(DiscardPolicy)或者丢弃任务队列中最旧任务(DiscardOldestPolicy)。丢弃最旧任务也不是简单的丢弃最旧的任务,而是有一些额外的处理。除了丢弃任务还可以直接抛出一个异常(RejectedExecutionException),这是比较简单的方式。抛出异常的方式(AbortPolicy)尽管实现方式比较简单,但是由于抛出一个RuntimeException,因此会中断调用者的处理过程。除了抛出异常以外还可以不进入线程池执行,在这种方式(CallerRunsPolicy)中任务将有调用者线程去执行。

原文地址: https://blog.csdn.net/pozmckaoddb/article/details/51478017

转载于:https://www.cnblogs.com/cblogs/p/9444557.html

线程池ThreadPoolExecutor里面4种拒绝策略相关推荐

  1. java线程池拒绝策略_Java线程池ThreadPoolExecutor的4种拒绝策略

    最近在做大批量数据采集转换工作,基础数据在本地但是需要调用网络资源完成数据转换.多方面原因在保证良好运行情况下,最多开5个线程进行网络资源调用.方案是基础数据在数据库分页,循环遍历每一条数据,创建调用 ...

  2. ThreadPoolExecutor 的八种拒绝策略 | 含番外!

    点击蓝色"程序猿DD"关注我 回复"资源"获取独家整理的学习资料! 作者 | KL 来源 | http://rrd.me/en3Wp 前言 谈到java的线程池 ...

  3. ThreadPoolExecutor里面4种拒绝策略--CallerRunsPolicy

    首先介绍一下ThreadPoolExecutor构造方法: public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long ke ...

  4. 任务数量超过线程池负荷了怎么办?拒绝策略安排起来!

    通过之前三篇关于Spring Boot异步任务实现的博文,我们分别学会了: @Async创建异步任务 为异步任务配置线程池 多个线程池隔离不同的异步任务 今天我们继续对异步任务的实现进行完善和优化! ...

  5. 关于线程池的五种实现方式,七大参数,四种拒绝策略

    一.池化技术之线程池 实现线程池视频讲解,附源码:「链接」 什么是池化技术?简单来说就是优化资源的使用,我准备好了一些资源,有人要用就到我这里拿,用完了就还给我.而一个比较重要的的实现就是线程池.那么 ...

  6. java线程池1001java线程池_深入浅出Java(Android )线程池ThreadPoolExecutor

    前言 关于线程池 在Java/Android开发中,设计到并发的请求,那基本上是离不开线程池了.用线程池的好处: 1.减少线程频繁创建.销毁的开销: 2.好控制并发量,降低OOM的可能,至于原因文中会 ...

  7. Java 线程池 ThreadPoolExecutor 八种拒绝策略浅析

    前言 谈到 Java 的线程池最熟悉的莫过于 ExecutorService 接口了,jdk1.5 新增的 java.util.concurrent 包下的这个 api,大大的简化了多线程代码的开发. ...

  8. 面试官问:线程池除了常见的4种拒绝策略,你还知道哪些?

    点击关注上方"视学算法",设为"置顶或星标" 第一时间送达技术干货. 来源 | http://rrd.me/en3Wp 前言 谈到java的线程池最熟悉的莫过于 ...

  9. Java 线程池 8 种拒绝策略

    前言 谈到java的线程池最熟悉的莫过于ExecutorService接口了,jdk1.5新增的java.util.concurrent包下的这个api,大大的简化了多线程代码的开发.而不论你用Fix ...

  10. 线程池:4个方法,7个参数,4种拒绝策略

    什么是池? 先讲一个例子,有可能可以帮助你理解,觉得无趣的小伙伴可以直接跳过.相信大多数都知道外包公司,甚至很多小伙伴还在外包公司呆过,其实外包公司我觉得也就可以看作是个"池". ...

最新文章

  1. dubbo:9个你不一定知道,但好用的功能
  2. pandas describe函数_SQL和Pandas同时掉到河里,你先救谁?
  3. Ant build.xml程序简单说明
  4. Powerdesigner数据库建模工具教程
  5. 有关Vs2008 由代码转化到设计器时死掉问题
  6. 五分钟了解数据库事务隔离
  7. centos php支持yaf,CentOS环境下给PHP7.0安装yaf扩展
  8. 无代码绘制基因表达箱线图
  9. 系统架构师学习笔记-操作系统(一)
  10. WEB安全基础-PHP+MySQL实践
  11. 高二女生制作危险驾驶报警手机软件
  12. [USACO13MAR]Poker Hands【贪心】
  13. image.open()得到的图片是什么类型_复古门窗花格图片大全让精彩生活继续闪耀 「巴森」...
  14. Angular和Vue.js 深度对比
  15. 北京师范大学c语言题库,北京师范大学C语言题库.doc
  16. 邓侃:中国首个全过程智能诊疗系统,全方位披露技术核心和商业模式
  17. Beta版本 为什么程序员总是分不清万圣节和圣诞节?因为 Oct 31 == Dec 25。
  18. C语言经典案例——第六章 字符串
  19. error: #268: declaration may not appear after executable statement in block
  20. OpenCV中LBPH人脸识别器识别人脸实战(附Python源码)

热门文章

  1. 猝不及防,iOS9.3测试版已经遭到越狱?
  2. 物联网来了,智能城市离我们还有多远?
  3. 自己动手开发编译器(八)用Linq编写解析器组合子
  4. [转]VS .NET 2005中水晶报表的打包部署
  5. linux开机时驱动的加载流程
  6. (十五)洞悉linux下的Netfilteriptables:开发自己的hook函数【实战】
  7. 传输层协议(13):拥塞控制(2)
  8. OpenCV读取一张图片,并将其转换为灰度图像显示
  9. 线程相关函数(1)-pthread_create(), pthread_join(), pthread_exit(), pthread_cancel() 创建取消线程
  10. Linux下如何查看高CPU占用率线程 LINUX CPU利用率计算