CompletableFuture基本概念及用法

news2024/10/5 14:17:15

CompletableFuture继承于java.util.concurrent.Future,它本身具备Future的所有特性,并且基于JDK1.8的流式编程以及Lambda表达式等实现一元操作符、异步回调以及事件驱动编程的异步类,可以用来实现多线程的串行关系,并行关系,聚合关系。它的灵活性和更强大的功能是Future无法比拟的。

简单来说,就是当使用异步线程去执行一个任务的时候,我们希望在任务结束以后触发

一个后续的动作。而CompletableFuture就可以实现这个功能。

举个简单的例子如下图,比如在一个批量支付的业务逻辑里面,涉及到查询订单、支付、发送邮件通知这三个逻辑。

这三个逻辑是按照顺序同步去实现的,也就是先查询到订单以后,再针对这个订单发起

支付,支付成功以后再发送邮件通知。

而这种设计方式导致这个方法的执行性能比较慢。

 

所以,这里可以直接使用CompletableFuture,如下图所示,也就是说把查询订单的逻辑放在一个异步线程池里面去处理。

然后基于CompletableFuture的事件回调机制的特性,可以配置查询订单结束后自动触发支付,支付结束后自动触发邮件通知。

从而极大的提升这个这个业务场景的处理性能!

 

CompletableFuture提供了5种不同的方式,把多个异步任务组成一个具有先后关系的处理链,然后基于事件驱动任务链的执行。

第一种,thenCombine (如图),把两个任务组合在一起,当两个任务都执行结束以后触发事件回调。

 

第二种,thenCompose (如图),把两个任务组合在一起,这两个任务串行执行,也就是第一个任务执行完以后自动触发执行第二个任务。

第三种,thenAccept(如图),第一个任务执行结束后触发第二个任务,并且第一个任务的执行结果作为第二个任务的参数,这个方法是纯粹接受上一个任务的结果,不返回新的计算值。

第四种,thenApply (如图),和thenAccept一样,但是它有返回值。

第五种,thenRun (如图),就是第一个任务执行完成后触发执行一个实现了Runnable接口的任务。

 

最后,我认为, CompletableFuture 弥补了原本Future的不足,使得程序可以在非阻塞的状态下完成异步的回调机制。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

I.MX6ULL_Linux_驱动篇(45)linux INPUT子系统

按键、鼠标、键盘、触摸屏等都属于输入(input)设备, Linux 内核为此专门做了一个叫做 input子系统的框架来处理输入事件。输入设备本质上还是字符设备,只是在此基础上套上了 input 框 架,用户只需要负责上报输入事件,比如按键值、…

Zotero+坚果云解决存储空间不足

Zotero实现同步有三种思路:①zotero自带同步(文件同步方式选择Zotero);②zotfile坚果云网盘同步;③zotero选项勾选文件同步坚果云WebDAV同步。由于第一种只有300M使用空间,使用一段时间就会提示存储空间不足…

动态规划(用空间换时间的算法)原理逻辑代码超详细!参考自《算法导论》

动态规划(用空间换时间的算法)-实例说明和用法详解 动态规划(DP)思想实例说明钢条切割问题矩阵链乘法问题 应用满足的条件和场景 本篇博客以《算法导论》第15章动态规划算法为本背景,大量引用书中内容和实例&#xff0…

【枚举,构造】CF1582 C D

Problem - C - Codeforces 题意: 思路: 思路很简单,只删除一种,直接枚举删除的是哪一种即可 但是回文子序列的判定我vp的时候写的很答辩,也不知道为什么当时要从中间往两边扫,纯纯自找麻烦 然后就越改越…

题解:散列查找(拉链法)出现冲突时,在散列表冲突点向外延伸一条链表(单链表),怎么使用memset函数

一、链接 840. 模拟散列表 二、题目 维护一个集合,支持如下几种操作: I x,插入一个数 xx;Q x,询问数 xx 是否在集合中出现过; 现在要进行 NN 次操作,对于每个询问操作输出对应的结果。 输…

SAP 开发编辑界面-关闭助手

打开关闭助手时的开发界面如下: 关闭关闭助手后的界面如下: 菜单栏: 编辑--》修改操作--》关闭助手

VLC视频直播低时延配置

默认的VLC的播放时延是比较高的,一般是秒级别,默认配置的话,都是5秒左右,这种默认配置是为了利用缓存机制,使播放体验更加流畅,对于需要更低时延的播放测试的话,并不适合,需要调整一…

商城-学习整理-基础-商品服务API-属性分组(七)

目录 一、创建系统菜单二、开发属性分组1、将三级分类功能抽取出来2、编写后端代码3、属性分组新增功能4、属性分组修改回显功能 三、品牌管理1、分页显示有点问题,使用MyBatis-Plus有点问题,需要使用分页插件,给容器中放一个2、修改模糊查询…

Netty: 向ChannelPipeline中添加ChannelHandler的顺序

Netty中的ChannelHandler有inbound handler,处理接收数据的过程;有outbound handler,处理发数据的过程。当然,也有的handler既处理接收的数据 ,也处理发送的数据。 每个channel对应一个ChannelPipeline。handler被添加…

多语言多用户跨境电商系统搭建--独立站源码制作

开发一个多语言多用户跨境电商系统搭建需要考虑以下几个方面: 1. 系统架构设计:选择一个适合多语言多用户跨境电商系统的开源框架或者自行设计系统架构。确保系统的稳定性和扩展性。 2. 多语言支持:设计一个多语言支持功能,使用…

电子邮件数据加密的工作原理

电子邮件数据加密是通过使用密码学算法对电子邮件的内容进行转换,使得只有授权的接收方能够解读邮件内容。下面是电子邮件数据加密的一般工作原理: 密钥生成:发送方和接收方分别生成自己的密钥对。密钥对通常包括公钥和私钥。公钥用于加密和验…

phonopy中频率单位的换算

phonopy给出的单位是THz,有时会向cm-1和eV单位进行转换。在phonopy中进行单位转换时, 主要是对在phonopy中使用的参数factor进行修改,我们平时声子谱导出使用命令是: phonopy band.conf (导出的是默认单位THz&…

Redisson 3.23.1 正式发布,官方推荐的 Redis 客户端

导读Redisson 3.23.1 现已发布,这是一个 Java 编写的 Redis 客户端,具备驻内存数据网格(In-Memory Data Grid)功能,并获得了 Redis 的官方推荐。 此版本更新内容如下: Improvement 减少了 RLiveObjectSer…

别再被问倒了!Mysql索引竟然在这些情况下失灵?

嗨,亲爱的读者们!小米又来啦~ 今天我们要聊一个在数据库面试中常常被问到的热门话题:Mysql索引失效。想要在面试中脱颖而出,掌握这个知识点可是必不可少哦!废话不多说,咱们现在就深入剖析一下,看…

SQL Server 查询数据并汇总相关技巧 23.08.08

GROUPING 是一个聚合函数,它产生一个附加的列,当用 CUBE 或 ROLLUP 运算符添加行时,附加的列输出值为1,当所添加的行不是由 CUBE 或 ROLLUP 产生时,附加列值为0。 仅在与包含 CUBE 或 ROLLUP 运算符的 GROUP BY 子句相联系的选择…

【模拟 + 离线】CF1719 C

Problem - C - Codeforces 题意: 思路: 手摸以下样例容易发现 对于最大值左边的数,答案可以直接模拟轮数得到 对于最大值,答案直接就是pos 对于最大值右边的数,答案就是0 接下来就是如何模拟轮数的问题了 一开始…

直流浪涌保护器与交流浪涌保护器的区别和作用

在现代社会,电力作为生产、生活的重要能源,其稳定供应显得尤为重要。然而,电力系统常常受到电压浪涌的干扰,这种突发的电压冲击可能给设备带来损害。为了应对这一问题,直流浪涌保护器和交流浪涌保护器应运而生&#xf…

Android车机录制视频报错,竟是编码器的锅 ?

1. 现象描述 工作中有一个项目,使用的是CameraView这个第三方相机库来调用相机。 CameraView封装了Camera1和Camera2,内部做了很多功能的封装,API使用起来相对比较简单。 在App中接入后,手机上能够正常录制视频,看上去…

Deep Networks with Stochastic Depth - 动态随机网络

文章目录 基本结构ResNet的公式改造效果计算前向传播过程 实验结果CIFAR数据集结果SVHN数据集结果训练时间的比对极深网络的对比测试ImageNet的测试结果测试过程中的结果 网络结构的Hyper-parameter比对测试 前面两篇是讲经典网络ResNet的: ResNet1 ResNet2 这个残…

中介者模式(Mediator)

中介者模式是一种行为设计模式,可以减少对象之间混乱无序的依赖关系。该模式会限制对象之间的直接交互,迫使它们通过一个封装了对象间交互行为的中介者对象来进行合作,从而使对象间耦合松散,并可独立地改变它们之间的交互。中介者…