Android Kotlin 异步操作回调转换为挂起函数

news2025/1/21 3:03:08

异步接口回调是一种通过接口将任务的执行和结果处理分离开来的编程设计模式。通常用于网络请求、数据库查询等耗时操作。

挂起函数是 Kotlin 中的一个特性,用于简化异步编程。挂起函数是可以在协程中暂停执行并恢复的函数,避免了回调地狱问题,使代码更加简洁和易读。在Kotlin中,我们可以使用 suspend 关键字来定义挂起函数,并通过 CoroutineScope 来管理和启动协程。

在真实的开发过程当中,遇到一些第三方的 SDK 是异步回调的,会与自身项目的协程作用域无法配合使用,以下举一个简单的例子:


 定义一个接口和异步操作方法:

interface Callback {
    fun onSuccess(result: String)
    fun onError(error: Throwable)
}

fun fetchData(callback: Callback) {
    // 异步操作
    thread {
        Thread.sleep(1000)
        callback.onSuccess("成功")
    }
}

在方法中模拟在子线程进行异步处理,完成后将数据通过接口返回


以 Activity 的 lifecycleScope 为例:

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        lifecycleScope.launch { // 主线程中开启协程作用域
            Log.e(TAG, "Scope: 开始")

            fetchData(object : Callback {
                override fun onSuccess(result: String) {
                    Log.i(TAG, result)
                }

                override fun onError(error: Throwable) {
                    Log.e(TAG, error.message.toString())
                }

            })

            Log.e(TAG, "Scope: 结束")
        }
    }

实际运行结果:

可以看到,协程内部并没有等待回调完成,直接结束了,因为方法内开启了一个子线程,对于方法而言,逻辑已经执行完毕了,所以直接输出了结束。在真实的开发过程当中,是需要等待接口回调后来执行下一个步骤的,所以需要将异步操作的方法转换为挂起函数


使用 suspendCoroutine 进行封装:

suspend fun fetchDataAsync(): String = suspendCoroutine {
    fetchData(object : Callback {
        override fun onSuccess(result: String) {
            it.resume(result)
        }

        override fun onError(error: Throwable) {
            it.resumeWithException(error)
        }
    })
}

在执行 suspendCoroutine 时,会将当前的协程作用域挂起,直到指定的回调函数调用 continuation.resume 或 continuation.resumeWithException 来恢复它。通过它就能很好的将异步操作转换为挂起函数,以便进行统一的协程管理

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        lifecycleScope.launch { // 主线程中开启协程作用域
            Log.e(TAG, "Scope: 开始")

            val result = fetchDataAsync()
            Log.i(TAG, result)

            Log.e(TAG, "Scope: 结束")
        }
    }

运行结果:

 


还可以使用 suspendCancellableCoroutine,它是 suspendCoroutine 的可取消版本,追加了协程取消的支持。如果协程被取消,它会自动调用取消逻辑。

suspend fun fetchDataAsync(): String = suspendCancellableCoroutine {
    fetchData(object : Callback {
        override fun onSuccess(result: String) {
            it.resume(result)
        }

        override fun onError(error: Throwable) {
            it.resumeWithException(error)
        }
    })
    it.invokeOnCancellation {
        // 协程取消时执行相应的取消逻辑,比如进行资源的释放等
    }
}

通过这个转换,我们可以利用 Kotlin 协程的强大特性来简化异步代码,让代码更易读且更具维护性

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

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

相关文章

php质量工具系列之PHPCPD

PHPCPD 用于检测重复代码,直观的说就是复制粘贴再稍微改改 该工具作者已经 停止维护 安装 composer global require --dev sebastian/phpcpd执行 phpcpd --log-pmd phpcpd_result.xml ./app参数介绍 --log-pmd 将结果保存在phpcpd_result.xml 中 ./app 是phpcpd扫…

linux系统PXE自动装机和无人值守

一、PXE 1.PXE:c/s模式,允许客户端通过网络从远程服务器(服务端)下载引导镜像,加载安装文件,实现自动化安装操作系统。(c/s客户端和服务端都可以是多台) 2.PXE优点:规模…

【机器学习基础】Python编程08:五个实用练习题的解析与总结

Python是一种广泛使用的高级编程语言,它在机器学习领域中的重要性主要体现在以下几个方面: 简洁易学:Python语法简洁清晰,易于学习,使得初学者能够快速上手机器学习项目。 丰富的库支持:Python拥有大量的机器学习库,如scikit-learn、TensorFlow、Keras和PyTorch等,这些…

基于STM32开发的智能家居监控系统

目录 引言环境准备智能家居监控系统基础代码实现:实现智能家居监控系统 4.1 传感器数据读取4.2 电器设备控制4.3 实时数据监控与分析4.4 用户界面与数据可视化应用场景:家庭安全监控与管理问题解决方案与优化收尾与总结 1. 引言 随着智能家居技术的发…

AI绘画中的图像格式技术

在数字艺术的广阔天地里,AI绘画作为一种新兴的艺术形式,正在逐渐占据一席之地。不同于传统绘画,AI绘画依赖于复杂的算法和机器学习模型来生成图像,而这一切的背后,图像格式技术发挥着至关重要的作用。图像格式不仅关系…

23 二叉搜索树

本节目标 1.内容安排说明 2.二叉搜索树实现 3.应用分析 4.进阶题 1. 内容安排说明 二叉树在c数据结构已经说过了,本节内容是因为: map和set特性需要先铺垫二叉搜索树,而二叉搜索树也是一种树形结构二叉搜索树的特性了解,有助于…

LNMP与动静态网站介绍

Nginx发展 Nginx nginx http server Nginx是俄罗斯人 Igor Sysoev(伊戈尔.塞索耶夫)开发的一款高性能的HTTP和反向代理服务器。 Nginx以高效的epoll.kqueue,eventport作为网络IO模型,在高并发场景下,Nginx能够轻松支持5w并发连接数的响应,并…

OrangePi AIpro Ubuntu 22.04 aarch64 安装MySql 8.0

查看MySQL安装包 接下来可以使用以下命令安装MySQL服务器: 安装MySQL 8.0 # 安装最新版本 sudo apt install -y mysql-server # 安装指定版本 sudo apt install -y mysql-server-8.0初始化配置信息 sudo mysql_secure_installationVALIDATE PASSWORD COMPONENT ca…

算法分析与设计期末考试复习(更新ing)

重点内容: 绪论: 简单的递推方程求解 1.19(1)(2) 、 教材例题 多个函数按照阶的大小排序 1.18 分治法: 分治法解决芯片测试问题 计算a^n的复杂度为logn的算法(快速幂) 分治法解决平面最近点对问…

SecureCRT[po破] for Mac SSH终端操作工具[解] 安装教程

文章目录 效果一、准备工作二、开始安装1、双击运行软件,将其从左侧拖入右侧文件夹中,等待安装完毕2、 应用程序显示软件图标,表示安装成功 三、输入对应参数1、解决“软件已损坏,无法打开,要移到废纸篓”问题解决步骤…

从零开始实现自己的串口调试助手(8)-循环发送

循环发送 准备 创建槽函数 设置QSpinBox的最大值 注意: // 我们不能在qt的ui线程中延时,否则将导致页面刷新问题 //QThread::msleep(ui->spinBox->text().toInt());//设置下次发送时间间隔 定时器实现 关联信号与槽: //添加自动换行定…

【Vue】什么是props

文章目录 一、介绍二、代码示例三、props校验四、props校验完整写法五、props&data、单向数据流 一、介绍 Props 定义 组件上 注册的一些 自定义属性 Props 作用 向子组件传递数据 特点 可以 传递 任意数量 的prop可以 传递 任意类型 的prop 二、代码示例 父组件App…

实习记录2

1.flowable框架参数传递大概流程 通过传递xml,传递到后端,然后后端去解析 2.vue封装组件 在 Vue.js 中创建可复用的自定义组件是一个常见的需求,这样可以提高代码的复用性和可维护性。下面是一个简单的步骤指南,帮助你创建一个…

无锡哲讯——机械行业ERP管理系统,引领智能制造新纪元

机械行业作为现代工业的基石,正面临着前所未有的变革。随着智能制造的兴起,ERP管理系统在机械行业中的作用日益凸显。无锡哲讯智能科技有限公司,凭借其在ERP领域的专业实力和丰富经验,为机械行业客户提供定制化的ERP解决方案&…

Transformer学习之SwinTransformer

1.算法简介 本文主要参考自以下链接,整理成线上的形式用于备忘,排版太麻烦了直接贴图,参考的朋友慎重,不如直接看参考链接,后期有了新的理解继续更正。 参考链接1:Swin-Transformer网络结构详解_swin tran…

【计算机网络】对应用层协议中HTTPS协议的总结

˃͈꒵˂͈꒱ write in front ꒰˃͈꒵˂͈꒱ ʕ̯•͡˔•̯᷅ʔ大家好,我是xiaoxie.希望你看完之后,有不足之处请多多谅解,让我们一起共同进步૮₍❀ᴗ͈ . ᴗ͈ აxiaoxieʕ̯•͡˔•̯᷅ʔ—CSDN博客 本文由xiaoxieʕ̯•͡˔•̯᷅ʔ 原创 CSDN 如…

上市公司绿色并购数据+do文件(1996-2024.4)

数据简介:手工搜集重污染上市公司的并购公告,采用内容分析法,对每次并购的背景和目的,主并企业和标的企业经营范围以及该次并购对主并企业带来的影响进行综合分析,逐一判断该项并购事件是否为绿色并购 时间跨度&#…

欢乐钓鱼大师辅助:哪家云手机自动钓鱼更好操作!

在探索《欢乐钓鱼大师》的世界时,我们不得不提到一个强大的游戏辅助工具——VMOS云手机。通过VMOS云手机,你可以轻松实现自动钓鱼,让游戏体验更加便捷高效。 什么是VMOS云手机? VMOS云手机是一款基于虚拟机技术的云端工具&#…

融云:应用出海新增长引擎,GPT-4o 后的 AI 创新与用户运营

近日,融云与 TikTok、维卓联合在京举办了“十年出海,遇上 AI”私享会。 会上,融云解决方案架构师于洪达带来了《应用出海新增长引擎,AI 创新与用户精细化运营》主题分享,探讨在 AI 技术大潮下应用出海通过创新运营方式…

金融科技:跨境支付的新引擎,开启全球化支付新时代

一、引言 在全球经济一体化的今天,跨境支付作为连接各国经贸往来的重要桥梁,其便捷性、安全性和效率性成为了各国企业和消费者关注的焦点。金融科技,作为现代金融与传统科技深度融合的产物,正以其独特的创新力和推动力,成为跨境支付领域的新引擎,引领着全球化支付新时代…