prestartallcorethreads() 方法用于在启动线程池后，立即创建并启动所有核心线程。调用该方法后，线程池中的活跃线程数会直接达到 corepoolsize 的值，从而避免在第一个任务到达时才逐个创建线程的延迟。这适用于需要快速响应大量并发任务的场景。
如何正确初始化并调用 prestartAllCoreThreads
要使用 prestartAllCoreThreads()，你需要先创建一个 ThreadPoolExecutor 实例，然后显式调用该方法。关键在于必须在提交任何任务之前或之后立即调用，且确保线程池处于运行状态。默认情况下，核心线程是懒加载的，即只有当有任务提交时才会创建，而此方法强制提前创建。
import java.util.concurrent.*;
public class PreStartExample {
public static void main(String[] args) throws InterruptedException {
// 定义核心线程数和最大线程数
int corePoolSize = 5;
int maxPoolSize = 10;
// 创建线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(
corePoolSize,
maxPoolSize,
60L, TimeUnit.SECONDS,
new LinkedBlockingQueue()
);
// 关键步骤：预启动所有核心线程
executor.prestartAllCoreThreads();
// 验证：检查当前活跃线程数
System.out.println("Active threads after prestart: " + executor.getActiveCount());
// 提交一个简单任务
executor.submit(() -> {
System.out.println("Task executed by thread: " + Thread.currentThread().getName());
});
// 等待任务完成并关闭线程池
Thread.sleep(1000);
executor.shutdown();
}
}
运行上述代码，控制台将输出：
Active threads after prestart: 5
Task executed by thread: pool-1-thread-1
这表明在提交任务前，5个核心线程已经被创建并处于等待状态。
与 submit 提交任务时的行为对比
如果不调用 prestartAllCoreThreads()，线程池中的核心线程会在第一个任务到达时才被创建。这意味着第一次任务提交会有额外的线程创建开销。通过对比可以发现，预启动方式能显著降低首次任务的响应时间，特别是在高并发初期。
import java.util.concurrent.*;
public class ComparisonExample {
public static void main(String[] args) throws InterruptedException {
// 场景1：不预启动
ThreadPoolExecutor noPreStart = new ThreadPoolExecutor(3, 3, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue());
long start1 = System.currentTimeMillis();
noPreStart.submit(() -> { try { Thread.sleep(100); } catch (InterruptedException e) {} });
long end1 = System.currentTimeMillis();
System.out.println("No pre-start time: " + (end1 - start1) + "ms");
noPreStart.shutdown();
// 场景2：预启动
ThreadPoolExecutor withPreStart = new ThreadPoolExecutor(3, 3, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue());
withPreStart.prestartAllCoreThreads();
long start2 = System.currentTimeMillis();
withPreStart.submit(() -> { try { Thread.sleep(100); } catch (InterruptedException e) {} });
long end2 = System.currentTimeMillis();
System.out.println("With pre-start time: " + (end2 - start2) + "ms");
withPreStart.shutdown();
}
}
预期结果中，No pre-start time 通常大于 With pre-start time，因为前者包含了线程创建的耗时。具体数值取决于系统负载，但趋势一致。
预启动后线程池的状态变化
调用 prestartAllCoreThreads() 后，线程池的 getActiveCount() 会立即返回 corePoolSize 的值。此时，这些线程都处于 WAITING 状态，等待从工作队列中获取任务。如果未提交任务，它们不会执行任何逻辑，也不会消耗 CPU 资源，仅占用少量内存和操作系统线程句柄。若后续提交的任务数量超过核心线程数，线程池会根据拒绝策略处理多余任务。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
