BlockingonacollectionofFutures(在一组Futures上阻塞)
创始人
2024-12-22 20:30:25
0

如果需要等待一组未来值而不想阻塞主线程,可以使用 CompletableFuture 类提供的 CompletableFuture.allOf() 方法。该方法接受一组 CompletableFuture 对象并返回一个新的 CompletableFuture,该 CompletableFuture 在所有对象都完成后执行。可以将回调附加到这个 CompletableFuture,以在所有对象都完成后执行。

以下是一个示例代码,演示如何在一组 CompletableFuture 中使用 allOf() 方法:

import java.util.concurrent.*;

public class CompletableFutureExample {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newFixedThreadPool(2);

        CompletableFuture future1 = CompletableFuture.supplyAsync(() -> {
            try {
               Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Result of Future 1";
        }, executor);

        CompletableFuture future2 = CompletableFuture.supplyAsync(() -> {
            try {
               Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Result of Future 2";
        }, executor);

        CompletableFuture future3 = CompletableFuture.supplyAsync(() -> {
            try {
               Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Result of Future 3";
        }, executor);

        CompletableFuture allFutures = CompletableFuture.allOf(future1, future2, future3);

        allFutures.thenRun(() -> {
            try {
                String combinedResult = future1.get() + "\n" + future2.get() + "\n" + future3.get();
                System.out.println(combinedResult);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
            executor.shutdown();
        });

        // wait for all futures to complete
        allFutures.get();
    }
}

在上面的示例中,我们用 CompletableFuture.supplyAsync() 创建了三个 Future。然后,我们使用 CompletableFuture.allOf() 创建了一个 CompletableFuture,使得我们可以等待所有 Future 的完成而不阻塞主线程。在所有未来对象完成时执行回调。然后我们使用 Future.get() 来等待每个 Future 的结果,并将它们组合起来。最后,我们关闭了线程池。

相关内容

热门资讯

软件辅助挂!顺欣茶楼辅助视频(... 软件辅助挂!顺欣茶楼辅助视频(辅助)真是是有辅助神器(有挂规律)顺欣茶楼辅助视频脚本下载中分为三种模...
方法辅助挂!潘潘讲故事app辅... 方法辅助挂!潘潘讲故事app辅助(辅助)真是是有辅助挂(真实有挂)1、点击下载安装,潘潘讲故事app...
记者获悉!小程序蜀山西川血战辅... 记者获悉!小程序蜀山西川血战辅助(辅助)切实存在有辅助工具(有挂详情)小薇(辅助器软件下载)致您一封...
2026版规律!广东雀神智能插... 2026版规律!广东雀神智能插件辅助(辅助)一贯确实有辅助技巧(有挂透视)1)广东雀神智能插件辅助有...
2026版辅助挂!九九联盟后台... 2026版辅助挂!九九联盟后台可以操作吗(辅助)总是是有辅助方法(有挂透明挂)九九联盟后台可以操作吗...
方法辅助挂!黑科技辅助软件免费... 方法辅助挂!黑科技辅助软件免费(辅助)切实是真的有辅助工具(有挂秘籍)一、黑科技辅助软件免费可以开透...
此事备受玩家关注!雀神广东麻将... 此事备受玩家关注!雀神广东麻将透视视频(辅助)竟然存在有辅助攻略(讲解有挂)1、金币登录送、破产送、...
无独有偶!潮友会pp下载辅助器... 无独有偶!潮友会pp下载辅助器(辅助)好像真的是有辅助app(有挂秘籍)1、下载好潮友会pp下载辅助...
2026版方法!广东雀神祈福真... 2026版方法!广东雀神祈福真的有用吗(辅助)好像是有辅助技巧(有挂工具)1、进入到广东雀神祈福真的...
网友热议!欢聚水鱼神器(辅助)... 网友热议!欢聚水鱼神器(辅助)确实真的是有辅助工具(有挂秘笈)欢聚水鱼神器能透视中分为三种模型:欢聚...