详解Java8中CompletableFuture类的使用
作者:程序员无名 发布时间:2022-06-28 17:39:43
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对象执行完毕。
来源:https://juejin.cn/post/7221151497974972473
猜你喜欢
- 这篇文章主要介绍了JDK线程池和Spring线程池的使用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值
- ShardingSphereShardingSphere是一套开源的分布式数据库中间件解决方案组成的生态圈,它由Sharding-JDBC、
- 一、JdbcTemplateSpring 框架对 JDBC 进行封装,使用 JdbcTemplate 方便实现对数据库操作二、实战2.1 引
- 这篇文章主要介绍了Java日期与时间类原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参
- springboot集成swagger3swagger3的springboot启动器jar包<!-- https://mvnrepos
- 一、场景描述仪器数据文件的格式包含Pdf、Word、Excel等多种,不同种格式的文件其数据的采集方式不同,因此定义仪器数据采集接口,并定义
- 前文本章是关于Java流程控制语句的最全汇总,本篇为汇总中篇。流程是人们生活中不可或缺的一部分,它表示人们每天都在按照一定的流程做事。比如出
- 前言xxljob 是采用 java 开发的开源的任务调度系统,架构上分为调度管理器、执行器,目前除了官方提供的 java 执行器外,也有 g
- SSO :同一个帐号在同一个公司不同系统上登陆 使用SpringSecurity实现类似于SSO登陆系统是十分简单的 下面我就搭
- 一、Java的前世为什么会产生Java?Java的特点是什么?从C语言开始讲,C语言是一种结构化语言,模块化编程,便于程序的调试,依靠非常全
- 首先:因为工作需要,需要对接socket.io框架对接,所以目前只能使用netty-socketio。websocket是不支持对接sock
- 引言在Broker中,事务消息的初始化是通过BrokerController.initialTransaction()方法执行的。priva
- java获取文件的inode标识符,如果文件被删除或者重命名,inode的值会发生变更,因此可以在第一次加载File之后记录inode,后续
- jar 包启动时指定配置文件 application.ymlnohup java -jar vPaas.jar --spring.confi
- jstat命令简介jstat(Java Virtual Machine Statistics Monitoring Tool)是JDK提供的
- 其实这个表示有点不太对,应该是 Druid 动态切换数据源的方法,只是应用在了 springboot 框架中,准备代码准备了半天,之前在一次
- 一. String类简介1. 介绍字符串广泛应用 在 Java 编程中,在 Java 中字符串属于对象,Java 提供了 String 类来
- 本文实例讲述了Java实现的计算最大下标距离算法。分享给大家供大家参考,具体如下:题目描述给定一个整形数组,找出最大下标距离j−i, 当且A
- 前言目前主流的锁有两种,一种是synchronized,另一种就是ReentrantLock,JDK优化到现在目前为止synchronize
- 本文实例为大家分享了java实现酒店管理系统的具体代码,供大家参考,具体内容如下要求:【酒店管理系统】HotelSystem.java某酒店