Supplier 惰性调用和 Future#get 同步等待调用结合

📖一、背景介绍

关于任务异步执行,两个点不可避免:异步结果和异步回调。

而在我的工程中有这样一段代码:使用 CompletableFuture 进行封装,可以异步执行,异步回调,通过 get() 等待异步任务的结果

注:任何方法都可以封装成 CallbackTask 调用。

图片

但用着用着就发现明显的不对劲,主线程会阻塞等待结果。异步转同步!

图片

Optional.ofNullable(invoke.get(DEFAULT_MAX_TIMEOUT, TimeUnit.SECONDS))。get() 方法会进行阻塞等待。invokeWithResult 封装得不是很理想。

图片

有没有好的方法,不执行阻塞等待呢?直接返回 CompletableFuture 就可以了,等主线程用到的时候,再调用 CompletableFuture#get获取。

但用 CompletableFuture 作为方法返回值,个人觉得语义并不很好,有没有其他方式呢,带着这个问题过了一天,终于有了灵感 -- supplier 惰性求值。

📒二、supplier 惰性

Supplier接口在 Java 中通常被用于实现惰性求值。Supplier的特点在于它的 get()方法,该方法没有输入参数,并在被调用时返回一个T类型的值。在Supplier 被定义时,并不会执行 get() 方法中的代码;只有在显式调用 get() 方法时,代码才会执行,并且生成并提供一个值。

图片

这允许代码在需要时才生成值,从而实现了惰性求值。因为Supplier推迟了执行,直到调用者准备好接收值,这可以提高性能,避免不必要的计算,尤其是在处理耗时的操作或创建资源密集型对象时。

一个简单的例子可以展示Supplier的惰性行为

图片

灵感来了,尝试用 supplier 来解决上面的问题。

📑三、supplier 和 Future#get 结合

将 Future#get 用 supplier 表达,等需要异步结果的时候再从 supplier 中获取。

图片

没错,supplier 达到效果。主线程使用 invokeWithSupplier 时不再堵塞。只是有 supplier#get才会阻塞获得结果值。

但为了更符合业务语义,进一步将 supplier 进行包装,用包装类承载结果

图片

用 AsyncResp 作为返回类型,最终方法如下:

图片

后来回顾,AsyncResp 甚至可以对 CompletableFuture 进行包装,如下所示:

图片

真的是,条条道路通罗马,多一些思考发现代码其实还挺有趣的!

异步、异步回调、异步结果是非常常见的问题,应用的场景也特别多,工程中常备此类工具。

对于 supplier 惰性能力,包装了 Future#get,觉得挺有意思的,决定把过程记录下来。

最后说一句(求关注!)

如果这篇文章对您有所帮助,或者有所启发的话,求一键三连:点赞、转发、在看。

关注公众号:woniuxgg,在公众号中回复:笔记  就可以获得蜗牛为你精心准备的java实战语雀笔记,回复面试、开发手册、有超赞的粉丝福利!

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

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

相关文章

JUC-CAS

1. CAS概述 CAS(Compare ans swap/set) 比较并交换,实现并发的一种底层技术。它将预期的值和内存中的值比较,如果相同,就更新内存中的值。如果不匹配,一直重试(自旋)。Java.util.concurrent.atomic包下的原…

【GitHub项目推荐--一个简单的绘图应用程序(Rust + GTK4)】【转载】

一个用 Rust 和 GTK4 编写的简单的绘图应用程序来创建手写笔记。 Rnote 旨在成为一个简单但实用的笔记应用程序,用于手绘或注释图片或文档。它最终能够导入/导出各种媒体文件格式。而且输出的作品是基于矢量的,这使其在编辑和更改内容时非常灵活。 地址…

微信小程序之全局配置-window和tabBar

学习的最大理由是想摆脱平庸,早一天就多一份人生的精彩;迟一天就多一天平庸的困扰。各位小伙伴,如果您: 想系统/深入学习某技术知识点… 一个人摸索学习很难坚持,想组团高效学习… 想写博客但无从下手,急需…

解密POM:提升自动化脚本稳定性和开发效率的正确姿势!

Page Objects是selenium的一种测试设计模式,主要将每个页面看作是一个class。class的内容主要包括属性和方法,属性不难理解,就是这个页面中的元素对象,比如输入用户名的输入框,输入登陆密码的输入框、登陆按钮、这个页…

数据库设计问题

问题: 某学校要设计一个数据库,学校的业务规则概括如下: 学校内班级若干,每个班级内又有学生若干。学校开设课程若干,只有某些特定的班级能上指定的课程。学生选修某些课程,但是在自身班级下的课程是必修。学校定期组…

RK3399平台开发系列讲解(网络篇)什么是Linux路由

🚀返回专栏总目录 文章目录 一、什么是路由二、路由配置命令沉淀、分享、成长,让自己和他人都能有所收获!😄 一、什么是路由 一张路由表中会有多条路由规则。每一条规则至少包含这三项信息。 目的网络:这个包想去哪儿?出口设备:将包从哪个口扔出去?下一跳网关:下一个…

[RK-Linux] 移植Linux-5.10到RK3399(十)| 配置AP6256模组使能WIFI、BT功能

手上 ROC-RK3399-PC Pro 使用蓝牙 WIFI 模组是 AP6256。 一、AP6256 模组介绍 AP6256是正基科技(AMPAK)推出的一款低成本、低功耗的双模模块,它集成了Wi-Fi和蓝牙功能。这款模块支持SDIO接口,具有以下特点: 1、型号:AP6256 2、接口:SDIO(Secure Digital Input/Outp…

分类预测 | Matlab实现LSTM-Attention-Adaboost基于长短期记忆网络融合注意力机制的Adaboost数据分类预测/故障识别

分类预测 | Matlab实现LSTM-Attention-Adaboost基于长短期记忆网络融合注意力机制的Adaboost数据分类预测/故障识别 目录 分类预测 | Matlab实现LSTM-Attention-Adaboost基于长短期记忆网络融合注意力机制的Adaboost数据分类预测/故障识别分类效果基本描述程序设计参考资料 分类…

【DG 特长生2019】模拟赛赛后总结(2024.1.24)

打了330pt,订正后350pt T1 签到 T2 dfs剪枝(虽然我写挂了) T3 NOIP原题 T4 floyd 主要是想分享一下T4。 写了一种基于floyd的做法。 感觉好像和大部分人的写法不太一样。 因为看到大小关系,我就想到了传递性。 floyd是可以维护传递…

Pyside6中QTableWidget使用

目录 一:介绍: 二:演示 一:介绍: 在 PySide6 中,QTableWidget 是一个用于展示和编辑表格数据的控件。它提供了在窗口中创建和显示表格的功能,并允许用户通过单元格来编辑数据。 要使用 QTabl…

【学网攻】 第(4)节 -- 交换机划分Vlan

文章目录 【学网攻】 第(1)节 -- 认识网络 【学网攻】 第(2)节 -- 交换机认识及使用【学网攻】 第(3)节 -- 交换机配置聚合端口 前言 网络已经成为了我们生活中不可或缺的一部分,它连接了世界各地的人们,让信息和资源得以自由流动。随着互联网的发展&am…

Linux 下查看端口以及释放端口

目录 一、查看端口是否被占用 1、使用 netstat 命令 2、使用 lsof 命令 二、释放端口 1、使用kill命令 2、使用 fuser 命令 三、netstat 四、lsof 五、fuser 一、查看端口是否被占用 在 Linux 系统上,你可以使用 netstat 或 lsof 命令来查看端口是否被占用。…