CompletableFuture 基本用法

一、 CompletableFuture简介

CompletableFuture 是 Java 8 引入的一个功能强大的类，用于异步编程和并发处理。它提供了丰富的 API 来处理异步任务的结果，支持函数式编程风格，并允许通过链式调用组合多个异步操作。

二、CompletableFuture中的方法

1. 创建 CompletableFuture 对象

  • CompletableFuture.supplyAsync(Supplier<U> supplier): 异步执行给定的 Supplier 函数，并返回一个新的 CompletableFuture，当函数完成时，该 CompletableFuture 将以函数的结果完成。

示例代码：

import java.util.concurrent.CompletableFuture;  
import java.util.concurrent.ExecutionException;  public class CompletableFutureExample {  public static void main(String[] args) throws ExecutionException, InterruptedException {  // 使用 supplyAsync 异步执行一个计算  CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {  // 模拟一个耗时的计算  try {  Thread.sleep(2000); // 等待 2 秒  } catch (InterruptedException e) {  Thread.currentThread().interrupt();  throw new IllegalStateException(e);  }  return "Hello, CompletableFuture!";  });  // 主线程可以继续执行其他任务，而不需要等待上面的计算完成  // 当需要结果时，可以调用 get() 方法（这会阻塞，直到结果可用）  String result = future.get(); // 这里会等待上面的计算完成，然后返回结果  System.out.println(result); // 输出 "Hello, CompletableFuture!"  }  
}

 这里顺便讲一下get方法：

（1）get方法的作用是等待此 CompletableFuture 完成，然后返回其结果（或抛出异常）。

（2）get方法的返回值是CompletableFuture<T> 里面的泛型的类型；比如上面的例子中CompletableFuture<String> 泛型是String 所以这里future.get()的返回值是String类型

示例1：

import java.util.concurrent.CompletableFuture;  
import java.util.concurrent.ExecutionException;  public class CompletableFutureExample {  public static void main(String[] args) throws ExecutionException, InterruptedException {  CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {  ...... });  String result = future.get(); // 因为 CompletableFuture<String> 泛型是String 所以这里future.get()的返回值是String类型}  
}

示例2：

import java.util.concurrent.CompletableFuture;  
import java.util.concurrent.ExecutionException;  public class CompletableFutureExample {  public static void main(String[] args) throws ExecutionException, InterruptedException {  CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {  ...... });  Integerresult = future.get(); // 因为 CompletableFuture<Integer> 泛型是Integer所以这里future.get()的返回值是Integer类型}  
}

另外，supplyAsync 方法还有一个重载版本，它接受一个 Executor 作为参数，允许你指定用于执行计算的线程池。这对于控制异步任务的执行环境非常有用。例如：

ExecutorService executor = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池  
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {  // ... 耗时的计算 ...  
}, executor); // 使用指定的线程池执行计算

 

  • CompletableFuture.runAsync(Runnable runnable): 异用于异步地执行一个 Runnable 任务，并且不返回任何结果（返回类型为 CompletableFuture<Void>）。这在你只关心任务的执行而不关心其返回值时非常有用。
import java.util.concurrent.CompletableFuture;  public class CompletableFutureExample {  public static void main(String[] args) {  // 使用默认的 ForkJoinPool 异步执行任务  CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {  // 模拟一个耗时的任务  try {  Thread.sleep(2000); // 假设任务需要2秒来完成  } catch (InterruptedException e) {  Thread.currentThread().interrupt(); // 恢复中断状态  throw new RuntimeException(e); // 抛出运行时异常以便可以看到异常信息  }  System.out.println("任务执行完毕！");  });  // 在主线程中继续执行其他操作，不需要等待上面的任务完成  System.out.println("主线程继续执行...");  // 如果你想等待任务完成，可以调用 future.join() 或 future.get()，但请注意这可能会阻塞当前线程  // 这里我们只是打印出任务是否已经完成  System.out.println("任务是否完成: " + future.isDone());  // 注意：由于任务是异步执行的，所以上面的 isDone() 方法可能返回 false，因为任务可能还没有完成  // 你可以通过 future.thenRun(...) 来添加在任务完成后要执行的代码  future.thenRun(() -> System.out.println("任务完成后执行的代码"));  // 注意：thenRun 中的代码也是异步执行的，并且可能在主线程之后执行  // 为了确保主线程在异步任务完成后才结束，可以调用 future.join()  try {  future.join(); // 等待异步任务完成  } catch (Exception e) {  e.printStackTrace();  }  // 现在可以确定异步任务已经完成  System.out.println("主线程结束");  }  
}

 

2. 处理异步任务的结果

  • thenApply(Function<? super T,? extends U> fn): 当此 CompletableFuture 完成时，将结果应用于给定的函数，并返回一个新的 CompletableFuture，该 CompletableFuture 将以函数的结果完成。
  • thenAccept(Consumer<? super T> action): 当此 CompletableFuture 完成时，对结果执行给定的操作，然后返回 this。
  • thenRun(Runnable action): 当此 CompletableFuture 完成时，执行给定的操作，然后返回 this。

3. 组合多个 CompletableFuture

  • thenCombine(CompletableFuture<? extends U> other, BiFunction<? super T,? super U,? extends V> fn): 当此 CompletableFuture 和另一个给定的 CompletableFuture 都完成时，使用这两个结果作为参数应用给定的函数，并返回一个新的 CompletableFuture，该 CompletableFuture 将以函数的结果完成。

传统写法：

    public static void main(String[] args) {CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(1000); // 等待1秒} catch (InterruptedException e) {e.printStackTrace();}return 42; // 假设这是第一个任务的结果});CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(500); // 等待0.5秒} catch (InterruptedException e) {e.printStackTrace();}return 13; // 假设这是第二个任务的结果});// 使用 thenCombine 合并两个任务的结果CompletableFuture<Integer> resultFuture = future1.thenCombine(future2, (a, b) -> a + b);// 等待结果并打印Integer join = resultFuture.join();System.out.println(join);//55}

 链式调用：

   public static void main(String[] args) {CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(1000); // 等待1秒} catch (InterruptedException e) {e.printStackTrace();}return 42; // 假设这是第一个任务的结果}).thenCombine(CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(500); // 等待0.5秒} catch (InterruptedException e) {e.printStackTrace();}return 13; // 假设这是第二个任务的结果}),(res1,res2)->{int total = res1 + res2;return total;});// 等待结果并打印Integer total = future1.join();System.out.println(total); // 42+13=55}
  • thenCompose(Function<? super T,? extends CompletionStage<U>> fn): 当此 CompletableFuture 完成时，对其结果应用给定的函数，该函数返回一个新的 CompletionStage，然后返回表示该 CompletionStage 结果的 CompletableFuture。

 thenCompose是 CompletableFuture 类中的一个方法，它允许你将一个 CompletableFuture 的结果用作另一个 CompletableFuture 计算的输入，从而链式地组合多个异步操作。

使用场景

thenCompose 适用于以下场景：

  1. 连续异步处理：当你需要对一个异步操作的结果进行另一个异步操作时，可以使用 thenCompose 将这两个操作连接在一起。
  2. 避免嵌套：使用 thenCompose 可以避免 Future 的嵌套，使得代码更加简洁和平坦。

传统写法：

package com.etime.test;import java.util.concurrent.CompletableFuture;/*** @Date 2024/6/22 20:08* @Author liukang**/
public class SupplyAsyncTest {public static void main(String[] args) {CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(1000); // 等待1秒} catch (InterruptedException e) {e.printStackTrace();}return 42; // 假设这是计算的结果});CompletableFuture<Integer> resultFuture = future.thenCompose(value -> {// 使用前一个任务的结果（value）作为输入，创建并返回一个新的CompletableFuturereturn CompletableFuture.supplyAsync(() -> value * 2); // 将结果乘以2});// 等待结果并打印Integer join = resultFuture.join();System.out.println(join);//84}}

 链式调用：

  public static void main(String[] args) {CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(1000); // 等待1秒} catch (InterruptedException e) {e.printStackTrace();}return 42; // 假设这是计算的结果}).thenCompose(value -> CompletableFuture.supplyAsync(()->{return value*2;}));Integer join = future.join();System.out.println(join);}
  • allOf(CompletableFuture<?>... cfs): 返回一个新的 CompletableFuture，该 CompletableFuture 在所有给定的 CompletableFuture 都完成时完成。
  • anyOf(CompletableFuture<?>... cfs): 返回一个新的 CompletableFuture，该 CompletableFuture 在任何一个给定的 CompletableFuture 完成时完成。

4. 异常处理

  • exceptionally(Function<Throwable,? extends T> fn): 当此 CompletableFuture 异常完成时，应用给定的函数到异常，并返回一个新的 CompletableFuture，该 CompletableFuture 将以函数的结果完成。

exceptionally是Java中CompletableFuture类的一个方法，用于处理异步操作中可能发生的异常。通过调用exceptionally方法并定义一个异常处理函数，你可以确保在异步操作出现异常时能够优雅地处理，并返回一个默认值或其他的值。

    public static void main(String[] args) {CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {// 模拟耗时计算，返回结果try {Thread.sleep(1000); // 等待1秒} catch (InterruptedException e) {e.printStackTrace();}return 42; // 假设这是计算的结果}).thenCompose(value -> CompletableFuture.supplyAsync(()->{return value/0;})).exceptionally((e -> {System.out.println("发生了异常");System.out.println("异常信息为："+e.getMessage());return null;}));// 等待结果并打印Integer join = future.join();System.out.println(join);}

 

  • handle(BiFunction<? super T,Throwable,? extends U> fn): 当此 CompletableFuture 完成时，无论是正常完成还是异常完成，都将结果和异常（如果有）应用于给定的函数，并返回一个新的 CompletableFuture，该 CompletableFuture 将以函数的结果完成。

5. 其他方法

  • join(): 等待此 CompletableFuture 完成，然后返回其结果（或抛出异常），是get方法的升级版。
  • get(): 等待此 CompletableFuture 完成，然后返回其结果（或抛出异常）。与 join() 类似，但可能抛出 InterruptedException 和 ExecutionException。

join()和get()的区别

  1. 抛出异常的方式不同：
    • get 方法会抛出 ExecutionException 异常（如果异步任务执行过程中出现异常），这个异常是具体的，需要显式捕获。此外，如果线程在等待过程中被中断，它还会抛出 InterruptedException。
    • join 方法则会抛出 CompletionException 异常（如果异步任务执行过程中出现异常），这个异常是 unchecked 的，因此不需要显式捕获。如果线程在等待过程中被中断，它不会抛出 InterruptedException，因为它本身是不可中断的。

  1. 方法调用限制不同：
    • get 方法可以在调用时设置等待的超时时间，如果超时还没有获取到结果，就会抛出 TimeoutException 异常。这使得 get 方法在使用时具有更大的灵活性。
    • join 方法则没有这样的超时机制，一旦调用就必须等待任务执行完成才能返回结果。它不能被中断，除非异步任务本身完成。

  1. 返回结果类型不同：
    • get 方法返回的是异步任务的执行结果，该结果是泛型类型 T 的，需要强制转换才能获取真正的结果。
    • join 方法同样返回的是异步任务的执行结果，但不需要强制类型转换，因为其结果就是泛型类型 T。
  2. 推荐使用方式不同：
    • join 方法通常被推荐用于 CompletableFuture，因为它没有受到 interrupt 的干扰，不需要捕获异常，也不需要强制类型转换。这使得代码更加简洁和易于阅读。
    • get 方法则提供了更多的控制选项，如设置超时时间，这在某些需要更细粒度控制的场景下可能是有用的。但需要注意的是，它可能会抛出 InterruptedException，这需要在代码中显式处理。
  3. 阻塞行为：
    • 两者都是阻塞方法，都会阻塞当前线程直到异步任务完成。但如上所述，join 方法是不可中断的，而 get 方法可以被中断。

总结来说，join 和 get 方法在 CompletableFuture 中都用于获取异步任务的执行结果，但在抛出异常的方式、方法调用限制、返回结果类型以及推荐使用方式等方面存在显著的区别。根据具体的需求和场景，可以选择使用 join 或 get 方法。

  • complete(T value): 如果尚未完成，则尝试以给定值完成此 CompletableFuture。
  • completeExceptionally(Throwable ex): 如果尚未完成，则尝试以给定异常完成此 CompletableFuture。

这些只是 CompletableFuture 提供的一部分方法，但它已经足够强大，可以处理大多数异步编程和并发处理的场景。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/32333.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

通用大模型的低代码平台——3分钟内快速搭建一个邮件提醒工具

通用大模型的低代码平台——3分钟内快速搭建一个邮件提醒工具

文章目录 ⭐前言⭐node-koa开发一个发送邮件的api⭐百度智能云控制面板&#x1f496; 发送邮件的组件配置&#x1f496; 配置应用发布 ⭐总结⭐结束 ⭐前言 大家好&#xff0c;我是yma16&#xff0c;通用大模型的低代码平台——3分钟内快速搭建一个智能股票分析邮件提醒工具。…
阅读更多...
Linux环境搭建之CentOS7（包含静态IP配置）

Linux环境搭建之CentOS7（包含静态IP配置）

&#x1f525; 本文由 程序喵正在路上 原创&#xff0c;CSDN首发&#xff01; &#x1f496; 系列专栏&#xff1a;虚拟机 &#x1f320; 首发时间&#xff1a;2024年6月22日 &#x1f98b; 欢迎关注&#x1f5b1;点赞&#x1f44d;收藏&#x1f31f;留言&#x1f43e; 安装VMw…
阅读更多...
SD卡无法读取？原因分析与数据恢复策略

SD卡无法读取？原因分析与数据恢复策略

一、SD卡无法读取的困境 SD卡作为便携式的存储介质&#xff0c;广泛应用于手机、相机、平板等多种电子设备中。然而&#xff0c;在使用过程中&#xff0c;我们可能会遭遇SD卡无法读取的困扰。当我们将SD卡插入设备时&#xff0c;设备无法识别SD卡&#xff0c;或者虽然识别了SD…
阅读更多...
投资者回归理性？美股去年备受追捧的AI概念股，今年超过一半在下跌

投资者回归理性？美股去年备受追捧的AI概念股，今年超过一半在下跌

喊两句AI就能圈钱的日子一去不复返了&#xff0c;未来企业要用实打实的业绩说话。 正文 去年备受追捧的AI概念股中&#xff0c;今年绝大多数已经开始下跌。面对越来越谨慎的投资者&#xff0c; 上市公司或许很难再打着AI的旗号圈钱。 今年&#xff0c;标普500指数中有60%的股…
阅读更多...
教大家封装一个基础el-table 行内气泡编辑框，你一定用的到

教大家封装一个基础el-table 行内气泡编辑框，你一定用的到

今天的任务就是封装这个用element ui 组件来封装，如果让你封装你会怎么封装呢？ 不说废话了，直接上代码 新建一个EditablePopoverColumn.vue组件文件 <template><el-table-column :prop="prop" :label="label"><template slot-scope=&…
阅读更多...
和琪宝的厦门之旅～

和琪宝的厦门之旅～

本作品采用知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议进行许可。 本作品 (李兆龙 博文, 由 李兆龙 创作)&#xff0c;由 李兆龙 确认&#xff0c;转载请注明版权。 引言 承接去年国庆的遗憾&#xff0c;我们将这次的旅行城市定为厦门。 琪宝是下午四点左右到…
阅读更多...
机器学习课程复习——支持向量机

机器学习课程复习——支持向量机

支持向量机是一种二类分类模型。基本模型：定义在特征空间上的间隔最大的线性分类器模型升级：线性分类器+核技巧=非线性分类器学习策略：间隔最大化（可形式化为求解凸二次规划的问题；可等价于正则化的合页损失函数的最小化问题）学习算法：求解图二次规划的最优化算法支持向…
阅读更多...
C语言程序设计-2 程序的灵魂—算法

C语言程序设计-2 程序的灵魂—算法

【例 2.1】求 12345。 最原始方法&#xff1a; 步骤 1&#xff1a;先求 12&#xff0c;得到结果 2。 步骤 2&#xff1a;将步骤 1 得到的乘积 2 乘以 3&#xff0c;得到结果 6。 步骤 3&#xff1a;将 6 再乘以 4&#xff0c;得 24。 步骤 4&#xff1a;将 24 再乘以 5&#xf…
阅读更多...
荒野大镖客2启动找不到emp.dll的7个修复方法，轻松解决dll丢失的办法

荒野大镖客2启动找不到emp.dll的7个修复方法，轻松解决dll丢失的办法

一、emp.dll文件丢失的常见原因 安装或更新问题&#xff1a;在软件或游戏的安装过程中&#xff0c;可能由于安装程序未能正确复制文件到目标目录&#xff0c;或在更新过程中文件被意外覆盖或删除&#xff0c;导致emp.dll文件丢失。 安全软件误删&#xff1a;某些安全软件可能…
阅读更多...
0702负反馈放大电路的四种组态

0702负反馈放大电路的四种组态

阅读更多...
自动控制原理出射角计算

自动控制原理出射角计算

背景&#xff1a;突然发现自己出射角不会算 被减数是零点到极点的角度&#xff0c;减数是极点到极点的角度
阅读更多...
关于Windows系统下redis的闪退问题。

关于Windows系统下redis的闪退问题。

一、问题分析 首先&#xff0c;有这个问题的一般是如下操作&#xff1a; 1、在运行项目时发现无法连接到redis服务器&#xff0c; 2、进入Redis安装目录(如图)——>鼠标双击打开redis-server.exe&#xff0c;然后闪退&#xff0c; 3、运行redis-cli时提示&#xff1a;“由…
阅读更多...
使用ESP32和Flask框架实现温湿度数据监测系统

使用ESP32和Flask框架实现温湿度数据监测系统

项目概述 在这个项目中&#xff0c;我们将使用ESP32微控制器读取温湿度传感器的数据&#xff0c;并将这些数据通过HTTP请求传输到基于Flask框架的服务器。Flask是一个轻量级的Python Web框架&#xff0c;非常适合快速开发和部署Web应用。通过这个项目&#xff0c;我们不仅可以了…
阅读更多...
【Unity】RPG2D龙城纷争（三）角色、角色数据集

【Unity】RPG2D龙城纷争（三）角色、角色数据集

更新日期&#xff1a;2024年6月18日。 项目源码&#xff1a;第五章发布&#xff08;正式开始游戏逻辑的章节&#xff09; 索引 简介角色数据集&#xff08;RoleDataSet&#xff09;一、定义角色数据集类二、角色基础数据&#xff08;公共数据&#xff09; 角色&#xff08;Role…
阅读更多...
最优化第六讲练习题

最优化第六讲练习题

使用牛顿法 def f(vec):x1,x2vec[0],vec[1]return x1*x1/22*x2*x2def first_order(vec):x1,x2vec[0],vec[1]return np.array((x1,4*x2))x0np.array((2,1)) #初始点 secnp.array([[1,0],[0,4]]) #二阶导 try:invnp.linalg.inv(sec) except:print("矩阵不存在逆矩阵")…
阅读更多...
基于YOLOv5的交通标志检测的设计与实现

基于YOLOv5的交通标志检测的设计与实现

简介 在智能交通系统中，交通标志的准确检测与识别对提高道路安全和交通效率至关重要。为了实现这一目标，我们开发了一种基于YOLOv5目标检测模型的交通标志检测系统。本报告将详细介绍该系统的实际应用与实现，包括系统架构、功能实现、使用说明、检测示例、数据集获取与介绍…
阅读更多...
Rocky Linux archive下载地址

Rocky Linux archive下载地址

Index of /vault/rocky/https://dl.rockylinux.org/vault/rocky/
阅读更多...
2024年安全员-A证证考试题库及安全员-A证试题解析

2024年安全员-A证证考试题库及安全员-A证试题解析

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 2024年安全员-A证证考试题库及安全员-A证试题解析是安全生产模拟考试一点通结合&#xff08;安监局&#xff09;特种作业人员操作证考试大纲和&#xff08;质检局&#xff09;特种设备作业人员上岗证考试大纲随机出的…
阅读更多...
ArcGIS arcpy代码工具——批量要素裁剪栅格影像

ArcGIS arcpy代码工具——批量要素裁剪栅格影像

系列文章目录 ArcGIS arcpy代码工具——批量对MXD文件的页面布局设置修改 ArcGIS arcpy代码工具——数据驱动工具批量导出MXD文档并同步导出图片 ArcGIS arcpy代码工具——将要素属性表字段及要素截图插入word模板 ArcGIS arcpy代码工具——定制属性表字段输出表格 ArcGIS arc…
阅读更多...
C++ 79 之 自己写异常类

C++ 79 之 自己写异常类

#include <iostream> #include <string> using namespace std;class MyOutOfRange : public exception{ // 选中exception右键 转到定义 复制一份 virtual const char* what() const _GLIBCXX_TXN_SAFE_DYN _GLIBCXX_NOTHROW 进行函数重写 public: string m_msg;M…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023