怎么用代码演示线程池在调用 prestartAllCoreThreads() 时抢先激活所有核心的内幕-java教程-PHP中文网

prestartAllCoreThreads() 的作用是主动唤醒并初始化所有核心线程，使其立即进入等待任务的就绪状态；它通过循环调用 addWorker(null, true) 创建 corePoolSize 个空闲线程，线程启动后阻塞在 workQueue.take() 上，不改变线程池状态，仅实现预加载。

prestartAllCoreThreads() 的作用本质

这个方法不是“启动线程池”，而是**主动唤醒并初始化所有核心线程（corepoolsize 个）**，让它们立刻进入等待任务的就绪状态。它不改变线程池状态（比如从 running 变成 shutdown），也不影响后续 submit/execute 行为——只是把“懒加载”变成“预加载”。

底层发生了什么（以 ThreadPoolExecutor 为例）

调用 prestartAllCoreThreads() 时，线程池会循环调用 addWorker(null, true) 共 corePoolSize 次：

null 表示不带初始任务（线程启动后直接阻塞在 workQueue.take() 上）
true 表示强制创建核心线程（绕过 corePoolSize 容量限制检查）
每次成功 addWorker 就真正启动一个新 Thread，执行 Worker.run() → runWorker() → 首先尝试从队列取任务（此时为空，于是阻塞等待）

也就是说：线程已存在、已启动、已持有锁、已挂起在 take()，只等第一个任务到来就被唤醒——这就是“抢先激活”的全部内幕。

代码演示：对比有无 prestart 的线程创建时机

下面是一个可运行的小例子，用日志清晰展示线程何时被创建：

import java.util.concurrent.*;

public class PrestartDemo {
    public static void main(String[] args) throws InterruptedException {
        ThreadPoolExecutor pool = new ThreadPoolExecutor(
            2, 4, 60, TimeUnit.SECONDS,
            new LinkedBlockingQueue(10),
            new ThreadFactory() {
                private int count = 0;
                @Override
                public Thread newThread(Runnable r) {
                    Thread t = new Thread(r, "Worker-" + (++count));
                    System.out.println("[ThreadFactory] 创建线程: " + t.getName());
                    return t;
                }
            }
        );

        System.out.println("=== 调用 prestartAllCoreThreads() 前 ===");
        Thread.sleep(100);

        pool.prestartAllCoreThreads(); // 立即创建 2 个核心线程

        System.out.println("=== 提交第一个任务 ===");
        pool.submit(() -> {
            System.out.println("任务1 执行在线程: " + Thread.currentThread().getName());
            try { Thread.sleep(500); } catch (InterruptedException e) {}
        });

        System.out.println("=== 提交第二个任务 ===");
        pool.submit(() -> {
            System.out.println("任务2 执行在线程: " + Thread.currentThread().getName());
        });

        pool.shutdown();
        pool.awaitTermination(2, TimeUnit.SECONDS);
    }
}

输出会类似：

=== 调用 prestartAllCoreThreads() 前 ===
[ThreadFactory] 创建线程: Worker-1
[ThreadFactory] 创建线程: Worker-2
=== 提交第一个任务 ===
任务1 执行在线程: Worker-1
=== 提交第二个任务 ===
任务2 执行在线程: Worker-2

注意：两个 Worker 线程在 submit 之前就已创建完毕；若去掉 prestartAllCoreThreads()，则第一次 submit 时才创建 Worker-1，第二次 submit 才创建 Worker-2（延迟明显）。