线程用多了,是不是也了解了解协程(Coroutines)
lipiwang 2024-11-01 14:08 8 浏览 0 评论
前言
自从用上Kotlin之后,渐渐地开始路转粉,Kotlin的确是好用…
Coroutines(协程)正式版出来之后,逐渐感觉到这种以“同步”方式写异步代码的感觉还挺有意思。不用再写CallBack,直来直去、从上到下。
不过,在实际开发中,却因为用法的不规范,导致了性能受损,异常不断。因此在便有了这篇文章。
当然这篇文章,并不算我原创。准确的说是我翻译,因为人家总结的太好了。原文地址
正文
1、使用coroutineScope包装async调用或使用SupervisorJob处理异常
PS:这是一个坑,我们组就踩过。
如果异步块可能抛出异常,请不要依赖于使用try / catch块包装它。(没错,try不住的,仍会出现异常)
错误代码:
val job: Job = Job() val scope = CoroutineScope(Dispatchers.Default + job) // may throw Exception fun doWork(): Deferred<String> = scope.async { ... } // (1) fun loadData() = scope.launch { try { doWork().await() // (2) } catch (e: Exception) { ... } }
在上面的示例中,doWork函数启动新的协同程序(1),它可能会抛出未处理的异常。如果你尝试用try / catch块(2)包装doWork,它仍然会崩溃。
正确:避免崩溃的一种方法是使用SupervisorJob
// 区别就在这 val job = SupervisorJob() // (1) val scope = CoroutineScope(Dispatchers.Default + job) // may throw Exception fun doWork(): Deferred<String> = scope.async { ... } fun loadData() = scope.launch { try { doWork().await() } catch (e: Exception) { ... } }
!!注意!!
只有当async运行在拥有SupervisorJob的coroutine作用域时,这才有效(try住异常)。因此,下面的代码仍会崩溃,因为异步是在父协同程序(1)的作用域内启动的。
val job = SupervisorJob() val scope = CoroutineScope(Dispatchers.Default + job) fun loadData() = scope.launch { // 此情况下,是try不住异常的 try { async { // (1) // may throw Exception }.await() } catch (e: Exception) { ... } }
那么针对这种情况的正确做法是什么呢?
正确:另一种避免崩溃的方法是使用coroutineScope(1)包装async,这是最好的方法(PS:我们日常开发就这么使用就ok了)。现在,当异常发生在async内部时,它将取消在这个范围内创建的所有其他协程,而不涉及外部范围。(2)
val job = SupervisorJob() val scope = CoroutineScope(Dispatchers.Default + job) // may throw Exception fun doWork(): Deferred<String> = coroutineScope { // (1) async { ... } } fun loadData() = scope.launch { // (2) try { doWork().await() } catch (e: Exception) { ... } }
2、对于根协程来说,首选Dispatcher.Main
如果需要一个后台工作并在根协程中更新UI,那么不要用非主调度器(选Dispatcher.Main)启动它。
错误代码:
val scope = CoroutineScope(Dispatchers.Default) // (1) fun login() = scope.launch { withContext(Dispatcher.Main) { view.showLoading() } // (2) networkClient.login(...) withContext(Dispatcher.Main) { view.hideLoading() } // (2) }
这种写法是完全没有必要的,会造成性能上的损耗,因为在更新UI的时候,会带来上下文(CoroutineContext)的切换。所以针对这种业务,我们完全可以通过写法来避免这种损耗。
正确:针对这种业务,我们直接创建Dispatchers.Main的根协程就ok了。
val scope = CoroutineScope(Dispatchers.Main) fun login() = scope.launch { view.showLoading() withContext(Dispatcher.IO) { networkClient.login(...) } view.hideLoading() }
3、避免使用无意义的async/await
如果我们使用的是async(),然后是立即await(),那么应该立刻马上停止这种“骚”操作。
错误代码:
launch { val data = async(Dispatchers.Default) { /* code */ }.await() }
正确:如果仅想切换协程工作上下文并立即挂起父协程工作上下文,那么最好是这样做。
这话咋理解呢?说白了就是,如果我们只是想单纯的切换协程的上下文,直接用withContext就ok了。
launch { val data = withContext(Dispatchers.Default) { /* code */ } }
从性能上讲,这不是一个大问题,但从规范上讲,async()意味着:希望在后台启动几个协程任务,然后await()它们。
4、避免无脑取消Job
这是一个有趣的点。当然这部分内容,官方文档也有提起。
如果需要取消协程,请不要首先取消范围Job。
错误代码:
class WorkManager { val job = SupervisorJob() val scope = CoroutineScope(Dispatchers.Default + job) fun doWork1() { scope.launch { /* do work */ }} fun doWork2() { scope.launch { /* do work */ }} fun cancelAllWork() { job.cancel()} } fun main() { val workManager = WorkManager() workManager.doWork1() workManager.doWork2() workManager.cancelAllWork() workManager.doWork1() // (1) }
上述代码的问题是,当我们取消Job时,其将被置为已完成状态。方法(1)已经不会再被执行了。
正确:
如果要取消特定范围的所有协程,可以使用cancelChildren函数。此外,提供取消个人工作的可能性是一种很好的做法(2)。
class WorkManager { val job = SupervisorJob() val scope = CoroutineScope(Dispatchers.Default + job) fun doWork1(): Job = scope.launch { /* do work */ } // (2) fun doWork2(): Job = scope.launch { /* do work */ } // (2) fun cancelAllWork() { scope.coroutineContext.cancelChildren() // (1) } } fun main() { val workManager = WorkManager() workManager.doWork1() workManager.doWork2() workManager.cancelAllWork() workManager.doWork1() }
尾声
为了避免篇幅过长,精简掉了一些有歧义的,或者是我还没有研究明白的内容。总结、整理、翻译了这些内容。希望可以为在Kotlin路上前进的小伙伴们带来帮助~
相关推荐
- ubuntu单机安装open-falcon极度详细操作
-
备注:以下操作均由本人实际操作并得到验证,喜欢的同学可尝试操作安装。步骤一1.1环境准备(使用系统:ubuntu18.04)1.1.1安装redisubuntu下安装(参考借鉴:https://...
- Linux搭建promtail、loki、grafana轻量日志监控系统
-
一:简介日志监控告警系统,较为主流的是ELK(Elasticsearch、Logstash和Kibana核心套件构成),虽然优点是功能丰富,允许复杂的操作。但是,这些方案往往规模复杂,资源占用高,...
- 一文搞懂,WAF阻止恶意攻击的8种方法
-
WAF(Web应用程序防火墙)是应用程序和互联网流量之间的第一道防线,它监视和过滤Internet流量以阻止不良流量和恶意请求,WAF是确保Web服务的可用性和完整性的重要安全解决方案。它...
- 14配置appvolume(ios14.6配置文件)
-
使用AppVolumes应用程序功能,您可以管理应用程序的整个生命周期,包括打包、更新和停用应用程序。您还可以自定义应用程序分配,以向最终用户提供应用程序的特定版本14.1安装appvolume...
- 目前流行的缺陷管理工具(缺陷管理方式存在的优缺点)
-
摘自:https://blog.csdn.net/jasonteststudy/article/details/7090127?utm_medium=distribute.pc_relevant.no...
- 开源数字货币交易所开发学习笔记(2)——SpringCloud
-
前言码云(Gitee)上开源数字货币交易所源码CoinExchange的整体架构用了SpringCloud,对于经验丰富的Java程序员来说,可能很简单,但是对于我这种入门级程序员,还是有学习的必要的...
- 开发JAX-RPC Web Services for WebSphere(下)
-
在开发JAX-RPCWebServicesforWebSphere(上)一文中,小编为大家介绍了如何创建一个Web服务项目、如何创建一个服务类和Web服务,以及部署项目等内容。接下来小编将为大...
- CXF学习笔记1(cxf client)
-
webservice是发布服务的简单并实用的一种技术了,个人学习了CXF这个框架,也比较简单,发布了一些笔记,希望对笔友收藏并有些作用哦1.什么是webServicewebService让一个程序可...
- 分布式RPC最全详解(图文全面总结)
-
分布式通信RPC是非常重要的分布式系统组件,大厂经常考察的Dubbo等RPC框架,下面我就全面来详解分布式通信RPC@mikechen本篇已收于mikechen原创超30万字《阿里架构师进阶专题合集》...
- Oracle WebLogic远程命令执行0day漏洞(CVE-2019-2725补丁绕过)预警
-
概述近日,奇安信天眼与安服团队通过数据监控发现,野外出现OracleWebLogic远程命令执行漏洞最新利用代码,此攻击利用绕过了厂商今年4月底所发布的最新安全补丁(CVE-2019-2725)。由...
- Spring IoC Container 原理解析(spring中ioc三种实现原理)
-
IoC、DI基础概念关于IoC和DI大家都不陌生,我们直接上martinfowler的原文,里面已经有DI的例子和spring的使用示例《InversionofControlContainer...
- Arthas线上服务器问题排查(arthas部署)
-
1Arthas(阿尔萨斯)能为你做什么?这个类从哪个jar包加载的?为什么会报各种类相关的Exception?我改的代码为什么没有执行到?难道是我没commit?分支搞错了?遇到问题无法在...
- 工具篇之IDEA功能插件HTTP_CLENT(idea2021插件)
-
工具描述:Java开发人员通用的开发者工具IDEA集成了HTTPClient功能,之后可以无需单独安装使用PostMan用来模拟http请求。创建方式:1)简易模式Tools->HTTPCl...
- RPC、Web Service等几种远程监控通信方式对比
-
几种远程监控通信方式的介绍一.RPCRPC使用C/S方式,采用http协议,发送请求到服务器,等待服务器返回结果。这个请求包括一个参数集和一个文本集,通常形成“classname.meth...
- 《github精选系列》——SpringBoot 全家桶
-
1简单总结1SpringBoot全家桶简介2项目简介3子项目列表4环境5运行6后续计划7问题反馈gitee地址:https://gitee.com/yidao620/springbo...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- maven镜像 (69)
- undefined reference to (60)
- zip格式 (63)
- oracle over (62)
- date_format函数用法 (67)
- 在线代理服务器 (60)
- shell 字符串比较 (74)
- x509证书 (61)
- localhost (65)
- java.awt.headless (66)
- syn_sent (64)
- settings.xml (59)
- 弹出窗口 (56)
- applicationcontextaware (72)
- my.cnf (73)
- httpsession (62)
- pkcs7 (62)
- session cookie (63)
- java 生成uuid (58)
- could not initialize class (58)
- beanpropertyrowmapper (58)
- word空格下划线不显示 (73)
- jar文件 (60)
- jsp内置对象 (58)
- makefile编写规则 (58)