专栏首页JavaQconcurrent包下线程池类小结

concurrent包下线程池类小结

并发包下的线程池技术虽然常用,但是知识点较多易忘。所以,参考网络资源做了一个小结,便于复习。

Executor接口

用于执行已提交的Runnable任务。

ExecutorService接口

继承自Executor接口。

ScheduledExecutorService接口

继承自ExecutorService接口,在给定的延迟后执行任务或定时执行任务,类图如下。

RejectedExecutionHandler接口

当Executor已经关闭或任务队列已经饱和时,提交新任务时,Executor对应的处理策略。

RejectedExecutionHandler接口实现类

RejectedExecutionHandler接口4个实现类对应4种处理策略:

BlockingQueue接口

BlockingQueue接口定义任务队列。

ArrayBlockingQueue类

实现了BlockingQueue接口。一个由数组支持的有界阻塞队列。此队列按 FIFO(先进先出)原则对元素进行排序。队列的头部是在队列中存在时间最长的元素。队列的尾部是在队列中存在时间最短的元素。新元素插入到队列的尾部,队列获取操作则是从队列头部开始获得元素。类图如下图所示。

Executors类

为ExecutorService、ScheduledExecutorService、ThreadFactory和Callable提供了便捷的工厂方法。

此类支持以下各种方法:

  • 创建并返回设置有常用配置字符串的 ExecutorService 的方法。
  • 创建并返回设置有常用配置字符串的 ScheduledExecutorService 的方法。
  • 创建并返回“包装的”ExecutorService 方法,它通过使特定于实现的方法不可访问来禁用重新配置。
  • 创建并返回 ThreadFactory 的方法,它可将新创建的线程设置为已知的状态。
  • 创建并返回非闭包形式的 Callable 的方法,这样可将其用于需要 Callable 的执行方法中。

ThreadPoolExecutor类

类图如下图所示。

ThreadPoolExecutor使用Executors工厂方法Executors.newCachedThreadPool()(无界线程池,可以进行自动线程回收)、Executors.newFixedThreadPool(int)(固定大小线程池)和 Executors.newSingleThreadExecutor()(单个后台线程)配置的线程池执行每个提交的任务。

使用构造方法可以创建一个自定义的线程池。ThreadPoolExecutor将根据corePoolSize和maximumPoolSize设置的边界自动调整池大小。当新任务在方法execute(java.lang.Runnable) 中提交时,如果运行的线程少于corePoolSize,则创建新线程来处理请求,即使其他辅助线程是空闲的。如果运行的线程多于corePoolSize而少于 maximumPoolSize,则仅当队列满时才创建新线程。如果设置的corePoolSize和maximumPoolSize相同,则创建了固定大小的线程池。如果将 maximumPoolSize 设置为基本的无界值(如Integer.MAX_VALUE),则允许池适应任意数量的并发任务。在大多数情况下,核心和最大池大小仅基于构造来设置,不过也可以使用setCorePoolSize(int)和 setMaximumPoolSize(int)进行动态更改。所有BlockingQueue都可用于传输和保持提交的任务。可以使用此队列与池大小进行交互:

  • 如果运行的线程少于corePoolSize,则Executor始终首选添加新的线程,而不进行排队。
  • 如果运行的线程等于或多于corePoolSize,则Executor始终首选将请求加入队列,而不添加新的线程。
  • 如果无法将请求加入队列,则创建新的线程,除非创建此线程超出maximumPoolSize,在这种情况下,任务将被拒绝。

ScheduledThreadPoolExecutor类

实现了ScheduledExecutorService接口,在给定的延迟后执行任务,或者定时执行任务,按照提交的先进先出(FIFO)顺序来启用那些被安排在同一执行时间的任务。类图如下所示。

虽然此类继承自ThreadPoolExecutor,但是几个继承的调整方法对此类并无作用。特别是,因为它作为一个使用corePoolSize 线程和一个无界队列的固定大小的池,所以调整maximumPoolSize没有什么效果。

本文分享自微信公众号 - JavaQ(Java-Q)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2016-09-22

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 高并发编程-ReentrantLock公平锁深入解析

    ReentrantLock是一个可重入的互斥锁,它不但具有synchronized实现的同步方法和同步代码块的基本行为和语义,而且具备很强的扩展性。Reentr...

    JavaQ
  • 高并发编程-CyclicBarrier深入解析

    CyclicBarrier是一个同步辅助类,它允许一组线程互相等待,直到所有线程都到达某个公共屏障点(也可以叫同步点),即相互等待的线程都完成调用await方法...

    JavaQ
  • 我画了25张图展示线程池工作原理和实现原理,原创干货,建议先收藏再阅读

    有朋友留言提到文中的场景是IO密集型操作,不是CPU密集操作,不需要使用线程池,我猜这位朋友可能想表达的是IO密集且阻塞时间久的不要使用线程池方案解决。IO密集...

    JavaQ
  • 【小家java】BlockingQueue阻塞队列详解以及5大实现(ArrayBlockingQueue、DelayQueue、LinkedBlockingQueue...)

    在新增的Concurrent包中,BlockingQueue很好的解决了多线程中,如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类,为我们快速搭...

    YourBatman
  • 程序员修仙之路--设计一个实用的线程池

    经过一个多小时的代码排查终于查明了线上程序线程数过多的原因:这是一个接收mq消息的一个服务,程序大体思路是这样的,监听的线程每次收到一条消息,就...

    架构师修行之路
  • Apache Jmeter 性能测试

    今天在写性能测试报告的时候需要使用到数据,打算用做一下性能测试,然后在百度后发现了一款Apache开源的Jmeter压测工具

    彼岸舞
  • 在阿里面试官面前现场手撕DelayQueue源码!

    延迟元素的无边界阻塞队列,在该队列中,仅当元素的延迟到期时才可以使用它. 队首是该 Delayed 元素,其延迟在过去最远过期. 如果没有延迟已经过期,就没...

    JavaEdge
  • DelayQueue 核心源码解析

    当元素的getDelay(TimeUnit.NANOSECONDS)方法返回的值小于或等于零时,就会发生过期.

    JavaEdge
  • 线程之生产者消费者模式

    前几篇复习了下《线程的创建方式》、《线程的状态》、《Thread 的源码解析》、《wait、notify/notifyAll 源码解析》这几篇文章。这篇是第五篇...

    一个优秀的废人
  • MySQL50-9-第31-35题

    查询每门课程的平均成绩,结果按平均成绩降序排列;平均成绩相同时,按课程编号c_id升序排列

    皮大大

扫码关注云+社区

领取腾讯云代金券