Java中应显式构造ThreadPoolExecutor而非使用Executors静态工厂，因其可控制核心线程数、有界队列及拒绝策略，避免OOM或线程爆炸；任务通过submit(Callable)获取Future结果，关闭时需调用shutdown()、awaitTermination()和必要时shutdownNow()。
Java中使用Executor框架的核心是把任务提交给线程池执行，而不是手动创建和管理Thread对象。关键在于理解Executor、ExecutorService、ThreadPoolExecutor之间的关系，并掌握常见线程池的创建方式和使用场景。
Executor框架的核心接口与类
Executor是最顶层接口，只定义了execute(Runnable)方法；ExecutorService扩展了它，支持提交Runnable/Callable任务、关闭线程池、获取Future结果等；ThreadPoolExecutor是它的核心实现类，允许精细控制核心线程数、最大线程数、队列类型、拒绝策略等。
日常开发中，通常不直接new ThreadPoolExecutor，而是通过Executors工具类快速创建预设配置的线程池：
-
Executors.newFixedThreadPool(n)：固定大小线程池，适合负载稳定、任务量可预期的场景 -
Executors.newCachedThreadPool()：弹性线程池，空闲60秒自动回收线程，适合大量短生命周期任务 -
Executors.newSingleThreadExecutor()：单线程池，保证任务串行执行，适用于需要顺序处理的场景 -
Executors.newScheduledThreadPool(n)：支持定时/周期性执行任务
推荐用法：使用ThreadPoolExecutor代替Executors静态工厂
Executors创建的线程池存在隐患，比如newFixedThreadPool和newSingleThreadExecutor内部使用无界LinkedBlockingQueue，可能导致内存溢出；newCachedThreadPool最大线程数为Integer.MAX_VALUE，高并发下可能创建过多线程拖垮系统。
立即学习“Java免费学习笔记（深入）”；
更安全的做法是显式构造ThreadPoolExecutor：
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, // 核心线程数
4, // 最大线程数
60L, // 空闲线程存活时间
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(100), // 有界阻塞队列
new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略：由调用线程执行任务
);
这样能明确控制资源边界，避免OOM或线程爆炸。
任务提交与结果获取
ExecutorService提供多种提交方式：
-
execute(Runnable)：无返回值，适合不需要结果的异步操作 -
submit(Runnable)：返回Future，可通过get()等待执行完成（但结果为null） -
submit(Callable<t>)</t>：返回Future，可获取任务执行结果，支持异常传播
示例：
Future<String> future = executor.submit(() -> {
Thread.sleep(1000);
return "done";
});
String result = future.get(); // 阻塞等待，获取返回值
线程池的正确关闭流程
不关闭线程池会导致JVM无法正常退出。标准关闭步骤是：
- 调用
shutdown()：停止接收新任务，已提交任务继续执行 - 调用
awaitTermination(timeout, unit)：等待所有任务执行完毕，超时则强制终止 - 若未正常结束，调用
shutdownNow()：尝试中断正在执行的任务，并返回未执行的任务列表
建议在应用关闭钩子或Spring的@PreDestroy中执行该逻辑。
