ExecutorService executors =Executors.newFixedThreadPool(5);
CompletableFuture aFuture = CompletableFuture.supplyAsync(() -> {
log.info("aaaaaaaaaaaaaaaaaa");
return "aa";
}, executors);
CompletableFuture bFuture = CompletableFuture.supplyAsync(() -> {
log.info("bbbbbbbbbbbbbbbbb");
return "bb";
}, executors);
CompletableFuture cFuture = CompletableFuture.supplyAsync(() -> {
log.info("cccccccccc");
return "cc";
}, executors);
log.info("return:"+aFuture.get());
log.info("return:"+bFuture.get());
log.info("return:"+cFuture.get());
JAVA基于CompletableFuture的流水线并行处理深度实践,满满干货 - 掘金
多线程并发之CountDownLatch(闭锁)使用详解_流烟默的博客-CSDN博客_多线程countdownlatch
版权声明:本文为zmm0420原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。