文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

详解Java8中CompletableFuture类的使用

2023-05-15 14:33

关注

Java 8中引入了CompletableFuture类,它是一种方便的异步编程工具,可以处理各种异步操作,如网络请求、文件IO和数据库操作等。它是Java的Future接口的扩展,提供了一些有用的方法来创建、操作和组合异步操作。本文将详细介绍CompletableFuture的使用方式。

创建CompletableFuture

CompletableFuture提供了多种方法来创建CompletableFuture对象,如:

1.使用CompletableFuture.supplyAsync()方法创建异步执行的Supplier,Supplier中的代码会在异步线程中执行,代码执行完毕后,CompletableFuture将会得到执行结果。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");

2.使用CompletableFuture.runAsync()方法创建异步执行的Runnable,Runnable中的代码会在异步线程中执行,代码执行完毕后,CompletableFuture将会得到null作为执行结果。

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
    //异步执行的代码
});

3.使用CompletableFuture.completedFuture()方法创建一个已经完成的CompletableFuture对象。

CompletableFuture<String> future = CompletableFuture.completedFuture("Hello");

4.使用CompletableFuture的构造方法创建CompletableFuture对象。

CompletableFuture<String> future = new CompletableFuture<>();

这种方式通常用于在执行某个操作之前创建一个CompletableFuture对象,并将其传递给其他方法,以便在异步操作完成后将结果传递回来。

处理CompletableFuture的结果

当异步操作完成时,可以通过CompletableFuture的get()方法获取执行结果。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");
String result = future.get();
System.out.println(result); //输出"Hello"

但是,get()方法是一个阻塞的方法,它会一直等待异步操作完成,并返回结果或者抛出异常。如果你不想阻塞当前线程,你可以使用回调函数的方式来处理CompletableFuture的结果。

1.使用thenApply()方法处理CompletableFuture的结果。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<String> future2 = future.thenApply(result -> result + " World");
System.out.println(future2.get()); //输出"Hello World"

在这个例子中,我们使用thenApply()方法来处理CompletableFuture的结果。它接受一个Function函数,用于将CompletableFuture的结果转换为另一个值。

2.使用thenAccept()方法处理CompletableFuture的结果。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");
future.thenAccept(result -> System.out.println(result + " World"));

在这个例子中,我们使用thenAccept()方法来处理CompletableFuture的结果。它接受一个Consumer函数,用于处理CompletableFuture的结果,但是不返回任何结果。

3.使用thenCompose()方法组合多个CompletableFuture。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "World");
CompletableFuture<String> future3 = future1.thenCompose(result1 -> future2.thenApply(result2 -> result1 + " " + result2));
     try {
        System.out.println(future3.get());
    } catch (InterruptedException e) {
          throw new RuntimeException(e);
    } catch (ExecutionException e) {
        throw new RuntimeException(e);
    }

在这个例子中,我们使用thenCompose()方法来组合多个CompletableFuture对象。它接受一个Function函数,该函数将CompletableFuture的结果转换为另一个CompletableFuture对象。在这个例子中,我们先使用future1来创建一个新的CompletableFuture对象,然后将future2的结果作为参数传递给该对象的处理函数。

4.使用thenCombine()方法组合多个CompletableFuture。

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> 10);
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 20);
CompletableFuture<Integer> future3 = future1.thenCombine(future2, (result1, result2) -> result1 + result2);
System.out.println(future3.get()); //输出30

在这个例子中,我们使用thenCombine()方法来组合多个CompletableFuture对象。它接受另一个CompletableFuture对象和一个BiFunction函数,该函数用于将两个CompletableFuture的结果合并为一个新的结果。

处理CompletableFuture的异常

当CompletableFuture执行过程中出现异常时,我们需要使用exceptionally()方法来处理异常。

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    throw new RuntimeException("异常信息");
});

future.exceptionally(ex -> {
    System.out.println(ex.getMessage()); //输出"异常信息"
    return 0;
});

在这个例子中,我们使用exceptionally()方法来处理CompletableFuture的异常。它接受一个Function函数,用于处理异常并返回一个默认值。

等待多个CompletableFuture执行完毕

有时我们需要等待多个CompletableFuture对象执行完毕后再继续执行下一步操作。我们可以使用CompletableFuture的allOf()方法或anyOf()方法来等待多个CompletableFuture对象执行完毕。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "World");
CompletableFuture<Void> allFuture = CompletableFuture.allOf(future1, future2);
allFuture.get();

CompletableFuture<Object> anyFuture = CompletableFuture.anyOf(future1, future2);
System.out.println(anyFuture.get()); //输出"Hello"或"World"

在这个例子中,我们使用allOf()方法来等待所有的CompletableFuture对象执行完毕,并使用anyOf()方法来等待任何一个CompletableFuture对象执行完毕。

总结

CompletableFuture是Java 8中提供的一种非常方便的异步编程工具,它可以处理各种异步操作,并提供了丰富的方法来创建、操作和组合CompletableFuture对象。在实际应用中,我们可以根据实际需求选择合适的方法来使用CompletableFuture,提高代码的性能和可读性。

到此这篇关于详解Java8中CompletableFuture类的使用的文章就介绍到这了,更多相关Java8 CompletableFuture类内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯