首先创建合适的线程池，根据场景选择FixedThreadPool、CachedThreadPool或WorkStealingPool，推荐手动配置ThreadPoolExecutor；接着通过execute、submit、invokeAll或invokeAny提交任务，其中invokeAll可批量获取Future结果；最后注意Callable异常处理及使用shutdown正确关闭线程池，结合CompletionService优化执行效率。
在Java并发编程中，ExecutorService 是执行异步任务的核心工具之一。当需要批量处理多个任务时，合理使用 ExecutorService 不仅能提升程序性能，还能有效管理线程资源。本文将解析如何使用 ExecutorService 批量执行任务，并提供实用的操作技巧。
创建合适的线程池
批量执行任务前，首先要根据业务场景选择合适的线程池类型：
- Executors.newFixedThreadPool(n)：创建固定大小的线程池，适合任务量明确且稳定的场景。
- Executors.newCachedThreadPool()：创建可缓存的线程池，适用于大量短时任务。
- Executors.newWorkStealingPool()：基于ForkJoinPool，适合并行处理可拆分的任务。
推荐在生产环境中使用 ThreadPoolExecutor 手动构造线程池，便于控制核心参数如核心线程数、最大线程数和队列容量。
提交批量任务的多种方式
ExecutorService 提供了多种方法提交多个任务，可根据是否需要返回结果来选择：
立即学习“Java免费学习笔记（深入）”；
- execute(Runnable)：提交无返回值的任务，适用于只需执行无需结果的场景。
- submit(Callable)：提交有返回值的任务，返回 Future 对象用于获取结果。
- invokeAll(Collection<Callable>)：批量提交 Callable 任务，阻塞直到所有任务完成，返回 Future 列表。
- invokeAny(Collection<Callable>)：执行多个任务，任一任务完成后即返回结果，其余任务取消。
例如，使用 invokeAll 批量获取结果：
List<Callable<String>> tasks = Arrays.asList(
() -> "Task 1 result",
() -> "Task 2 result",
() -> "Task 3 result"
);
List<Future<String>> futures = executorService.invokeAll(tasks);
for (Future<String> future : futures) {
System.out.println(future.get()); // 输出每个任务结果
}
异常处理与资源管理
批量执行中必须注意异常和线程池生命周期管理：
- Callable 中的异常会被封装在 Future 中，调用 get() 时需捕获 ExecutionException。
- 任务内部应尽量捕获受检异常并包装为运行时异常或返回默认值。
- 使用 try-finally 或 try-with-resources 确保线程池正确关闭：
try {
// 提交任务...
} finally {
executorService.shutdown();
if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
executorService.shutdownNow(); // 强制关闭
}
}
优化建议与注意事项
提高批量任务执行效率的关键点：
- 避免创建过多线程，合理设置线程池大小（通常设为 CPU 核心数 + 1 或根据 I/O 阻塞情况调整）。
- 大批量任务可结合 CompletionService 使用，按完成顺序处理结果，提升响应速度。
- 监控 Future 状态，防止任务长时间阻塞导致线程堆积。
- 优先使用 Callable 而非 Runnable，便于统一处理结果和异常。
基本上就这些。掌握 ExecutorService 的批量任务操作，关键是理解不同提交方式的适用场景，并做好线程池配置与异常控制。不复杂但容易忽略细节，写好并发代码需要耐心和实践。
