ExecutorService是Java中管理线程池的核心工具，通过Executors提供多种预设线程池，但生产环境推荐手动创建ThreadPoolExecutor以更好控制参数；支持提交Runnable和Callable任务，返回Future用于获取结果或取消任务，调用get()时需注意阻塞问题；应用关闭时必须调用shutdown()或shutdownNow()并配合awaitTermination实现优雅停机；为提升稳定性，应使用自定义ThreadFactory设置线程名和异常处理器，并监控线程池状态指标，合理配置资源与异常处理可显著提升系统并发性能与可靠性。
在Java中，ExecutorService 是并发编程中管理线程池的核心工具。它封装了线程的创建、调度和销毁过程，让开发者能更专注于任务逻辑而非线程控制。合理使用 ExecutorService 不仅能提升系统性能，还能避免资源耗尽等问题。
创建合适的线程池
Java通过 Executors 工具类提供了多种预设线程池，但应根据实际场景选择：
- newFixedThreadPool(n)：创建固定大小的线程池，适用于负载稳定、任务数量可预期的场景。
- newCachedThreadPool()：线程数可动态扩展，适合大量短时异步任务，但可能创建过多线程影响系统稳定性。
- newSingleThreadExecutor()：单线程执行器，保证任务按顺序执行，适合串行化处理任务。
- newScheduledThreadPool(n)：支持定时或周期性任务执行，替代传统的 Timer 类。
生产环境中推荐使用 ThreadPoolExecutor 手动构造线程池，便于控制核心参数如队列容量、拒绝策略等，避免资源失控。
提交任务并处理结果
ExecutorService 支持两种任务类型：Runnable（无返回值）和 Callable（有返回值）。
立即学习“Java免费学习笔记（深入）”；
- 使用 execute(Runnable) 提交无需返回结果的任务。
- 使用 submit(Runnable/Callable) 提交任务并获取 Future 对象，用于后续获取结果或取消任务。
例如，获取异步计算结果：
Futurefuture = executor.submit(() -> { // 模拟耗时计算 Thread.sleep(1000); return 42; }); // 获取结果（阻塞直到完成） Integer result = future.get();
注意：调用 get() 会阻塞当前线程，建议设置超时时间或结合轮询机制使用。
正确关闭线程池
应用关闭时必须显式关闭线程池，否则可能导致JVM无法退出。
- 调用 shutdown()：停止接收新任务，等待已提交任务完成。
- 调用 shutdownNow()：尝试中断正在执行的任务，并返回未执行的任务列表。
推荐做法：
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
这段代码确保线程池优雅关闭，同时响应中断信号。
监控与异常处理
默认情况下，未捕获的异常会导致线程终止且不易察觉。可通过以下方式增强稳定性：
- 在 Runnable 中使用 try-catch 包裹任务逻辑，记录日志或上报错误。
- 为线程池设置自定义的 ThreadFactory，统一命名线程并添加未捕获异常处理器。
- 监控核心指标如活跃线程数、任务队列长度、已完成任务数等，辅助性能调优。
例如自定义 ThreadFactory：
ThreadFactory factory = r -> {
Thread t = new Thread(r, "my-pool-thread");
t.setUncaughtExceptionHandler((t, e) ->
System.err.println("Thread " + t.getName() + " threw exception: " + e));
return t;
};
基本上就这些。掌握 ExecutorService 的关键在于理解任务调度机制、合理配置资源以及做好生命周期管理。用得好，能显著提升系统的并发能力与稳定性。
