Java知识体系

Appearance

`ThreadPoolTaskExecutor` 的任务分发与执行顺序

这篇文章的内容需要核实并更新一下，如果看到，可以call 一下我

理解 Spring 中 ThreadPoolTaskExecutor 的任务分发与执行顺序 ​

在 Java 并发编程中，线程池（ThreadPoolExecutor）是一种非常重要的概念，它能帮助我们高效地管理和分发线程。而 Spring 的 ThreadPoolTaskExecutor 是对 JDK 原生 ThreadPoolExecutor 的封装，广泛用于任务的并发处理。

今天，我们主要探讨这样一个问题：当线程池中的任务等待队列已满时，提交的新任务会如何处理？这会对任务的实际执行顺序产生什么影响？

1. 线程池中任务的分发机制 ​

ThreadPoolTaskExecutor 的关键参数 ​

线程池的行为主要由以下几个参数控制：

  • 核心线程数（corePoolSize）：线程池始终保持运行的线程数，即使它们处于空闲状态。
  • 最大线程数（maxPoolSize）：线程池能够容纳的最大并发线程数（包括核心线程和非核心线程）。
  • 队列容量（queueCapacity）：线程池用于存储等待执行任务的队列大小。如果队列已满，则新任务将触发其他机制。
  • 拒绝策略（rejectionPolicy）：当线程池的线程数达到最大值且队列已满时，控制新任务的处理方式（如抛出异常、丢弃任务等）。

任务的具体调度逻辑 ​

当线程池接收到一个新任务时，它会依次按照以下规则处理任务：

  1. 空闲核心线程处理： 如果当前运行的线程数未达到核心线程数（corePoolSize），线程池将立即创建一个新线程来处理任务。
  2. 任务进入等待队列： 如果当前运行的线程数已经等于核心线程数，并且等待队列未满，则新任务会被放置到队列中等待调度。
  3. 创建非核心线程处理任务： 如果等待队列已满，但运行线程数小于最大线程数（maxPoolSize），线程池将创建一个新的非核心线程来处理任务。
  4. 执行拒绝策略： 如果线程池的线程数已达上限，并且等待队列也已满，新任务将被线程池的拒绝策略处理，例如抛出异常（默认行为）。

2. 队列满时任务的执行顺序：一个容易混淆的问题 ​

常见问题 ​

当线程池的等待队列已满时，提交的新任务会绕过队列直接由非核心线程执行。这可能导致新任务的执行顺序早于队列中的任务，从而打破了通常的任务提交先后顺序。

这种现象是线程池设计使然，属于其正常行为，由以下两点决定：

  1. 新任务不会加入已经满载的队列。
  2. 队列中的任务调度优先级低于新任务（非核心线程优先执行新任务）。

3. 用代码验证线程池任务的实际执行顺序 ​

让我们用一个实际代码来验证队列已满时新任务的执行情况。

代码示例 ​

下面是一个 ThreadPoolTaskExecutor 的配置及任务提交过程：

java
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

public class TaskExecutionOrder {

    public static void main(String[] args) {
        // 创建 ThreadPoolTaskExecutor
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(2);  // 核心线程数
        executor.setMaxPoolSize(4);   // 最大线程数
        executor.setQueueCapacity(3); // 队列容量
        executor.setThreadNamePrefix("MyExecutor-");
        executor.initialize();

        // 提交任务
        for (int i = 1; i <= 6; i++) {
            final int taskId = i;
            executor.execute(() -> {
                System.out.println(Thread.currentThread().getName() + " 正在执行任务 " + taskId);
                try {
                    Thread.sleep(3000); // 模拟任务耗时
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}

配置分析 ​

  • 核心线程数为 2：最多 2 个任务可以立即并发执行。
  • 最大线程数为 4：在核心线程和队列耗尽后，最多再创建 2 个非核心线程。
  • 队列容量为 3：多余任务将排队等待执行。

任务提交顺序是：任务1、任务2、任务3、任务4、任务5、任务6。

预期行为 ​

  1. 核心线程（MyExecutor-1 和 MyExecutor-2）立即执行任务1和任务2。
  2. 任务3、任务4、任务5被加入队列，等待核心线程空闲。
  3. 任务6因队列已满，直接由非核心线程（MyExecutor-3）处理。
  4. 队列中的任务（任务3、任务4、任务5）必须等到核心线程处理完任务1和任务2后，才能依次调度。

输出示例 ​

运行后的输出可能如下：

MyExecutor-1 正在执行任务 1
MyExecutor-2 正在执行任务 2
MyExecutor-3 正在执行任务 6
MyExecutor-1 正在执行任务 3
MyExecutor-2 正在执行任务 4
MyExecutor-1 正在执行任务 5

如上输出可以得出以下结论：

  1. 任务6提前执行：由于队列已满，非核心线程直接调度任务6执行。
  2. 队列任务延后执行：队列任务3、任务4、任务5必须由空闲的核心线程拉取，因此顺序发生错位。

4. 总结与建议 ​

线程池的任务调度特点 ​

  • 在队列容量足够时，新任务会进入队列，任务执行顺序与提交顺序一致。
  • 当队列容量不足时：
  • 新任务直接由非核心线程处理，绕过队列任务；
  • 队列中的任务需要等待已有线程空闲后才能执行，导致可能的顺序错位。

设计注意事项 ​

  1. 实时性优先的任务：避免使用过大的队列容量。特别是对于需要按提交顺序严格执行的任务，可以将队列容量设为零（使用 SynchronousQueue）以规避这种不一致性。
  2. 批处理型任务：如果对任务顺序要求不高，且关注线程资源节省，可适当增加队列容量，减少线程扩展。
  3. 动态配置线程池参数：在应用中，线程池的参数应根据实际负载调优。合理配置核心线程数、队列容量和最大线程数，可以有效避免队列排队时间过长或线程资源浪费。

通过理解线程池的任务调度逻辑，我们可以更好地掌控任务的执行顺序，从而更高效地处理并发任务。