源码分析Java中ThreadPoolExecutor的底层原理

 更新时间:2023年05月07日 09:06:24   作者:向猪羊  
这篇文章主要带大家从源码分析一下Java中ThreadPoolExecutor的底层原理,文中的示例代码讲解详细,具有一定的学习价值,需要的可以参考一下

一、根据代码查看jdk提供的3种线程池创建

public class TestController {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();//快
        ExecutorService executorService1 = Executors.newFixedThreadPool(10);//慢
        ExecutorService executorService2 = Executors.newSingleThreadExecutor();//很慢

        for (int i = 0; i < 100; i++) {
            executorService.execute(new MyTask(i));
        }
    }
}

class MyTask implements Runnable{
    private int i;

    public MyTask(int i) {
        this.i = i;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread()+"-"+i);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

在运行过程中可以发现3者速度有所差别,当然3者的速度要根据实际处理自行判别,此处只以此代码业务为例。

二、3种方式源码分析

1、Executors.newCachedThreadPool()

源码参数为:

0, 
Integer.MAX_VALUE,
60L, 
TimeUnit.SECONDS,
new SynchronousQueue<Runnable>()

以下图中的外包公司为例(结合图观看),corePoolSize为0,即核心员工数为0;maximumPoolSize为Integer.MAX_VALUE,即非核心员工数为2的31次方-1;且BlockingQueue为同步队列。当任务进来后分配给队列,通过队列分配给非核心员工,下一个任务再进入队列,以此循环执行,直到任务执行完成或者非核心员工都没有空闲时,执行拒绝策略。

2、Executors.newFixedThreadPool(10)

源码参数为:

nThreads, 
nThreads,
0L, 
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()

以下图中的外包公司为例(结合图观看),corePoolSize为10,即核心员工数为10;maximumPoolSize为10,即无非核心员工,且BlockingQueue为链表队列,链表队列最大数为2的31次方-1,若到达最大值后执行拒绝策略。当任务进来后分配10个任务给10个核心员工,其余任务进入链表队列,当核心员工有空闲时将链表队列中的某任务给与空闲员工。以此循环执行。

3、Executors.newSingleThreadExecutor()

源码参数为:

1, 
1,
0L, 
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()

以下图中的外包公司为例(结合图观看),corePoolSize为1,即核心员工数为1;maximumPoolSize为1,即无非核心员工,且BlockingQueue为链表队列,链表队列最大数为2的31次方-1,若到达最大值后执行拒绝策略。当任务进来后分配1个任务给1个核心员工,其余任务进入链表队列,当核心员工有空闲时将链表队列中的某任务给与空闲员工。以此循环执行。

三、自定义方式执行

    public class TestController {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();//快
        ExecutorService executorService1 = Executors.newFixedThreadPool(10);//慢
        ExecutorService executorService2 = Executors.newSingleThreadExecutor();//很慢
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 20,
                                0L, TimeUnit.MILLISECONDS,
                                            new ArrayBlockingQueue<Runnable>(10));
        for (int i = 0; i < 100; i++) {
            threadPoolExecutor.execute(new MyTask(i));
        }
    }
}

运行结果如图:

当线程执行到任务30时将会报出异常,为什么下面还会继续执行任务11-20呢?

其实这与提交优先级、执行优先级有关

提交优先级

在执行任务1-10是会将任务直接给核心员工,当任务11-20进来后会分配到队列等待,此时任务21-30进来后发现队列与核心员工中都存在任务,会将其分配给非核心员工执行。当40以后的任务进来后,由于没有空闲人员,将会抛出异常。

执行优先级

在执行任务1-10是会将任务直接给核心员工,任务11-20进来后会分配给非核心员工执行,当任务21-30进来后会分配到队列等待。当40以后的任务进来后,由于没有空闲人员,将会抛出异常。

以上就是源码分析Java中ThreadPoolExecutor的底层原理的详细内容,更多关于Java ThreadPoolExecutor的资料请关注脚本之家其它相关文章!

相关文章

  • Spring中@Qualifier注解的用法

    Spring中@Qualifier注解的用法

    但凡有点开发经验,多多少少可能都遇到过@Qualifier注解的使用场景,本文主要介绍了Spring中@Qualifier注解的用法,感兴趣的可以了解一下
    2023-11-11
  • SpringBoot动态定时功能实现方案详解

    SpringBoot动态定时功能实现方案详解

    在SpringBoot项目中简单使用定时任务,不过由于要借助cron表达式且都提前定义好放在配置文件里,不能在项目运行中动态修改任务执行时间,实在不太灵活。现在我们就来实现可以动态修改cron表达式的定时任务,感兴趣的可以了解一下
    2022-11-11
  • sentinel流量控制框架(目录设置)

    sentinel流量控制框架(目录设置)

    Sentinel 是面向分布式服务架构的高可用流量防护组件帮助开发者保障微服务的稳定性,本文重点给大家介绍sentinel流量控制框架的相关知识,感兴趣的朋友一起看看吧
    2022-03-03
  • Java数据脱敏常用方法(3种)

    Java数据脱敏常用方法(3种)

    数据脱敏常用在电话号码和身份证号,本文主要介绍了Java数据脱敏常用方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-07-07
  • Java Lock锁多线程中实现流水线任务

    Java Lock锁多线程中实现流水线任务

    这篇文章主要介绍了Java Lock锁多线程中实现流水线任务,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-05-05
  • 详解Java拦截器以及自定义注解的使用

    详解Java拦截器以及自定义注解的使用

    这篇文章主要为大家介绍了Java拦截器以及自定义注解的使用,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助<BR>
    2021-12-12
  • Java基于redis和mysql实现简单的秒杀(附demo)

    Java基于redis和mysql实现简单的秒杀(附demo)

    这篇文章主要介绍了Java基于redis和mysql实现简单的秒杀(附demo),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-02-02
  • Java使用RedisTemplate操作Redis遇到的坑

    Java使用RedisTemplate操作Redis遇到的坑

    这篇文章主要介绍了Java使用RedisTemplate操作Redis遇到的坑,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12
  • Java 实战项目之小说在线阅读系统的实现流程

    Java 实战项目之小说在线阅读系统的实现流程

    读万卷书不如行万里路,只学书上的理论是远远不够的,只有在实战中才能获得能力的提升,本篇文章手把手带你用java+SSM+jsp+mysql+maven实现前台阅读后台管理的小说在线阅读系统,大家可以在过程中查缺补漏,提升水平
    2021-11-11
  • IDEA 的基本介绍使用及断点调试技巧

    IDEA 的基本介绍使用及断点调试技巧

    IDEA 是 JetBrains 公司的产品,总部位于捷克的首都布拉格,IDEA在业界被公认为最好的 Java 开发工具,今天通过本文给大家介绍IDEA 的基本介绍使用及断点调试技巧,感兴趣的朋友跟随小编一起看看吧
    2021-11-11

最新评论