百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

线程用多了,是不是也了解了解协程(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...

取消回复欢迎 发表评论: