CompletableFuture.runAsync 是开启异步线程并且是无返回值。 CompletableFuture.allOf().join 等所有循环执行完毕再走主线程。

//线程池使用
@Autowired
@Qualifier("asyncServiceExecutor")
private Executor executor;
/*业务代码，add到list*/
CompletableFuture.allOf(list.stream().map(async ->   CompletableFuture.runAsync(() -> {
/*业务代码*/
}, executor)).toArray(CompletableFuture[]::new)).join();
复制代码