ExecutorService是Java并发编程核心工具，用于批量执行任务并管理线程生命周期。通过submit()提交任务可获得Future对象，便于获取结果或监控状态，结合List统一管理异步结果；推荐使用Callable返回结果，Runnable用于无返回值任务，调用Future.get()时应设置超时防止阻塞。生产环境建议显式创建ThreadPoolExecutor，合理配置核心线程数、最大线程数、工作队列及拒绝策略，避免Executors工厂方法潜在风险。任务完成后需优雅关闭线程池：先调用shutdown()停止接收新任务，再通过awaitTermination()等待任务完成，必要时调用shutdownNow()强制中断。需主动处理异常，如在Callable中捕获异常并封装结果，或为线程池设置UncaughtExceptionHandler记录日志，结合监控工具跟踪线程池状态。掌握这些技巧可有效提升并发性能与系统稳定性。
在Java中，ExecutorService 是并发编程的核心工具之一，特别适合批量执行多个任务。它能有效管理线程生命周期、提升性能并避免手动创建线程带来的资源浪费。下面介绍如何使用 ExecutorService 批量执行任务，并分享一些实用的并发管理技巧。
批量提交任务的常用方式
你可以通过 execute() 或 submit() 方法向线程池提交任务。对于批量处理，推荐使用 submit()，因为它返回一个 Future 对象，可以获取任务结果或判断执行状态。
- 使用 List 存储 Future，便于统一管理异步结果
- Runnable 用于无返回值的任务，Callable 可返回结果并支持泛型
- 调用 Future.get() 可阻塞等待任务完成，注意设置超时避免无限等待
示例代码：
ExecutorService executor = Executors.newFixedThreadPool(4);
List<Future<String>> results = new ArrayList<>();
<p>for (int i = 0; i < 10; i++) {
final int taskId = i;
Callable<String> task = () -> "Task " + taskId + " completed by " + Thread.currentThread().getName();
results.add(executor.submit(task));
}</p><p>// 获取结果
for (Future<String> result : results) {
try {
System.out.println(result.get(5, TimeUnit.SECONDS)); // 设置超时
} catch (TimeoutException e) {
System.err.println("任务执行超时");
}
}</p>合理配置线程池参数
直接使用 Executors 工厂方法创建线程池虽然方便，但在生产环境中容易引发问题（如 FixedThreadPool 可能导致内存溢出）。建议通过 ThreadPoolExecutor 显式构造线程池。
立即学习“Java免费学习笔记（深入）”；
- 核心线程数：保持常驻的线程数量，根据CPU核心数和任务类型设定
- 最大线程数：控制并发上限，防止资源耗尽
- 工作队列：选择合适的阻塞队列（如 LinkedBlockingQueue、ArrayBlockingQueue）
- 拒绝策略：定义任务过多时的处理方式，如 AbortPolicy、CallerRunsPolicy
例如：
int corePoolSize = Runtime.getRuntime().availableProcessors(); int maxPoolSize = corePoolSize * 2; long keepAliveTime = 60L; <p>ThreadPoolExecutor executor = new ThreadPoolExecutor( corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), new ThreadPoolExecutor.CallerRunsPolicy() );</p>
优雅关闭线程池
任务执行完毕后必须正确关闭线程池，否则 JVM 无法退出。不能直接调用 shutdownNow()，应先停止接收新任务，再等待已有任务完成。
- 调用 shutdown() 表示不再接收新任务
- 配合 awaitTermination() 等待所有任务结束
- 设置合理的等待时间，避免程序卡住
标准关闭流程：
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 强制中断
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
异常处理与监控建议
默认情况下，线程池中的未捕获异常会被吞掉，导致问题难以排查。需要主动处理异常情况。
- 在 Callable 中 try-catch 异常并封装到返回值中
- 为线程池设置 UncaughtExceptionHandler，记录日志
- 定期检查 Future 状态，及时发现失败任务
- 结合监控工具（如 Micrometer）统计活跃线程数、队列长度等指标
示例异常处理：
ThreadFactory namedFactory = r -> {
Thread t = new Thread(r);
t.setUncaughtExceptionHandler((t, e) ->
System.err.println("Thread " + t.getName() + " failed: " + e.getMessage())
);
return t;
};
基本上就这些。掌握 ExecutorService 的批量任务处理技巧，关键是理解线程池行为、合理配置资源并做好异常和生命周期管理。不复杂但容易忽略细节。
