【Java 并发编程】线程池机制 ( 线程池阻塞队列 | 线程池拒绝策略 | 使用 ThreadPoolExecutor 自定义线程池参数 )

简介: 【Java 并发编程】线程池机制 ( 线程池阻塞队列 | 线程池拒绝策略 | 使用 ThreadPoolExecutor 自定义线程池参数 )

文章目录

一、线程池阻塞队列

二、拒绝策略

三、使用 ThreadPoolExecutor 自定义线程池参数





一、线程池阻塞队列


线程池阻塞队列是线程池创建的第 5 55 个参数 : BlockingQueue<Runnable> workQueue ;


public ThreadPoolExecutor(int corePoolSize,     // 核心线程数 , 这些线程基本不会被销毁
                              int maximumPoolSize,      // 最大线程数 , 线程池能创建的最大线程数量
                              long keepAliveTime,     // 空闲情况下 , 非核心线程存活时间
                              TimeUnit unit,      // 空闲时间单位
                              BlockingQueue<Runnable> workQueue,// 任务的阻塞队列 ★
                              ThreadFactory threadFactory,    // 创建线程的工厂类
                              RejectedExecutionHandler handler) // 拒绝策略


线程池阻塞队列 : 线程池中的阻塞队列 , 同一时刻 , 只能有 1 11 个线程访问队列 , 执行任务 入队 / 出队 操作 ; 队列都是 FIFO 先进先出 ;


阻塞队列相关概念 :


大小边界 :

有界 : 阻塞队列 大小有限制 , 不是无限大的 ;

无界 : 阻塞队列 理论上无限大 , 比如设置成 Integer.MAX_VALUE ;

队列已满 : 只能出队 , 不能入队 ; 入队操作需阻塞等待 ;

队列为空 : 只能入队 , 不能出队 ; 出队操作需要等待 ;

ArrayBlockingQueue : 有界阻塞队列 , 需要 指定阻塞队列大小 ;


LinkedBlockingQueue : 无界阻塞队列 , 基于链表的阻塞队列 ;


Executors.newCachedThreadPool() 或 Executors.newFixedThreadPool(10) 方法创建的线程池 , 使用的是该阻塞队列 ;

SynchronousQueue : 队列 不存储元素 , 后一个 Runnable 任务入队 , 必须等到前一个任务执行完毕才可以 , 否则会一直阻塞等待 ;


Executors.newCachedThreadPool() 方法创建的线程池 , 使用的是该阻塞队列 ;

PriorityBlockingQueue : 有优先级的阻塞队列 ;



阻塞队列吞吐量 : SynchronousQueue > LinkedBlockingQueue > ArrayBlockingQueue ;






二、拒绝策略


线程池拒绝策略是线程池创建的第 7 77 个参数 : RejectedExecutionHandler handler ;


 

public ThreadPoolExecutor(int corePoolSize,     // 核心线程数 , 这些线程基本不会被销毁
                              int maximumPoolSize,      // 最大线程数 , 线程池能创建的最大线程数量
                              long keepAliveTime,     // 空闲情况下 , 非核心线程存活时间
                              TimeUnit unit,      // 空闲时间单位
                              BlockingQueue<Runnable> workQueue,// 任务的阻塞队列 
                              ThreadFactory threadFactory,    // 创建线程的工厂类
                              RejectedExecutionHandler handler) // 拒绝策略 ★



线程池拒绝策略 : 如果核心线程 , 非核心线程都在执行任务 , 阻塞队列是有界的 , 也满了 , 此时线程池如果再添加任务 , 就会触发如下拒绝策略 ;


DiscardPolicy : 丢弃任务 ;

DiscardOldestPolicy : 丢弃队头的最旧的任务 ;

AbortPolicy : 抛出异常 , 这也是默认方式 ;

CallerRunsPolicy : 调用者自行处理 ;


线程池默认的拒绝策略是 抛出异常 方式 ;


 

private static final RejectedExecutionHandler defaultHandler =
        new AbortPolicy();






三、使用 ThreadPoolExecutor 自定义线程池参数


创建 1 11 个线程池 , 核心线程数是 2 22 , 最大线程数是 3 33 , 则非核心线程 0 ~ 1 个 , 非核心线程最大空闲存活时间 60 秒 , 阻塞队列最大存放 10 个元素 , 拒绝策略设置为抛出异常方式 , 如果阻塞队列装满 , 再次尝试执行新任务时 , 会抛出异常 ;



代码示例 :


import java.util.concurrent.*;
public class Main {
    public static void main(String[] args) {
        ExecutorService executorService = new ThreadPoolExecutor(
                2,                          // 核心线程数 2
                3,                      // 最大线程数 3, 非核心线程 0 ~ 1 个
                60,                        // 非核心线程最大空闲存活时间 60 秒
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(10),   // 阻塞队列, 最大存放 10 个元素
                Executors.defaultThreadFactory(),       // 线程工厂
                new ThreadPoolExecutor.AbortPolicy()    // 决绝策略, 如果执行任务失败, 抛出异常
        );
        for (int i = 0; i < 20; i ++) {
            executorService.execute(new Task(i));
        }
    }
    static class Task implements Runnable {
        /**
         * 记录线程的索引 0 ~ 99
         */
        private int i = 0;
        public Task(int i) {
            this.i = i;
        }
        @Override
        public void run() {
            System.out.println("线程 ID : " + Thread.currentThread().getName() + " , 线程索引 : " + i);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}


执行结果 : 这里线程最大执行到了 12 1212 , 也就是从 0 00 开始计数 , 执行了 13 1313 个任务 , 其中 3 33 个线程池各自执行一个任务 , 阻塞队列存放 10 1010 个任务 , 再次尝试将第 14 1414 个任务放入阻塞队列时 , 报出 java.util.concurrent.RejectedExecutionException 异常 , 但是队列中的 10 1010 个任务也正常执行完毕 ;


线程 ID : pool-1-thread-2 , 线程索引 : 1
线程 ID : pool-1-thread-3 , 线程索引 : 12
线程 ID : pool-1-thread-1 , 线程索引 : 0
Exception in thread "main" java.util.concurrent.RejectedExecutionException: 
Task Main$Task@5cad8086 rejected from java.util.concurrent.ThreadPoolExecutor@6e0be858
[Running, pool size = 3, active threads = 3, queued tasks = 10, completed tasks = 0]
  at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047)
  at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
  at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
  at Main.main(Main.java:16)
线程 ID : pool-1-thread-3 , 线程索引 : 2
线程 ID : pool-1-thread-1 , 线程索引 : 4
线程 ID : pool-1-thread-2 , 线程索引 : 3
线程 ID : pool-1-thread-1 , 线程索引 : 5
线程 ID : pool-1-thread-2 , 线程索引 : 7
线程 ID : pool-1-thread-3 , 线程索引 : 6
线程 ID : pool-1-thread-1 , 线程索引 : 9
线程 ID : pool-1-thread-2 , 线程索引 : 8
线程 ID : pool-1-thread-3 , 线程索引 : 10
线程 ID : pool-1-thread-2 , 线程索引 : 11

image.png

目录
相关文章
|
1月前
|
监控 Kubernetes Java
阿里面试:5000qps访问一个500ms的接口,如何设计线程池的核心线程数、最大线程数? 需要多少台机器?
本文由40岁老架构师尼恩撰写,针对一线互联网企业的高频面试题“如何确定系统的最佳线程数”进行系统化梳理。文章详细介绍了线程池设计的三个核心步骤:理论预估、压测验证和监控调整,并结合实际案例(5000qps、500ms响应时间、4核8G机器)给出具体参数设置建议。此外,还提供了《尼恩Java面试宝典PDF》等资源,帮助读者提升技术能力,顺利通过大厂面试。关注【技术自由圈】公众号,回复“领电子书”获取更多学习资料。
|
11天前
|
安全 Java C#
Unity多线程使用(线程池)
在C#中使用线程池需引用`System.Threading`。创建单个线程时,务必在Unity程序停止前关闭线程(如使用`Thread.Abort()`),否则可能导致崩溃。示例代码展示了如何创建和管理线程,确保在线程中执行任务并在主线程中处理结果。完整代码包括线程池队列、主线程检查及线程安全的操作队列管理,确保多线程操作的稳定性和安全性。
|
3月前
|
Java
.如何根据 CPU 核心数设计线程池线程数量
IO 密集型:核心数*2 计算密集型: 核心数+1 为什么加 1?即使当计算密集型的线程偶尔由于缺失故障或者其他原因而暂停时,这个额外的线程也能确保 CPU 的时钟周期不会被浪费。
164 4
|
3月前
|
Java 开发者
Java多线程编程中的常见误区与最佳实践####
本文深入剖析了Java多线程编程中开发者常遇到的几个典型误区,如对`start()`与`run()`方法的混淆使用、忽视线程安全问题、错误处理未同步的共享变量等,并针对这些问题提出了具体的解决方案和最佳实践。通过实例代码对比,直观展示了正确与错误的实现方式,旨在帮助读者构建更加健壮、高效的多线程应用程序。 ####
|
9天前
|
Linux
Linux编程: 在业务线程中注册和处理Linux信号
本文详细介绍了如何在Linux中通过在业务线程中注册和处理信号。我们讨论了信号的基本概念,并通过完整的代码示例展示了在业务线程中注册和处理信号的方法。通过正确地使用信号处理机制,可以提高程序的健壮性和响应能力。希望本文能帮助您更好地理解和应用Linux信号处理,提高开发效率和代码质量。
38 17
|
18天前
|
Linux
Linux编程: 在业务线程中注册和处理Linux信号
通过本文,您可以了解如何在业务线程中注册和处理Linux信号。正确处理信号可以提高程序的健壮性和稳定性。希望这些内容能帮助您更好地理解和应用Linux信号处理机制。
50 26
|
2月前
|
存储 安全 Java
Java多线程编程秘籍:各种方案一网打尽,不要错过!
Java 中实现多线程的方式主要有四种:继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点,适用于不同的场景。继承 Thread 类最简单,实现 Runnable 接口更灵活,Callable 接口支持返回结果,线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外,还介绍了多线程相关的常见面试问题及答案,涵盖线程概念、线程安全、线程池等知识点。
234 2
|
3月前
|
设计模式 Java 开发者
Java多线程编程的陷阱与解决方案####
本文深入探讨了Java多线程编程中常见的问题及其解决策略。通过分析竞态条件、死锁、活锁等典型场景,并结合代码示例和实用技巧,帮助开发者有效避免这些陷阱,提升并发程序的稳定性和性能。 ####
|
3月前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱,如竞态条件、死锁和内存一致性错误,并提供了实用的避免策略。通过分析典型错误案例,本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧,从而提升并发程序的稳定性和性能。 ####
|
2月前
|
缓存 Java 调度
多线程编程核心:上下文切换深度解析
在现代计算机系统中,多线程编程已成为提高程序性能和响应速度的关键技术。然而,多线程编程中一个不可避免的概念就是上下文切换(Context Switching)。本文将深入探讨上下文切换的概念、原因、影响以及优化策略,帮助你在工作和学习中深入理解这一技术干货。
60 10