当前位置:主页 > java教程 > java中ThreadPoolExecutor常识汇总

分享java中ThreadPoolExecutor常识总结

发布:2020-02-17 15:58:01 189


给网友朋友们带来一篇Java相关的编程文章,网友欧阳州根据主题投稿了本篇教程内容,涉及到java、ThreadPoolExecutor、java中ThreadPoolExecutor常识汇总相关内容,已被106网友关注,涉猎到的知识点内容可以在下方电子书获得。

java中ThreadPoolExecutor常识汇总

线程池技术在并发时经常会使用到,java中的线程池的使用是通过调用ThreadPoolExecutor来实现的。ThreadPoolExecutor提供了四个构造函数,最后都会归结于下面这个构造方法:

// 七个参数的构造函数
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)

这些参数的意义如下:

  • corePoolSize:该线程池中核心线程数最大值
  • maximumPoolSize: 该线程池中线程总数最大值
  • keepAliveTime:该线程池中非核心线程闲置超时时长
  • unit:keepAliveTime的单位
  • workQueue:阻塞队列BlockingQueue,维护着等待执行的Runnable对象
  • threadFactory:创建线程的接口,需要实现他的Thread newThread(Runnable r)方法。
  • RejectedExecutionHandler:饱和策略,最大线程和工作队列容量且已经饱和时execute方法都将调用RejectedExecutionHandler 。

ThreadPoolExecutor工作流程

流程图如下:

java中ThreadPoolExecutor常识汇总

大致过程陈述为:

  1. 向线程池中添加任务,当任务数量少于corePoolSize时,会自动创建thead来处理这些任务;
  2. 当添加任务数大于corePoolSize且少于maximmPoolSize时,不在创建线程,而是将这些任务放到阻塞队列中,等待被执行;
  3. 接上面2的条件,且当阻塞队列满了之后,继续创建thread,从而加速处理阻塞队列;
  4. 当添加任务大于maximmPoolSize时,根据饱和策略决定是否容许继续向线程池中添加任务,默认的饱和策略是AbortPolicy(直接丢弃)。

线程池中使用的阻塞队列

  • ArrayBlockingQueue:基于数组结构的有界阻塞队列,构造函数一定要传大小,FIFO(先进先出);
  • LinkedBlockingQueue:无界,默认大小65536(Integer.MAX_VALUE),当大量请求任务时,容易造成内存耗尽。
  • SynchronousQueue:同步队列,是一个特殊的BlockingQueue,它没有容量(这是因为在SynchronousQueue中,插入将等待另一个线程的删除操作,反之亦然)。具体可以参考:《Java SynchronousQueue Examples(译)》
  • PriorityBlockingQueue: 优先队列,无界。
  • DelayedWorkQueue:这个队列接收到任务时,首先先入队,只有达到了指定的延时时间,才会执行任务

阻塞队列常见的方法如下表所示:

 

方法名 说明 注意
add 增加一个元索 如果队列已满,则抛出一个IIIegaISlabEepeplian异常
remove 移除并返回队列头部的元素 如果队列为空,则抛出一个NoSuchElementException异常
element 返回队列头部的元素 如果队列为空,则抛出一个NoSuchElementException异常
offer 添加一个元素并返回true 如果队列已满,则返回false
poll 移除并返问队列头部的元素 如果队列为空,则返回null
peek 返回队列头部的元素 如果队列为空,则返回null
put 添加一个元素 如果队列满,则阻塞
take 移除并返回队列头部的元素 如果队列为空,则阻塞

 

常见四种线程池

  • newCachedThreadPool
  • newFixedThreadPool
  • newSingleThreadExecutor
  • newScheduledThreadPool

 

线程池 使用的阻塞队列 线程池大小 超时
CachedThreadPool SynchronousQueue(队列长度无限 可增加,最大值Integer.MAX_VALUE 默认60秒超时
FixedThreadPool LinkedBlockingQueue(队列长度无限) 可指定nThreads,固定数量 不会超时
newSingleThreadExecutor LinkedBlockingQueue(队列长度无限), 固定为1 不超时
newScheduledThreadPool DelayedWorkQueue 可增加,最大值Integer.MAX_VALUE 不超时

 

它们通过Executors以静态方法的方式直接调用,实质上是它们最终调用的是ThreadPoolExecutor的构造方法,也就是本文最前面那段代码。

注:KeepAliveTime=0的话,表示不等待

《阿里巴巴java开发手册》中建议线程池不使用 Executors 去创建,而是通过 ThreadPoolExecutor的方式,这样的处理方式让写的人员更加明确线程池的运行规则,规避资源耗尽的风险。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持码农之家。


参考资料

相关文章

  • 为什么 Java 8 中不需要 StringBuilder 拼接字符串

    为什么 Java 8 中不需要 StringBuilder 拼接字符串

    发布:2022-10-19

    给网友们整理关于Java的教程,java8中,编辑器对“+”进行了优化,默认使用StringBuilder进行拼接,所以不用显示的使用StringBuilder了,直接用“+”就可以了。下面我们来详细了解一下


  • 浅谈java什么时候需要用序列化 

    发布:2023-04-26

    本文主要介绍了浅谈java什么时候需要用序列化,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧


  • Java设计模式中的迭代器模式详解

    发布:2023-04-08

    迭代器模式官方解释就是提供一个对象来顺序访问聚合对象中的一系列数据,而不暴露聚合对象的内部表示。何为聚合对象呢?最典型的就是集合类。大白话也就是,集合中的数据是私有的,集合中不应该提供直接遍历的方法,要定义一个新的对象用于访问这个集合


  • 通过Java实现设置Word文档页边距的方法详解

    发布:2023-03-26

    页边距是指页面的边线到文字的距离。通常可在页边距内部的可打印区域中插入文字和图形等。今天这篇文章将为您展示如何通过编程方式,设置Word 文档页边距,感兴趣的可以了解一下


  • java中实现创建目录与创建文件的操作实例

    发布:2023-04-25

    用Java创建文件或目录非常简单,下面这篇文章主要给大家介绍了关于java中实现创建目录与创建文件的操作实例,文中通过实例代码介绍的非常详细,需要的朋友可以参考下


  • Java使用DateUtils对日期进行数学运算经典应用示例【附DateUtils相关包文件下载】

    发布:2022-04-13

    这篇文章主要介绍了Java使用DateUtils对日期进行数学运算的方法,可实现针对日期时间的各种常见运算功能,并附带DateUtils的相关包文件供读者下载使用,需要的朋友可以参考下


  • JS小程序页面动态配置实现方法

    发布:2021-06-10

    这篇文章主要介绍了小程序页面动态配置实现方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧


  • Java properties 和 yml 的区别解析

    发布:2023-03-31

    properties和yml都是Spring Boot支持的两种配置文件,它们可以看做Spring Boot在不同时期的两种“产品”,这篇文章主要介绍了Java properties 和 yml 的区别,需要的朋友可以参考下


网友讨论