Java CompletableFuture：你真的了解它吗？

在这里插入图片描述

文章目录

    • 1 什么是 CompletableFuture？
    • 2 如何正确使用 CompletableFuture 对象？
    • 3 如何结合回调函数处理异步任务结果？
    • 4 如何组合并处理多个 CompletableFuture？

1 什么是 CompletableFuture？

CompletableFuture 是 Java 8 引入的一个强大的异步编程工具。允许以声明式的方式处理异步任务的结果，避免了传统回调和手动管理线程的复杂性。

CompletableFuture 可以组合和链式调用，高效地利用多核处理器的能力，并且减少了传统并发编程中常见的竞态条件和死锁等问题。

在日常开发中，经常需要处理那些可能耗时的任务，比如网络请求、数据库查询或者复杂的计算。使用 CompletableFuture，可以告诉程序如何在后台执行这些任务，然后在任务完成后执行特定的操作。

可以想象一下，CompletableFuture 就像是一条可以穿越时间的信使，你可以把一项任务托付给它，然后继续做其他事情。当任务完成时，它会及时将结果送回来，让你可以立即处理。这样，你就不必在等待任务完成的过程中浪费时间，而是可以更高效地利用自己的资源。

2 如何正确使用 CompletableFuture 对象？

CompletableFuture 可以以一种非阻塞的方式执行异步任务，并能够在任务完成后立即得到通知。通过链式调用的方式，可以很方便地组合多个异步操作，处理它们的结果或者异常。

通过 CompletableFuture.supplyAsync() 方法创建一个 CompletableFuture 对象，并指定一个需要异步执行的任务：

//  Supplier 函数会在一个新的线程上异步执行
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 模拟一个耗时操作，如从数据库中读取数据try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}return "异步任务完成";
});

通过在 CompletableFuture 上添加一些操作，比如处理任务的结果或者处理任务执行过程中可能发生的异常：

// thenAccept()方法接收一个 Consumer 函数
future.thenAccept(result -> {System.out.println("任务完成，结果为：" + result);
}).exceptionally(ex -> {System.out.println("任务出现异常：" + ex.getMessage());return null;
});

3 如何结合回调函数处理异步任务结果？

结合回调函数处理异步任务结果的过程可以比作在等待一份重要的快递时安排一个通知服务。这个通知服务就是回调函数，它会在快递送达时通知你，或者在处理完成后执行特定的操作。

在 Java 的 CompletableFuture 中，这种模式可以通过 supplyAsync() 、thenApply()、thenAccept() 和 handle() 方法来实现。

创建一个异步任务时，使用 CompletableFuture.supplyAsync() 可以启动一个任务，这个任务在后台线程中执行，直到它完成。假设有一个任务需要从远程服务器获取数据：

// supplyAsync() 方法接收一个 Supplier 函数，这个函数会在后台线程中运行，并返回一个结果
// 结果会被封装在 CompletableFuture 对象中，等待进一步处理
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 模拟从远程服务器获取数据try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}return "数据已成功获取";
});

使用 thenApply() 方法，可以在异步任务完成后，对结果进行转换。这个方法接收一个 Function 函数，这个函数会接收任务的结果，并返回一个新结果。比如，将获取的数据进行处理：

// thenApply() 方法将原始数据转换为大写形式
// 处理后的结果会成为新的 CompletableFuture 对象的结果
CompletableFuture<String> processedFuture = future.thenApply(result -> {// 对结果进行处理return result.toUpperCase();
});

为了执行一个操作而不关心处理的结果，可以使用 thenAccept() 方法。这个方法接收一个 Consumer 函数，它处理任务完成时的结果，可以在异步任务完成时执行一些操作，比如日志记录或通知用户。例如，将结果打印到控制台：

// 在任务完成后会调用传入的 Consumer 函数，并将结果传递给它
future.thenAccept(result -> {System.out.println("任务完成，结果是：" + result);
});

在任务执行过程中，可能会遇到异常。handle() 方法可以用来处理这些异常，它接收一个 BiFunction 函数，这个函数接收结果和异常（如果有的话），并返回一个处理后的结果。例如：

// handle() 方法检查是否有异常发生
// 如果有异常，它会处理异常并返回一个默认的结果
// 如果没有异常，它会处理正常的结果
CompletableFuture<String> handledFuture = future.handle((result, ex) -> {if (ex != null) {// 处理异常System.out.println("任务发生错误：" + ex.getMessage());return "错误处理结果";}// 处理正常结果return result.toLowerCase();
});

对于这四种回调函数，可以使得异步任务的结果处理变得灵活而强大。通过结合使用不同的回调函数，可以对异步任务的结果进行多种操作，保证程序在处理复杂任务时仍然保持清晰和高效。

4 如何组合并处理多个 CompletableFuture？

组合和处理多个 CompletableFuture 可以让并发任务变得更加灵活和高效。设想有多个任务需要并行执行，然后将它们的结果结合起来进行进一步处理。

在进行组合时，最基本的方法之一是将多个 CompletableFuture 的结果合并。比如，有两个任务需要并行完成，获取两个不同的数据源，然后将这两个结果结合起来。

可以使用 thenCombine() 方法，它接收两个 CompletableFuture 和一个合并函数，两个 CompletableFuture 必须在相同的线程池中执行。

假设有两个任务分别从不同的 API 获取数据：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {// 模拟从第一个 API 获取数据return "数据1";
});CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {// 模拟从第二个 API 获取数据return "数据2";
});

为了将这两个结果结合起来，可以使用 thenCombine()：

// thenCombine() 方法接收两个 CompletableFuture 和一个函数，这个函数将两个任务的结果合并成一个结果
// 最终的结果是将两个字符串连接在一起
CompletableFuture<String> combinedFuture = future1.thenCombine(future2, (result1, result2) -> {// 将两个结果结合成一个return result1 + " 和 " + result2;
});

另一个有用的方法是 allOf()方法。当有多个任务需要并行执行，并且在所有任务完成后执行某个操作时，allOf() 非常有用。它接收一个 CompletableFuture 数组，并在所有这些 CompletableFuture 完成时触发。可以用来等待多个异步任务完成，然后执行某个操作：

CompletableFuture<Void> allOfFuture = CompletableFuture.allOf(future1, future2);

要获取所有任务的结果，可以在 allOf() 的结果上添加一个回调函数：

// thenRun() 方法会在所有任务完成后执行，它不需要处理结果，只是执行某个操作
allOfFuture.thenRun(() -> {// 处理所有任务完成后的操作try {String result1 = future1.get();String result2 = future2.get();System.out.println("任务1的结果: " + result1);System.out.println("任务2的结果: " + result2);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}
});

如果有任务依赖于另一个任务的结果，可以使用 thenCompose()方法。这种情况下，第二个任务会在第一个任务完成后开始执行。thenCompose() 方法接收一个返回 CompletableFuture 的函数，然后将这两个 CompletableFuture 链接起来：

CompletableFuture<String> future3 = future1.thenCompose(result1 -> {// 使用第一个任务的结果来创建新的 CompletableFuturereturn CompletableFuture.supplyAsync(() -> result1 + " 处理完成");
});

对于这些方法来说，它们为处理多个异步任务提供了强大的工具，使得并发编程更加高效和灵活。通过合理使用这些方法，可以实现复杂的异步任务组合和处理逻辑，确保程序的高效执行。

世界会向那些有目标和远见的人让路

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

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

相关文章

Coze插件发布！PDF转Markdown功能便捷集成，打造你的专属智能体

Coze插件发布！PDF转Markdown功能便捷集成，打造你的专属智能体

近日&#xff0c;TextIn开发的PDF转Markdown插件正式上架Coze。 在扣子搜索“pdf转markdown”&#xff0c;或在Coze搜索“pdf2markdown” 即可找到插件&#xff0c;在你的专属智能体中便捷使用文档解析功能。 如果想测试解析插件在你需要的场景下表现如何&#xff0c;可以直接…
阅读更多...
后端开发刷题 | 合并k个已排序的链表

后端开发刷题 | 合并k个已排序的链表

描述 合并 k 个升序的链表并将结果作为一个升序的链表返回其头节点。 数据范围&#xff1a;节点总数 0≤n≤5000&#xff0c;每个节点的val满足 ∣val∣<1000 要求&#xff1a;时间复杂度 O(nlogn) 示例1 输入&#xff1a; [{1,2,3},{4,5,6,7}] 返回值&#xff1a; …
阅读更多...
【数据结构】二叉树的深度理解

【数据结构】二叉树的深度理解

&#x1f36c;个人主页&#xff1a;Yanni.— &#x1f308;数据结构&#xff1a;Data Structure.​​​​​​ &#x1f382;C语言笔记&#xff1a;C Language Notes 前言 在之前学习了二叉树的基本概念&#xff0c;但二叉树有着更深入知识理解&#xff0c;这篇文章可以帮助大…
阅读更多...
使用Obsidian实现Anki快速制卡

使用Obsidian实现Anki快速制卡

文章目录 前言准备双双启用遇到问题查看是什么问题解决问题 开始使用使用前的一些设置快速制卡 前言 我现在使用 Anki 的同时也使用 Obsidian&#xff0c;正好可以通过插件来让这两个十分好用的软件实现联动。 在 Obsidian 中实现 Anki 的快速制卡。 准备 首先要在这两个软…
阅读更多...
原型制作 | 歌词与进度条的位置呼应

原型制作 | 歌词与进度条的位置呼应

在之前的案例里面咱们做过了歌词滚动的效果&#xff0c;具体效果是这样的&#xff0c;点击播放按钮&#xff0c;歌词开始滚动&#xff1b;点击暂停按钮&#xff0c;歌词停止滚动&#xff0c;再次点击播放&#xff0c;歌词会继续滚动&#xff1b;一直播放直到结束&#xff0c;歌…
阅读更多...
java常见面试题汇总

java常见面试题汇总

&#x1f30f;个人博客主页&#xff1a;意疏-CSDN博客 希望文章能够给到初学的你一些启发&#xff5e; 如果觉得文章对你有帮助的话&#xff0c;点赞 关注 收藏支持一下笔者吧&#xff5e; 阅读指南&#xff1a; 开篇说明一、封装 继承 多态1.封装2.继承3.多态 二、什么是重载…
阅读更多...
【前端】VUE 在线运行 模拟器 通过字符串动态渲染页面 可以灵活使用

【前端】VUE 在线运行 模拟器 通过字符串动态渲染页面 可以灵活使用

【前端】VUE2 在线运行 模拟器 通过字符串动态渲染页面 可以灵活使用 <template><div><!-- 这里是动态组件--><component :is"component"></component><!-- 这里是动态组件--><br /><br /><br />可…
阅读更多...
Gitlab添加ssh秘钥download项目

Gitlab添加ssh秘钥download项目

1. 查看 、设置 git 用户名和邮箱 git config user.namegit config user.email git config --global user.name 用户名git config --global user.email 邮箱 2. 查看本地是否有ssh秘钥 秘钥默认放在C:\Users\用户\.ssh\目录下&#xff0c;进入这个目录&#xff0c;如果有 …
阅读更多...
elasticsearch的高亮查询三种模式查询及可能存在的问题

elasticsearch的高亮查询三种模式查询及可能存在的问题

目录 高亮查询使用介绍 高亮参数 三种分析器 可能存在的查询问题 fvh查询时出现StringIndexOutOfBoundsException越界 检索高亮不正确 参考文档 高亮查询使用介绍 Elasticsearch 的高亮&#xff08;highlight&#xff09;可以从搜索结果中的一个或多个字段中获取突出显…
阅读更多...
社区维修平台

社区维修平台

TOC springboot0751社区维修平台 第一章 绪 论 1.1背景及意义 系统管理也都将通过计算机进行整体智能化操作&#xff0c;对于社区维修平台所牵扯的管理及数据保存都是非常多的&#xff0c;例如住户管理、社区公告管理、维修工管理、维修订单管理、接单信息管理、订单信息管…
阅读更多...
谁将解锁储能的未来？迈威通信邀您共探EESA储能展的秘密

谁将解锁储能的未来？迈威通信邀您共探EESA储能展的秘密

九月金秋&#xff0c;硕果盈枝&#xff0c;迈威通信诚挚邀请您共赴一场科技盛宴——第三届EESA储能展&#xff0c;时间锁定9月2日至4日&#xff0c;地点&#xff1a;国家会展中心(上海)&#xff0c;一场关于绿色能源、智慧储能的梦幻之旅即将启航&#xff01; 您准备好迎接未来…
阅读更多...
利用大型语言模型协作提升甲状腺结节超声诊断的一致性和准确性| 文献速递-基于深度学习的癌症风险预测与疾病预后应用

利用大型语言模型协作提升甲状腺结节超声诊断的一致性和准确性| 文献速递-基于深度学习的癌症风险预测与疾病预后应用

Title 题目 Collaborative Enhancement of Consistency and Accuracy in US Diagnosis of Thyroid Nodules Using Large Language Models 利用大型语言模型协作提升甲状腺结节超声诊断的一致性和准确性 Background 背景 Large language models (LLMs) hold substantial …
阅读更多...
Redis内存管理

Redis内存管理

Redis使用Jemalloc(默认编译)来进行内存的管理&#xff1a; Jemalloc将内存分成许多不同的区域&#xff0c;每个区域成为arena&#xff0c;areana之间相互独立。Jemalloc通过创建多个arena来减少线程申请内存的操作冲突。一般arena数量为cpu数量*4. arena以chunk为单位向操作…
阅读更多...
FPGA 综合笔记

FPGA 综合笔记

仿真时阻塞赋值和非阻塞赋值 Use of Non-Blocking Assignment in Testbench : Verilog Use of Non-Blocking Assignment in Testbench : Verilog - Stack Overflow non-blocking assignment does not work as expected in Verilog non-blocking assignment does not work a…
阅读更多...
Python使用QtSide6(PyQt)编写界面

Python使用QtSide6(PyQt)编写界面

1、安装QtSide6 开始菜单cmd 创建虚拟环境 python -m venv env2 进入虚拟环境 call env2/scripts/activate 安装Pyside6 pip install Pyside6 2、设计Qt界面 打开designer.exe&#xff0c;设计界面 点击菜单【窗体】【View Python Code...】&#xff0c;点击【全部复制】…
阅读更多...
HarmonyOs透明弹窗(选择照片弹窗样式)

HarmonyOs透明弹窗(选择照片弹窗样式)

1.鸿蒙中需要实现一个如下图的弹窗 2.由上图中可以得出&#xff0c;只需要三个Text组件依次向下排列&#xff0c;弹窗背景设置透明即可&#xff0c;弹窗代码如下(仅展示弹窗样式)&#xff1a; /**** 自定义选择图片弹窗** 外部定义需要导出*/ CustomDialog //自定义弹窗 export…
阅读更多...
android13顶部状态栏里面调节背光，不隐藏状态栏面板

android13顶部状态栏里面调节背光，不隐藏状态栏面板

总纲 android13 rom 开发总纲说明 目录 1.前言 2.代码分析 3.修改方法 4.编译运行 5.彩蛋 1.前言 android13顶部状态栏里面调节背光，这个时候状态栏面板会被隐藏掉，有些需求就需要不隐藏这个面板。 2.代码分析 查找亮度条属性 id/brightness_slider ./frameworks/b…
阅读更多...
TOMCAT入门到精通

TOMCAT入门到精通

目录 一 WEB技术 1.1 HTTP协议和B/S 结构 1.2 前端三大核心技术 1.2.1 HTML 1.2.2 CSS&#xff08;Cascading Style Sheets&#xff09;层叠样式表 1.2.3 JavaScript 二 WEB框架 2.2后台应用架构 2.2.1单体架构 2.2.2微服务 2.2.3单体架构和微服务比较 三 tomcat的…
阅读更多...
2024Go语言面试宝典Golang零基础实战项目面试八股力扣算法笔记等

2024Go语言面试宝典Golang零基础实战项目面试八股力扣算法笔记等

2024最新Golang面试八股文&#xff0c;以及各种零基础全套实战项目&#xff0c;经典力扣算法题以及常见的面试题型&#xff0c;大厂面试题。go语言面试必备。包括GO基础类、GO并发编程、GO RUNTIME、微服务、容器技术、Redis、MySQL、Linux、缓存、网络和操作系统、消息队列、分…
阅读更多...
房产系统架构开发小程序分析

房产系统架构开发小程序分析

房产系统架构开发小程序在当前市场中具有显著的优势和潜力。以下是对房产小程序的分析&#xff1a; 用户需求满足&#xff1a;房产小程序通过提供楼盘信息查询、VR看房体验、购房流程指南等功能&#xff0c;满足用户对房产信息的需求&#xff0c;并提供更加便捷的用户体验 。…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023