您当前的位置:首页 > 电脑百科 > 程序开发 > 编程百科

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

时间:2020-08-07 11:20:29  来源:  作者:

1 池化技术之线程池

什么是池化技术?简单来说就是优化资源的使用,我准备好了一些资源,有人要用就到我这里拿,用完了就还给我。而一个比较重要的的实现就是线程池。那么线程池用到了池化技术有什么好处呢?

  • 降低资源的消耗
  • 提高响应的速度
  • 方便管理

也就是 线程复用、可以控制最大并发数、管理线程

2 线程池的五种实现方式

其实线程池我更愿意说成四种封装实现方式,一种原始实现方式。这四种封装的实现方式都是依赖于最原始的的实现方式。所以这里我们先介绍四种封装的实现方式

2.1 newSingleThreadExecutor()

这个线程池很有意思,说是线程池,但是池子里面只有一条线程。如果线程因为异常而停止,会自动新建一个线程补充。我们可以测试一下:我们对线程池执行十条打印任务,可以发现它们用的都是同一条线程

    public static void test01() {
        ExecutorService threadPool = Executors.newSingleThreadExecutor();
        try {
            //对线程进行执行十条打印任务
            for(int i = 1; i <= 10; i++){
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"=>执行完毕!");
                });
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //用完线程池一定要记得关闭
            threadPool.shutdown();
        }
    }
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!

2.2 newFixedThreadPool(指定线程数量)

这个线程池是可以指定我们的线程池大小的,可以针对我们具体的业务和情况来分配大小。它是创建一个核心线程数跟最大线程数相同的线程池,因此池中的线程数量既不会增加也不会变少,如果有空闲线程任务就会被执行,如果没有就放入任务队列,等待空闲线程。我们同样来测试一下:

    public static void test02() {
        ExecutorService threadPool = Executors.newFixedThreadPool(5);
        try {
            //对线程进行执行十条打印任务
            for(int i = 1; i <= 10; i++){
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"=>执行完毕!");
                });
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //用完线程池一定要记得关闭
            threadPool.shutdown();
        }
    }

我们创建了五条线程的线程池,在打印任务的时候,可以发现线程都有进行工作

pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-2=>执行完毕!
pool-1-thread-3=>执行完毕!
pool-1-thread-5=>执行完毕!
pool-1-thread-4=>执行完毕!

2.3 newCachedThreadPool()

这个线程池是创建一个核心线程数为0,最大线程为Inter.MAX_VALUE的线程池,也就是说没有限制,线程池中的线程数量不确定,但如果有空闲线程可以复用,则优先使用,如果没有空闲线程,则创建新线程处理任务,处理完放入线程池。我们同样来测试一下

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

 

2.4 newScheduledThreadPool(指定最大线程数量)

创建一个没有最大线程数限制的可以定时执行线程池在这里,还有创建一个只有单个线程的可以定时执行线程池(Executors.newSingleThreadScheduledExecutor())这些都是上面的线程池扩展开来了,不详细介绍了。

3 介绍线程池的七大参数

上面我们也说到了线程池有五种实现方式,但是实际上我们就介绍了四种。那么最后一种是什么呢?不急,我们可以点开我们上面线程池实现方式的源码进行查看,可以发现

  • newSingleThreadExecutor()的实现源码
关于线程池的五种实现方式,七大参数,四种拒绝策略

 

而点开其他几个线程池到最后都可以发现,他们实际上用的就是这个ThreadPoolExecutor。我们把源代码粘过来分析,其实也就是这七大参数

    /**
     * Creates a new {@code ThreadPoolExecutor} with the given initial
     * parameters.
     *
     * @param corePoolSize the number of threads to keep in the pool, even
     *        if they are idle, unless {@code allowCoreThreadTimeOut} is set
     * @param maximumPoolSize the maximum number of threads to allow in the
     *        pool
     * @param keepAliveTime when the number of threads is greater than
     *        the core, this is the maximum time that excess idle threads
     *        will wait for new tasks before terminating.
     * @param unit the time unit for the {@code keepAliveTime} argument
     * @param workQueue the queue to use for holding tasks before they are
     *        executed.  This queue will hold only the {@code Runnable}
     *        tasks submitted by the {@code execute} method.
     * @param threadFactory the factory to use when the executor
     *        creates a new thread
     * @param handler the handler to use when execution is blocked
     *        because the thread bounds and queue capacities are reached
     * @throws IllegalArgumentException if one of the following holds:<br>
     *         {@code corePoolSize < 0}<br>
     *         {@code keepAliveTime < 0}<br>
     *         {@code maximumPoolSize <= 0}<br>
     *         {@code maximumPoolSize < corePoolSize}
     * @throws NullPointerException if {@code workQueue}
     *         or {@code threadFactory} or {@code handler} is null
     */
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler) {
        if (corePoolSize < 0 ||
            maximumPoolSize <= 0 ||
            maximumPoolSize < corePoolSize ||
            keepAliveTime < 0)
            throw new IllegalArgumentException();
        if (workQueue == null || threadFactory == null || handler == null)
            throw new NullPointerException();
        this.acc = System.getSecurityManager() == null ?
                null :
                AccessController.getContext();
        this.corePoolSize = corePoolSize;
        this.maximumPoolSize = maximumPoolSize;
        this.workQueue = workQueue;
        this.keepAliveTime = unit.toNanos(keepAliveTime);
        this.threadFactory = threadFactory;
        this.handler = handler;
    }

毫无悬念,这就是最后一种方式,也是其他实现方式的基础。而用这种方式也是最容易控制,因为我们可以自由的设置参数。在阿里巴巴开发手册中也提到了

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

 

所以我们更需要去了解这七大参数,在平时用线程池的时候尽量去用ThreadPoolExecutor。而关于这七大参数我们简单概括就是

  • corePoolSize: 线程池核心线程个数
  • workQueue: 用于保存等待执行任务的阻塞队列
  • maximunPoolSize: 线程池最大线程数量
  • ThreadFactory: 创建线程的工厂
  • RejectedExecutionHandler: 队列满,并且线程达到最大线程数量的时候,对新任务的处理策略
  • keeyAliveTime: 空闲线程存活时间
  • TimeUnit: 存活时间单位

3.1 而关于线程池最大线程数量,我们也有两种设置方式

  1. CPU密集型
    获得cpu的核数,不同的硬件不一样,设置核数的的线程数量。
    我们可以通过代码Runtime.getRuntime().availableProcessors();获取,然后设置。
  2. IO密集型
    IO非常消耗资源,所以我们需要计算大型的IO程序任务有多少个。
    一般来说,线程池最大值 > 大型任务的数量即可
    一般设置大型任务的数量*2

这里我们用一个例子可以更好理解这些参数在线程池里面的位置和作用。如图1.0,我们这是一个银行

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

 

我们一共有五个柜台,可以理解为线程池的最大线程数量,而其中有两个是在营业中,可以理解为线程池核心线程个数。而下面的等待厅可以理解为用于保存等待执行任务的阻塞队列。银行就是创建线程的工厂。而关于空闲线程存活时间,我们可以理解为如图1.1这种情况,当五个营业中,却只有两个人需要被服务,而其他三个人一直处于等待的情况下,等了一个小时了,他们被通知下班了。这一个小时时间就可以说是空闲线程存活时间,而存活时间单位,顾名思义。

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

 

到现在我们就剩一个拒绝策略还没介绍,什么是拒绝策略呢?我们可以假设当银行五个柜台都有人在被服务,如图1.2。而等待厅这个时候也是充满了人,银行实在容不下人了。

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

 

这个时候对银行外面那个等待的人的处理策略就是拒绝策略。我们同样了解之后用代码来测试一下:

    public static  void test05(){
        ExecutorService threadPool = new ThreadPoolExecutor(
                //核心线程数量
                2,
                //最大线程数量
                5,
                //空闲线程存活时间
                3,
                //存活单位
                TimeUnit.SECONDS,
                //这里我们使用大多数线程池都默认使用的阻塞队列,并使容量为3
                new LinkedBlockingDeque<>(3),
                Executors.defaultThreadFactory(),
                //我们使用默认的线程池都默认用的拒绝策略
                new ThreadPoolExecutor.AbortPolicy()

        );
        try {
            //对线程进行执行十条打印任务
            for(int i = 1; i <= 2; i++){
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"=>执行完毕!");
                });
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //用完线程池一定要记得关闭
            threadPool.shutdown();
        }

    }

我们执行打印两条任务,可以发现线程池只用到了我们的核心两条线程,相当于只有两个人需要被服务,所以我们就开了两个柜台。

pool-1-thread-1=>执行完毕!
pool-1-thread-2=>执行完毕!

但是在我们将打印任务改到大于5的时候,(我们改成8)我们可以发现线程池的五条线程都在使用了,人太多了,我们的银行需要都开放了来服务。

for(int i = 1; i <= 8; i++)
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-2=>执行完毕!
pool-1-thread-3=>执行完毕!
pool-1-thread-4=>执行完毕!
pool-1-thread-5=>执行完毕!

在我们改成大于8的时候,可以发现拒绝策略触发了。银行实在容纳不下了,所以我们把外面那个人用策略打发了。

for(int i = 1; i <= 9; i++)
关于线程池的五种实现方式,七大参数,四种拒绝策略

 

在这里我们也可以得出一个结论:线程池大小= 最大线程数 + 阻塞队列大小

在上面我们在使用的阻塞队列是大多数的线程池都使用的阻塞队列,所以就引发思考下面这个问题。

3.2 为什么大部分的线程池都用LinkedBlockingQueue?

  • LinkedBlockingQueue 使用单向链表实现,在声明LinkedBlockingQueue的时候,可以不指定队列长度,长度为Integer.MAX_VALUE, 并且新建了一个Node对象,Node对象具有item,next变量,item用于存储元素,next指向链表下一个Node对象,在刚开始的时候链表的head,last都指向该Node对象,item、next都为null,新元素放在链表的尾部,并从头部取元素。取元素的时候只是一些指针的变化,LinkedBlockingQueue给put(放入元素),take(取元素)都声明了一把锁,放入和取互不影响,效率更高。
  • ArrayBlockingQueue 使用数组实现,在声明的时候必须指定长度,如果长度太大,造成内存浪费,长度太小,并发性能不高,如果数组满了,就无法放入元素,除非有其他线程取出元素,放入和取出都使用同一把锁,因此存在竞争,效率比LinkedBlockingQueue低。

4 四种策略

我们在使用ThreadPoolExecutor的时候是可以自己选择拒绝策略的,而拒绝策略我们所知道的有四种。

  • AbortPolicy(被拒绝了抛出异常)
  • CallerRunsPolicy(使用调用者所在线程执行,就是哪里来的回哪里去)
  • DiscardOldestPolicy(尝试去竞争第一个,失败了也不抛异常)
  • DiscardPolicy(默默丢弃、不抛异常)

4.1 AbortPolicy

我们在上面使用的就是AbortPolicy拒绝策略,在执行打印任务超出线程池大小的时候,抛出了异常。

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

 

4.2 CallerRunsPolicy

我们将拒绝策略修改为CallerRunsPolicy,执行后可以发现,因为第九个打印任务被拒绝了,所以它被调用者所在的线程执行了,也就是我们的main线程。(因为它从main线程来的,现在又回到了main线程。所以我们说它从哪里来回哪里去)

        ExecutorService threadPool = new ThreadPoolExecutor(
                //核心线程数量
                2,
                //最大线程数量
                5,
                //空闲线程存活时间
                3,
                //存活单位
                TimeUnit.SECONDS,
                //这里我们使用大多数线程池都默认使用的阻塞队列,并使容量为3
                new LinkedBlockingDeque<>(3),
                Executors.defaultThreadFactory(),
                //我们使用默认的线程池都默认用的拒绝策略
                new ThreadPoolExecutor.CallerRunsPolicy()

        );
pool-1-thread-2=>执行完毕!
main=>执行完毕!
pool-1-thread-2=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-2=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-3=>执行完毕!
pool-1-thread-4=>执行完毕!
pool-1-thread-5=>执行完毕!

4.3 DiscardOldestPolicy

尝试去竞争第一个任务,但是失败了。这里就没显示了,也不抛出异常。

pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-2=>执行完毕!
pool-1-thread-3=>执行完毕!
pool-1-thread-4=>执行完毕!
pool-1-thread-5=>执行完毕!

4.4 DiscardPolicy

多出来的任务,默默抛弃掉,也不抛出异常。

pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-1=>执行完毕!
pool-1-thread-2=>执行完毕!
pool-1-thread-3=>执行完毕!
pool-1-thread-4=>执行完毕!
pool-1-thread-5=>执行完毕!

可以看到我们的DiscardOldestPolicy与DiscardPolicy一样的结果,但是它们其实是不一样,正如我们最开始总结的那样,DiscardOldestPolicy在多出的打印任务的时候会尝试去竞争,而不是直接抛弃掉,但是很显然竞争失败不然也不会和DiscardPolicy一样的执行结果。但是如果在线程比较多的时候就可以很看出来。



Tags:线程池   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
原文链接: https://mp.weixin.qq.com/s/MTw7z6n_wk4y4CTmGkoRoA一切要从CPU说起你可能会有疑问,讲多线程为什么要从CPU说起呢?原因很简单,在这里没有那些时髦的概念,你可以更加清...【详细内容】
2021-08-13  Tags: 线程池  点击:(96)  评论:(0)  加入收藏
多线程并发是Java语言中非常重要的一块内容,同时,也是Java基础的一个难点。说它重要是因为多线程是日常开发中频繁用到的知识,说它难是因为多线程并发涉及到的知识点非常之多,想...【详细内容】
2021-07-12  Tags: 线程池  点击:(110)  评论:(0)  加入收藏
1. Dubbo简介及线程池策略Apache Dubbo 是一款高性能、轻量级的开源 Java 服务框架。提供了六大核心能力:面向接口代理的高性能RPC调用,智能容错和负载均衡,服务自动注册和发现...【详细内容】
2021-05-18  Tags: 线程池  点击:(202)  评论:(0)  加入收藏
在上一篇文章C++使用socket实现与微信小程序通信(下)中,小懵白就给大家简要地讲解了线程池的原理。 今天呢,小懵白就给大家继续讲解C++如何实现封装线程池类。第一步首先,我们需...【详细内容】
2021-05-14  Tags: 线程池  点击:(204)  评论:(0)  加入收藏
见字如面,我是威哥,一个从普通二本院校毕业,从未曾接触分布式、微服务、高并发到通过技术分享实现职场蜕变,成长为RocketMQ社区优秀布道师、大厂资深架构师,出版《RocketMQ技...【详细内容】
2021-03-31  Tags: 线程池  点击:(277)  评论:(0)  加入收藏
作者公众号:一角钱技术(org_yijiaoqian)前言线程池的具体实现有两种,分别是ThreadPoolExecutor 默认线程池和ScheduledThreadPoolExecutor 定时线程池,上一篇已经分析过ThreadPoo...【详细内容】
2020-12-22  Tags: 线程池  点击:(143)  评论:(0)  加入收藏
之前我们介绍了线程池的四种拒绝策略,了解了线程池参数的含义,那么今天我们来聊聊Java 中常见的几种线程池,以及在jdk7 加入的 ForkJoin 新型线程池 首先我们列出Java 中的...【详细内容】
2020-11-05  Tags: 线程池  点击:(91)  评论:(0)  加入收藏
前面几篇文章分析了线程的主要实现,今天来整体总结以下他们。总览图直接上总结的总览图,如下图: 如果看过前几篇文章应该基本能够看懂这张总结图,可能在单独的一篇文章里弄懂了...【详细内容】
2020-09-08  Tags: 线程池  点击:(63)  评论:(0)  加入收藏
大多数线程池实现都离不开锁的使用,如互斥量pthread_mutex*结合条件变量pthread_cond*。众所周知,锁的使用对于程序性能影响较大,虽然现有的pthread_mutex*在锁的申请与释放方...【详细内容】
2020-08-24  Tags: 线程池  点击:(87)  评论:(0)  加入收藏
作为 Java 程序员,无论是技术面试、项目研发或者是学习框架源码,不彻底掌握 Java 多线程的知识,做不到心中有数,干啥都没底气,尤其是技术深究时往往略显发憷。坐稳扶好,通过今天的...【详细内容】
2020-08-12  Tags: 线程池  点击:(48)  评论:(0)  加入收藏
▌简易百科推荐
摘 要 (OF作品展示)OF之前介绍了用python实现数据可视化、数据分析及一些小项目,但基本都是后端的知识。想要做一个好看的可视化大屏,我们还要学一些前端的知识(vue),网上有很多比...【详细内容】
2021-12-27  项目与数据管理    Tags:Vue   点击:(1)  评论:(0)  加入收藏
程序是如何被执行的&emsp;&emsp;程序是如何被执行的?许多开发者可能也没法回答这个问题,大多数人更注重的是如何编写程序,却不会太注意编写好的程序是如何被运行,这并不是一个好...【详细内容】
2021-12-23  IT学习日记    Tags:程序   点击:(9)  评论:(0)  加入收藏
阅读收获✔️1. 了解单点登录实现原理✔️2. 掌握快速使用xxl-sso接入单点登录功能一、早期的多系统登录解决方案 单系统登录解决方案的核心是cookie,cookie携带会话id在浏览器...【详细内容】
2021-12-23  程序yuan    Tags:单点登录(   点击:(8)  评论:(0)  加入收藏
下载Eclipse RCP IDE如果你电脑上还没有安装Eclipse,那么请到这里下载对应版本的软件进行安装。具体的安装步骤就不在这赘述了。创建第一个标准Eclipse RCP应用(总共分为六步)1...【详细内容】
2021-12-22  阿福ChrisYuan    Tags:RCP应用   点击:(7)  评论:(0)  加入收藏
今天想简单聊一聊 Token 的 Value Capture,就是币的价值问题。首先说明啊,这个话题包含的内容非常之光,Token 的经济学设计也可以包含诸多问题,所以几乎不可能把这个问题说的清...【详细内容】
2021-12-21  唐少华TSH    Tags:Token   点击:(9)  评论:(0)  加入收藏
实现效果:假如有10条数据,分组展示,默认在当前页面展示4个,点击换一批,从第5个开始继续展示,到最后一组,再重新返回到第一组 data() { return { qList: [], //处理后...【详细内容】
2021-12-17  Mason程    Tags:VUE   点击:(14)  评论:(0)  加入收藏
什么是性能调优?(what) 为什么需要性能调优?(why) 什么时候需要性能调优?(when) 什么地方需要性能调优?(where) 什么时候来进行性能调优?(who) 怎么样进行性能调优?(How) 硬件配...【详细内容】
2021-12-16  软件测试小p    Tags:性能调优   点击:(19)  评论:(0)  加入收藏
Tasker 是一款适用于 Android 设备的高级自动化应用,它可以通过脚本让重复性的操作自动运行,提高效率。 不知道从哪里听说的抖音 app 会导致 OLED 屏幕烧屏。于是就现学现卖,自...【详细内容】
2021-12-15  ITBang    Tags:抖音防烧屏   点击:(23)  评论:(0)  加入收藏
11 月 23 日,Rust Moderation Team(审核团队)在 GitHub 上发布了辞职公告,即刻生效。根据公告,审核团队集体辞职是为了抗议 Rust 核心团队(Core team)在执行社区行为准则和标准上...【详细内容】
2021-12-15  InfoQ    Tags:Rust   点击:(24)  评论:(0)  加入收藏
一个项目的大部分API,测试用例在参数和参数值等信息会有很多相似的地方。我们可以复制API,复制用例来快速生成,然后做细微调整既可以满足我们的测试需求1.复制API:在菜单发布单...【详细内容】
2021-12-14  AutoMeter    Tags:AutoMeter   点击:(20)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条