使用invokeAll可批量提交Callable任务并获取有序结果，适合需等待所有任务完成的场景；也可通过submit逐个提交任务以灵活控制执行流程；为避免阻塞应设置超时时间；最后需调用shutdown和awaitTermination确保线程池安全关闭。
在Java中，ExecutorService 是并发编程中非常重要的工具，它能有效管理线程池并执行多个任务。当你需要批量执行任务时，可以通过 ExecutorService 提交多个任务，并等待它们完成。以下是实现批量任务执行的常用方式和关键步骤。
使用 invokeAll 批量提交任务
最直接的方式是使用 invokeAll(Collection<Callable<T>> tasks) 方法，它可以一次性提交多个 Callable 任务，并返回每个任务的 Future 结果列表。
- 所有任务会并行执行，方法会阻塞直到所有任务完成。
- 返回的 Future 列表顺序与输入的任务集合顺序一致。
- 适合需要获取每个任务返回结果的场景。
示例代码：
ExecutorService executor = Executors.newFixedThreadPool(4);
<p>List<Callable<String>> tasks = new ArrayList<>();
for (int i = 1; i <= 5; i++) {
final int taskId = i;
tasks.add(() -> {
Thread.sleep(1000);
return "任务 " + taskId + " 完成";
});
}</p><p>try {
List<Future<String>> results = executor.invokeAll(tasks);
for (Future<String> result : results) {
System.out.println(result.get()); // 输出每个任务的结果
}
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
使用 submit 提交多个任务并手动收集 Future
如果你希望更灵活地控制任务提交过程，可以逐个调用 submit() 方法，并将返回的 Future 存入集合中，之后统一处理结果。
立即学习“Java免费学习笔记（深入）”；
- 可以混合使用 Runnable 和 Callable 任务。
- 支持异步处理或部分任务超时控制。
- 适用于任务数量动态变化或需差异化处理的场景。
示例代码：
ExecutorService executor = Executors.newFixedThreadPool(4);
List<Future<Integer>> futures = new ArrayList<>();
<p>for (int i = 0; i < 5; i++) {
final int job = i;
Future<Integer> future = executor.submit(() -> {
return job * job;
});
futures.add(future);
}</p><p>// 获取结果
for (Future<Integer> f : futures) {
try {
System.out.println("结果: " + f.get());
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
}
executor.shutdown();
设置超时限制避免无限等待
在生产环境中，长时间阻塞可能影响系统稳定性。你可以为 invokeAll 设置超时时间，防止某些任务卡住。
示例：带超时的批量执行
List<Future<String>> results = executor.invokeAll(tasks, 3, TimeUnit.SECONDS);
- 如果在指定时间内未完成所有任务，未完成的任务对应的 Future 调用
get()会抛出 TimeoutException。 - 可以根据业务需求决定是否取消这些任务（
future.cancel(true)）。
合理关闭线程池
任务执行完成后，必须调用 shutdown() 并配合 awaitTermination() 确保资源释放。
executor.shutdown();
try {
if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 强制关闭
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
基本上就这些。通过 ExecutorService 实现批量任务执行，关键是选择合适的方法提交任务、妥善处理结果与异常，并正确管理线程生命周期。不复杂但容易忽略细节。
