ThreadPoolExecutor运行机制

最近发现几起对ThreadPoolExecutor的误用,其中包括自己,发现都是因为没有仔细看注释和内部运转机制,想当然的揣测参数导致,先看一下新建一个ThreadPoolExecutor的构建参数:

 public ThreadPoolExecutor(int corePoolSize,  
  int maximumPoolSize,  
  long keepAliveTime,  
                           TimeUnit unit,  
                           BlockingQueue<Runnable> workQueue,  
                           ThreadFactory threadFactory,  
                           RejectedExecutionHandler handler)  

看这个参数很容易让人以为是线程池里保持corePoolSize个线程,如果不够用,就加线程入池直至maximumPoolSize大小,如果还不够就往workQueue里加,如果workQueue也不够就用RejectedExecutionHandler来做拒绝处理。

但实际情况不是这样,具体流程如下:

1)当池子大小小于corePoolSize就新建线程,并处理请求

2)当池子大小等于corePoolSize,把请求放入workQueue中,池子里的空闲线程就去从workQueue中取任务并处理

3)当workQueue放不下新入的任务时,新建线程入池,并处理请求,如果池子大小撑到了maximumPoolSize就用RejectedExecutionHandler来做拒绝处理

4)另外,当池子的线程数大于corePoolSize的时候,多余的线程会等待keepAliveTime长的时间,如果无请求可处理就自行销毁

内部结构如下所示:

从中可以发现ThreadPoolExecutor就是依靠BlockingQueue的阻塞机制来维持线程池,当池子里的线程无事可干的时候就通过workQueue.take()阻塞住。

其实可以通过Executes来学学几种特殊的ThreadPoolExecutor是如何构建的。

 public static ExecutorService newFixedThreadPool(int nThreads) {  
  return new ThreadPoolExecutor(nThreads, nThreads,  
                                   0L, TimeUnit.MILLISECONDS,  
  new LinkedBlockingQueue<Runnable>());  
 }  

newFixedThreadPool就是一个固定大小的ThreadPool

 public static ExecutorService newCachedThreadPool() {  
  return new ThreadPoolExecutor(0, Integer.MAX_VALUE,  
                                   60L, TimeUnit.SECONDS,  
  new SynchronousQueue<Runnable>());  
 }  

newCachedThreadPool比较适合没有固定大小并且比较快速就能完成的小任务,没必要维持一个Pool,这比直接new Thread来处理的好处是能在60秒内重用已创建的线程。

其他类型的ThreadPool看看构建参数再结合上面所说的特性就大致知道它的特性

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

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏行者常至

016.多线程-线程池的四种创建方式

版权声明:本文为博主原创文章,允许转载,请标明出处。 https://blog.csdn.net/qwdafedv/article/deta...

18030
来自专栏java 成神之路

java 线程池

25130
来自专栏吴伟祥

线程池总结 原

New Thread的弊端如下:        a、每次New Thread新建对象性能差。        b、线程缺乏统一的管理,可能无限制的新建线程,相...

10620
来自专栏杂烩

Java-ThreadPoolExecutor类

        handler:提交线程数量大于maximumPoolSize时的处理器

8420
来自专栏小勇DW3

ThreadPoolExecutor 线程池的源码解析

  上一篇从整体上介绍了Executor接口,从上一篇我们知道了Executor框架的最顶层实现是ThreadPoolExecutor类,Executors工厂...

14050
来自专栏码匠的流水账

聊聊rocketmq的SequenceProducerImpl

io/openmessaging/rocketmq/producer/SequenceProducerImpl.java

6810
来自专栏向治洪

React Native使用原生组件

概述 有时候App需要访问平台API,但React Native可能还没有相应的模块包装;或者你需要复用一些Java代码,而不是用Javascript重新实现一...

30580
来自专栏挖掘大数据

Spark整合Mongodb(附实例代码)

环境准备 mongodb下载 解压安装 启动mongodb服务 $MONGODB_HOME/bin/mongod --fork --dbpath=/root/...

46400
来自专栏xdecode

Java高并发之线程池详解

例如线程, jdbc连接等等, 在高并发场景中, 如果可以复用之前销毁的对象, 那么系统效率将大大提升.

16320
来自专栏JavaEdge

Java并发编程实战系列8之线程池的使用

ThreadPoolExecutor UML图: ? image ? image ? 8.1 在任务和执行策略之间隐形耦合 避免Thread starvati...

38490

扫码关注云+社区

领取腾讯云代金券