Java多线程中的ThreadPoolExecutor解读

 更新时间:2023年09月15日 10:07:34   作者:「已注销」  
这篇文章主要介绍了Java多线程中的ThreadPoolExecutor解读,线程池中的核心线程数,当提交一个任务时,线程池创建一个新线程执行任务,直到当前线程数等于corePoolSize;如果当前线程数为corePoolSize,继续提交的任务被保存到阻塞队列中,等待被执行,需要的朋友可以参考下

corePoolSize

线程池中的核心线程数。当提交一个任务时,线程池创建一个新线程执行任务,直到当前线程数等于corePoolSize;如果当前线程数为corePoolSize,继续提交的任务被保存到阻塞队列中,等待被执行。

maximumPoolSize

线程池中允许的最大线程数。如果当前阻塞队列满了,且继续提交任务,则创建新的线程执行任务,前提是当前线程数小于maximumPoolSize。

keepAliveTime

线程空闲时的存活时间。默认情况下,只有当线程池中的线程数大于corePoolSize时,keepAliveTime才会起作用,如果一个线程空闲的时间达到keepAliveTime,则会终止,直到线程池中的线程数不超过corePoolSize。但是如果调用了allowCoreThreadTimeOut(boolean)方法,keepAliveTime参数也会起作用,直到线程池中的线程数为0。

unit

keepAliveTime参数的时间单位。

workQueue

任务缓存队列,用来存放等待执行的任务。如果当前线程数为corePoolSize,继续提交的任务就会被保存到任务缓存队列中,等待被执行。 一般来说,这里的BlockingQueue有以下三种选择:

1.SynchronousQueue:一个不存储元素的阻塞队列,每个插入操作必须等到另一个线程调用移除操作,否则插入操作一直处于阻塞状态。因此,如果线程池中始终没有空闲线程(任务提交的平均速度快于被处理的速度),可能出现无限制的线程增长。

2.LinkedBlockingQueue:基于链表结构的阻塞队列,如果不设置初始化容量,其容量为Integer.MAX_VALUE,即为无界队列。因此,如果线程池中线程数达到了corePoolSize,且始终没有空闲线程(任务提交的平均速度快于被处理的速度),任务缓存队列可能出现无限制的增长。

3.ArrayBlockingQueue:基于数组结构的有界阻塞队列,按FIFO排序任务。

threadFactory

线程工厂,创建新线程时使用的线程工厂。

handler

任务拒绝策略,当阻塞队列满了,且线程池中的线程数达到maximumPoolSize,如果继续提交任务,就会采取任务拒绝策略处理该任务,线程池提供了4种任务拒绝策略:

1.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常,默认策略;

2.CallerRunsPolicy:由调用execute方法的线程执行该任务;

3.DiscardPolicy:丢弃任务,但是不抛出异常;

4.DiscardOldestPolicy:丢弃阻塞队列最前面的任务,然后重新尝试执行任务(重复此过程)。 当然也可以根据应用场景实现RejectedExecutionHandler接口,自定义饱和策略,如记录日志或持久化存储不能处理的任务。

public static void main(String[] args) {
    int corePoolSize = 0;
    int maximumPoolSize = 0;
    long keepAliveTime = 0;
    TimeUnit unit = TimeUnit.SECONDS;
    //1.SynchronousQueue:一个不存储元素的阻塞队列,每个插入操作必须等到另一个线程调用移除操作,
    //否则插入操作一直处于阻塞状态。因此,如果线程池中始终没有空闲线程(任务提交的平均速度快于被处理的速度),
    //可能出现无限制的线程增长。
    //2.LinkedBlockingQueue:基于链表结构的阻塞队列,如果不设置初始化容量,
    //其容量为Integer.MAX_VALUE,即为无界队列。因此,如果线程池中线程数达到了corePoolSize,
    //且始终没有空闲线程(任务提交的平均速度快于被处理的速度),任务缓存队列可能出现无限制的增长。
    //3.ArrayBlockingQueue:基于数组结构的有界阻塞队列,按FIFO排序任务。
    BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
    ThreadFactory threadFactory = new ThreadFactory() {
      @Override
      public Thread newThread(Runnable r) {
        return new Thread("newThread");
      }
    };
    //1.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常,默认策略;
    //2.CallerRunsPolicy:由调用execute方法的线程执行该任务;
    //3.DiscardPolicy:丢弃任务,但是不抛出异常;
    //4.DiscardOldestPolicy:丢弃阻塞队列最前面的任务,然后重新尝试执行任务(重复此过程)。
    RejectedExecutionHandler handler = new RejectedExecutionHandler() {
      @Override
      public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
      }
    };
    ThreadPoolExecutor threadPoolExecutor = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime,
            unit, 
            workQueue);
    ThreadPoolExecutor threadPoolExecutor1 = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime,
            unit, 
            workQueue, 
            threadFactory);
    ThreadPoolExecutor threadPoolExecutor2 = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime, 
            unit, 
            workQueue, 
            handler);
    ThreadPoolExecutor threadPoolExecutor3 = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime, 
            unit, 
            workQueue, 
            threadFactory, 
            handler);
  }

到此这篇关于Java多线程中的ThreadPoolExecutor解读的文章就介绍到这了,更多相关ThreadPoolExecutor解读内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Spring Boot优化后启动速度快到飞起技巧示例

    Spring Boot优化后启动速度快到飞起技巧示例

    这篇文章主要为大家介绍了Spring Boot优化后启动速度快到飞起的技巧示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-07-07
  • java实现微信抢红包算法

    java实现微信抢红包算法

    这篇文章主要为大家详细介绍了java实现微信抢红包算法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-09-09
  • 新版idea如何开启多台JVM虚拟机的流程步骤

    新版idea如何开启多台JVM虚拟机的流程步骤

    在IntelliJ IDEA这个集成开发环境中(IDE),开启JVM(Java Virtual Machine)通常是在运行Java应用程序时的操作,本文给大家介绍了新版idea如何开启多台JVM虚拟机的流程步骤,需要的朋友可以参考下
    2024-10-10
  • Java简单实现SpringMVC+MyBatis分页插件

    Java简单实现SpringMVC+MyBatis分页插件

    自己最近搭建的一个SpringMVC+Mybatis的框架 属于无实体类的框架 并实现了Myabtis的自动分页和总数查询 只要传入分页参数便能自动查询总数和分页 总数封装在参数里面执行查询后可以直接从参数中获取
    2015-09-09
  • java实现一个简单的Web服务器实例解析

    java实现一个简单的Web服务器实例解析

    这篇文章主要介绍了java实现一个简单的Web服务器实例解析,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-02-02
  • IDEA-Maven项目的jdk版本设置方法

    IDEA-Maven项目的jdk版本设置方法

    我们需要设置jdk的版本,不然会提示导致语法错误,这篇文章主要介绍了IDEA-Maven项目的jdk版本设置方法,小编觉得不错,一起来了解一下
    2019-04-04
  • Java中SynchronousQueue的底层实现原理剖析

    Java中SynchronousQueue的底层实现原理剖析

    BlockingQueue的实现类中,有一种阻塞队列比较特殊,就是SynchronousQueue(同步移交队列),队列长度为0。本文就来剖析一下SynchronousQueue的底层实现原理,感兴趣的可以了解一下
    2022-11-11
  • 基于创建Web项目运行时出错的解决方法(必看篇)

    基于创建Web项目运行时出错的解决方法(必看篇)

    下面小编就为大家带来一篇基于创建Web项目运行时出错的解决方法。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • java依赖混乱存在的问题与解决方案

    java依赖混乱存在的问题与解决方案

    这篇文章主要为大家介绍了java依赖混乱存在的问题与解决方案,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-09-09
  • Java 8 的异步编程利器 CompletableFuture的实例详解

    Java 8 的异步编程利器 CompletableFuture的实例详解

    这篇文章主要介绍了Java 8 的异步编程利器 CompletableFuture 详解,本文通过一个例子给大家介绍下Java 8  CompletableFuture异步编程的相关知识,需要的朋友可以参考下
    2022-03-03

最新评论