深入理解Java线程池（ThreadPoolExecutor完整入门与实战指南）

什么是 ThreadPoolExecutor？

ThreadPoolExecutor 是 Java 并发包（java.util.concurrent）中用于创建和管理线程池的核心类。它允许你通过复用一组工作线程来执行多个任务，避免频繁创建和销毁线程带来的性能开销。

为什么使用线程池？

• 减少线程创建/销毁的开销
• 控制并发线程数量，防止系统资源耗尽
• 提供任务队列机制，实现任务的缓冲与调度
• 支持灵活的拒绝策略，处理超负荷情况

ThreadPoolExecutor 构造函数详解

要创建一个 ThreadPoolExecutor，你需要理解它的核心参数：

public ThreadPoolExecutor(    int corePoolSize,      // 核心线程数    int maximumPoolSize,   // 最大线程数    long keepAliveTime,    // 非核心线程空闲存活时间    TimeUnit unit,         // 时间单位    BlockingQueue<Runnable> workQueue, // 任务队列    ThreadFactory threadFactory,       // 线程工厂（可选）    RejectedExecutionHandler handler   // 拒绝策略（可选）)  

参数说明：

• corePoolSize：线程池中保持的最小线程数，即使它们处于空闲状态。
• maximumPoolSize：线程池允许的最大线程数。
• keepAliveTime：当线程数超过核心线程数时，多余的空闲线程等待新任务的最长时间。
• workQueue：用于保存等待执行的任务的阻塞队列。
• RejectedExecutionHandler：当任务无法提交到线程池时（如队列已满且线程数已达上限），采取的处理策略。

实战：创建一个简单的线程池

下面是一个完整的示例，展示如何使用 ThreadPoolExecutor 执行多个任务：

import java.util.concurrent.*;public class ThreadPoolExample {    public static void main(String[] args) {        // 创建 ThreadPoolExecutor        ThreadPoolExecutor executor = new ThreadPoolExecutor(            2,                           // corePoolSize            4,                           // maximumPoolSize            10,                          // keepAliveTime            TimeUnit.SECONDS,            new LinkedBlockingQueue<>(10), // 任务队列容量为10            Executors.defaultThreadFactory(),            new ThreadPoolExecutor.AbortPolicy() // 默认拒绝策略        );        // 提交15个任务        for (int i = 0; i < 15; i++) {            final int taskId = i;            executor.submit(() -> {                System.out.println("任务 " + taskId + " 正在由线程 "                     + Thread.currentThread().getName() + " 执行");                try {                    Thread.sleep(2000); // 模拟耗时操作                } catch (InterruptedException e) {                    Thread.currentThread().interrupt();                }            });        }        // 关闭线程池（不再接受新任务，但会执行完已提交的任务）        executor.shutdown();        try {            // 等待所有任务完成，最多等待60秒            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {                executor.shutdownNow(); // 强制关闭            }        } catch (InterruptedException e) {            executor.shutdownNow();            Thread.currentThread().interrupt();        }    }}  

常用拒绝策略

当线程池和队列都满了，新任务会被拒绝。Java提供了四种内置策略：

• AbortPolicy（默认）：抛出 RejectedExecutionException
• CallerRunsPolicy：由调用线程直接执行该任务
• DiscardPolicy：静默丢弃任务
• DiscardOldestPolicy：丢弃队列中最老的任务，然后重试提交

最佳实践建议

• 始终显式创建 ThreadPoolExecutor，避免使用 Executors 工厂方法（如 newFixedThreadPool），因为它们可能使用无界队列，导致内存溢出。
• 合理设置 corePoolSize 和 maximumPoolSize，根据 CPU 核心数和任务类型（CPU密集型 or IO密集型）调整。
• 务必调用 shutdown() 或 shutdownNow() 来优雅关闭线程池，防止程序无法退出。
• 监控线程池状态（如活跃线程数、已完成任务数等），便于性能调优。

总结

通过本教程，你已经掌握了 ThreadPoolExecutor教程 的核心知识点，包括构造参数、任务提交、拒绝策略以及最佳实践。正确使用 线程池配置 能显著提升应用的并发能力和稳定性。

记住，Java线程池 不仅是面试高频考点，更是实际项目中不可或缺的工具。动手实践本文中的代码，你将对 多线程编程 有更深刻的理解！