|
n();
// 获取每个任务的结果或处理异常
List<String> results = new ArrayList<>();
for (CompletableFuture<String> future :futuresArray) {
// 处理任务的异常
future.exceptionally(ex -> {
System.out.println("Task encountered an exception: " + ex.getMessage());
return "0"; // 返回默认值或者做其他补偿操作
});
// 获取任务结果
String result = future.join();
results.add(result);
}
// 所有任务已完成，可以进行下一步操作
}
public void asynchronousAuthorization3(List<String> paramList) {
paramList.forEach(System.out::println);
System.out.println("异步执行 paramList 业务逻辑");
}
}
|