ExecutorService是Java并发编程中管理线程池的核心工具，封装了线程的创建、调度与生命周期管理。通过Executors工具类可快速创建固定大小（newFixedThreadPool）、可缓存（newCachedThreadPool）、单线程（newSingleThreadExecutor）和定时（newScheduledThreadPool）等线程池，但生产环境推荐直接使用ThreadPoolExecutor以精确控制核心参数，避免资源风险。任务可通过execute()提交无返回值的Runnable，或通过submit()提交Runnable/Callable并返回Future获取结果或异常。正确关闭需调用shutdown()，配合awaitTermination()等待完成，必要时shutdownNow()强制中断。需注意异常处理，因Runnable中的异常默认被吞，应在任务内捕获或使用Callable结合Future.get()处理ExecutionException，并可通过ThreadFactory设置未捕获异常处理器。结合JMX或日志监控活跃线程数、队列大小等指标有助于性能调优。合理配置、及时关闭、妥善处理异常是提升应用并发能力与稳定性的关键。
在Java中，ExecutorService 是并发编程中管理线程池的核心工具之一。它封装了线程的创建、调度和生命周期管理，使开发者可以更专注于任务逻辑，而不是底层线程控制。合理使用 ExecutorService 能显著提升应用性能和资源利用率。
创建合适的线程池
Java 提供了 Executors 工具类来快速创建常见的线程池，但应根据实际场景选择合适的类型：
- newFixedThreadPool(int nThreads)：创建固定大小的线程池。适用于负载稳定、任务数量可预估的场景。
- newCachedThreadPool()：创建可缓存的线程池，线程数按需扩展。适合大量短时异步任务，但可能创建过多线程，消耗系统资源。
- newSingleThreadExecutor()：单线程池，保证任务串行执行，适用于需要顺序处理的场景。
- newScheduledThreadPool(int corePoolSize)：支持定时或周期性任务执行。
注意：生产环境中建议通过 ThreadPoolExecutor 直接构造线程池，以便精确控制核心参数（如队列容量、拒绝策略等），避免 Executors 工厂方法潜在的资源风险。
提交任务并处理结果
可以通过 execute() 或 submit() 方法提交任务：
立即学习“Java免费学习笔记（深入）”；
- execute(Runnable)：无返回值，用于执行不需要结果的任务。
- submit(Runnable)：返回 Future>，可用于判断任务是否完成。
-
submit(Callable
) ：返回 Future，可通过 get() 获取任务执行结果，支持异常传播。
示例：
ExecutorService service = Executors.newFixedThreadPool(4); Futurefuture = service.submit(() -> { Thread.sleep(1000); return "Task completed"; }); String result = future.get(); // 阻塞直到结果返回
正确关闭线程池
不关闭线程池会导致资源泄漏，JVM无法正常退出。推荐使用以下步骤优雅关闭：
- 调用 shutdown()：停止接收新任务，已提交任务继续执行。
- 配合 awaitTermination() 等待任务完成。
- 必要时调用 shutdownNow() 强制中断运行中的任务（慎用）。
标准关闭模式：
service.shutdown();
try {
if (!service.awaitTermination(60, TimeUnit.SECONDS)) {
service.shutdownNow();
}
} catch (InterruptedException e) {
service.shutdownNow();
Thread.currentThread().interrupt();
}
监控与异常处理
线程池中的异常默认会被吞掉，尤其是 Runnable 任务。应主动捕获并处理：
- 在任务内部 try-catch 所有异常，并记录日志。
- 使用 Callable 结合 Future.get() 捕获 ExecutionException。
- 为线程池设置未捕获异常处理器（通过 ThreadFactory 实现）。
可结合 JMX 或日志输出监控核心指标：活跃线程数、队列大小、已完成任务数等，有助于排查性能瓶颈。
基本上就这些。掌握 ExecutorService 的使用要点，能有效提升 Java 应用的并发能力与稳定性。关键是按需配置、及时关闭、妥善处理异常。
