• Java并发面试题:(二)线程池参数和使用


    线程池参数

    在这里插入图片描述

    线程池工作过程

    当提交一个新任务到线程池时,具体的执行流程如下:

    1. 当我们提交任务,线程池会根据corePoolSize大小创建若干任务数量线程执行任务

    2. 当任务的数量超过corePoolSize数量,后续的任务将会进入阻塞队列阻塞排队

    3. 当阻塞队列也满了之后,那么将会继续创建(maximumPoolSize-corePoolSize)个数量的线程来
      执行任务,如果任务处理完成,maximumPoolSize-corePoolSize额外创建的线程等待

    keepAliveTime之后被自动销毁

    1. 如果达到maximumPoolSize,阻塞队列还是满的状态,那么将根据不同的拒绝策略对应处理
      在这里插入图片描述

    创建线程池

    阿里巴巴Java开发手册》中强制线程池不允许使用 Executors 去创建,而是通过
    ThreadPoolExecutor 的方式,这样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽
    的风险**

    Executors 返回线程池对象的弊端如下:
    FixedThreadPool 和 SingleThreadExecutor : 允许请求的队列长度为
    Integer.MAX_VALUE,可能堆积大量的请求,从而导致OOM。

    CachedThreadPool 和 ScheduledThreadPool : 允许创建的线程数量为
    Integer.MAX_VALUE ,可能会创建大量线程,从而导致OOM。

    方式一:通过构造方法实现
    在这里插入图片描述
    方式二:通过Executor 框架的工具类Executors来实现 我们可以创建三种类型的

    ThreadPoolExecutor:

    FixedThreadPool : 该方法返回一个固定线程数量的线程池。该线程池中的线程数量始终不变。
    当有一个新的任务提交时,线程池中若有空闲线程,则立即执行。若没有,则新的任务会被暂存在
    一个任务队列中,待有线程空闲时,便处理在任务队列中的任务。

    SingleThreadExecutor: 方法返回一个只有一个线程的线程池。若多余一个任务被提交到该线程
    池,任务会被保存在一个任务队列中,待线程空闲,按先入先出的顺序执行队列中的任务。

    CachedThreadPool: 该方法返回一个可根据实际情况调整线程数量的线程池。线程池的线程数
    量不确定,但若有空闲线程可以复用,则会优先使用可复用的线程。若所有线程均在工作,又有新
    的任务提交,则会创建新的线程处理任务。所有线程在当前任务执行完毕后,将返回线程池进行复
    用。
    对应Executors工具类中的方法如图所示:
    在这里插入图片描述

    拒绝策略

    1. AbortPolicy:直接丢弃任务,抛出异常,这是默认策略
    2. CallerRunsPolicy:只用调用者所在的线程来处理任务
    3. DiscardOldestPolicy:丢弃等待队列中最旧的任务,并执行当前任务
    4. DiscardPolicy:直接丢弃任务,也不抛出异常
  • 相关阅读:
    不用Swagger,那我用啥?
    深度解析C#数组对象池ArrayPool<T>底层原理
    Zellij-一个典型的 Rust程序的性能优化案例
    JAVA计算机毕业设计兴澜幼儿园管理系统Mybatis+源码+数据库+lw文档+系统+调试部署
    重学Java8新特性(一) : Lambda表达式、常见函数式接口、方法引用
    【Shashlik.EventBus】.NET 事件总线,分布式事务最终一致性
    黄金分割算法的一个简单实现
    【NLP】情绪分析与酒店评论
    有什么可以自动保存微信文件的方法么?
    《LC刷题总结》——回溯
  • 原文地址:https://blog.csdn.net/weixin_42774617/article/details/133843391