CompletableFuture 批量办卡

标签：批量 allOf futures future CompletableFuture new 办卡

需求背景：

每次传入需要办卡的订单的集合，根据每个办卡订单进行办卡操作。

 

技术要点：

CompletableFuture：

@Autowired
private ThreadPoolTaskExecutor executor;

方法：

List<CompletableFuture> futures = Collections.synchronizedList(new ArrayList<CompletableFuture>());   //创建线程集合 for (EtcCardApplyOrderRequestVo applyVo : etcCardApplyOrderRequestVoList) { 　　CompletableFuture<Result> future = CompletableFuture.supplyAsync(() -> applyOrder(applyOrderRequestVo),executor);  //每个线程内都有个返回bigdecimal
　　futures.add(future); }   //创建集合任务
CompletableFuture<Void> allOf = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));  
allOf.join();   //等待执行结束   //支付金额
amount = BigDecimal.ZERO;
for (CompletableFuture future : futures) {
if (future.isDone()){
try {
BigDecimal decimal = (BigDecimal) future.get();
amount = amount.add(decimal);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (ExecutionException e) {
throw new RuntimeException(e);
}
}   executor.shutdown(); }  

　　

标签：批量,allOf,futures,future,CompletableFuture,new,办卡
From： https://www.cnblogs.com/jiangzishun/p/17629239.html