Android开发中使用协程(上手指南)

一.保持对协程的追踪

我们知道协程可以处理耗时任务,但是假如我们的项目中开启了一千个协程处理任务,我们都是通过手动去追踪它们,那代码很容易出错。也很容易失去对协程的实时跟踪。就会引起work leak,任务泄漏,类似内存泄漏一样,任务泄漏会导致CPU,内存,磁盘资源被占用。甚至会发起一些无用的网络请求。为了避免任务的泄漏,Kotlin引入了结构化并发机制。
在Android平台使用结构化并发可以做到以下三件事:
(1)取消任务——当任务不需要继续执行的时候,取消他
(2)追踪任务——当任务正在执行的时候追踪他
(3)发出错误的信号——当协程执行失败时,发出错误信号表明有错误发生

二.借助scope 来取消任务

scope在协程中称为作用域,协程的运行必须指定作用域,CoroutineScope(作用域)可以对协程进行追踪,即使协程被挂起也是如此。CoroutineScope并不运行协程,他只是确保实时跟着协程的运行。因此在Kotlin中不允许在没有作用域的情况下启动新的协程。作用域可以跟踪所有的协程,有可以取消由它启动的协程。在Android开发中经常用到。比如在一个Activity中启动一个协程,当Activity关闭的时候,取消协程的执行。这个时候我们可以联想到让我们Activity的生命周期保持和作用域的生命周期一样。以上总结就是:作用域(CoroutineScope )会跟踪所有的协程,并可以取消由它启动的协程。

三.协程的启动方式

启动协程,必须要在作用域内,而启动协程的方式有两种:
(1)launch构建器——启动新的协程而不将结果返回给调用方
(2)async构建器——启动新的协程,通过await的挂起函数返回result
如:以下launch启动的协程,我们只是在挂起函数doSomthingOne中拿到了返回值。

package com.example.kotlin01

import kotlinx.coroutines.*
suspend fun main() {
    runBlocking {
        var job = launch {
            var result1 = doSomthingOne()
            println(result1)
        }

    }

}
suspend fun doSomthingOne(): Int {
    delay(2000)
    return 13
}

13

如:以下async启动的协程,我们通过返回调用await拿到返回值。

package com.example.kotlin01

import kotlinx.coroutines.*
suspend fun main() {
    runBlocking {
        var job = async {
           doSomthingOne()
        }
        println(job.await())

    }

}

suspend fun doSomthingOne(): Int {
    delay(2000)
    return 13
}
13

四.在 ViewModel 中启动协程

项目中经常我们通过使用jetpack中的ViewModel组件来作为View的控制器和Activity绑定起来,这样以来我们知道即使当我们的手机屏幕旋转Activity异常销毁重建的时候我们的Viewmodel也不会销毁。如果我们在ViewModel中启动协程,我们的协程也不会因此而被终止。我们知道协程都是运行在作用域中的,所以就产生了我们的ViewModel.viewModelScope。当viewModelScope被清除,调用onCleared的时候,我们的协程也就取消执行了。比如当一个接口正在请求数据的时候,此时用户关闭了应用,那么我们的请求就应该被取消掉。当一个协程中又启动了一个新的协程,那他们都公用父协程的作用域。viewModelScope的使用实例

package com.example.kotlin01

import androidx.lifecycle.ViewModel
import androidx.lifecycle.viewModelScope
import kotlinx.coroutines.launch

class MyViewModel : ViewModel() {

    fun runForever() {
        // 在 ViewModel 中启动新的协程
        viewModelScope.launch {
            // 当 ViewModel 被清除后,下列代码也会被取消
            while (true){
                println("你好")
            }
        }
    }
}

我们看到我们在协程体中写了一个死循环,但是假如我们的Viewmodel被清除的时候,协程也会被取消。死循环中的代码也会取消执行。

五.任务追踪

有时候我们会遇到一些更复杂的问题,比如在一个协程中处理多个网络请求,我们可以作在一个协程中又启动多个协程去执行任务,但是如果随意启动协程,就会容易引起任务泄漏,调用方可能感知不到启动了新的协程,也就无法追踪。为了解决这个问题,结构化并发保证了supend函数返回时,处理任务也都完成。我们使用coroutineScope或者supervisorScope构造器在supend函数中启动新的协程,确保了supend函数返回的时候,他们所做的任务也都能结束。

suspend fun fetchTwoDocs() {
    coroutineScope {
        launch { fetchDoc(1) }
        async { fetchDoc(2) }
    }
}

以上suspend函数fetchTwoDocs中使用了coroutineScope构造器启动了两个协程,当fetchTwoDocs函数返回的时候,确保了launch和async启动的协程也都已经完成执行。

六.任务追踪(处理一堆任务)

在以上的例子中,假如我们在supend函数中启动了一千个协程,那么是否还能正常追踪呢,结果也是一样的。coroutineScope构造器启动的协程会等待协程中的任务执行完成,supend函数才会返回。并且coroutineScope还会创建一个子scope(作用域),我们知道supend函数肯定是由某个协程内部调用的,运行在某个作用域内,那么suspend函数中通过coroutineScope启动的协程会创建一个子作用域scope ,这个子作用域继承了suspend函数所在协程的作用域(父作用域)。假如这个父作用域是一个viewScope,当用户离开界面,关闭Activity的时候,viewScope被清除,那么所有的子作用域也会被清楚。子作用域内的协程也会被取消执行。这样就不会造成了任务泄漏。

七.协程失败时发出报错信号

val unrelatedScope = MainScope()
// 丢失错误的例子
suspend fun lostError() {
   // 未使用结构化并发的 async
    unrelatedScope.async {
        throw InAsyncNoOneCanHearYou("except")
    }
}

以上我们在supend函数中声明了一个无关联的作用域,它不会按照结构化并发的方式启动新的协程,这段代码的错误将丢失,因为异常通过去获取,而我们并没有调用await 。所以这个错误将永远不会得到处理。
使用结构化并发

suspend fun foundError() {
    coroutineScope {
        async { 
            throw StructuredConcurrencyWill("throw")
        }
    }
}

使用结构化并发就是在supend函数中使用coroutineScope构造器启动协程,coroutineScope将会创建子作用域继承了supend函数所在协程的作用域。如果coroutineScope创建的协程抛出了异常,coroutineScope将会抛给调用方,因为我们使用的是coroutineScope而不是supervisorScope,当抛出异常的时候,所有的子任务就会被取消。

八.理解结构化并发

package com.example.kotlin01

import kotlinx.coroutines.*

suspend fun main() {
    println("${doSum()}")
}

suspend fun doSum(): Int = coroutineScope {
    var result1 = async { doSomthingOne() }
    var result2 = async { doSomthingTwo() }
    result1.await() + result2.await()
}

suspend fun doSomthingOne(): Int {

    delay(2000)
    println("doSomthingOne")
    return 13
}

suspend fun doSomthingTwo(): Int {
    delay(1000)
    println("doSomthingTwo")
    return 15
}

在supend 函数中我们通过coroutineScope 构造器启动了两个协程调用doSomthingOne,doSomthingTwo,因为coroutineScope 启动的协程的作用域都继承了supend函数所在协程的作用域,当doSomthingOne函数出现异常的时候,会抛给父作用域,父作用域下协程的的子协程都会被取消。也就是doSomthingOne和doSomthingTwo都会被取消。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,547评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,399评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,428评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,599评论 1 274
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,612评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,577评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,941评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,603评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,852评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,605评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,693评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,375评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,955评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,936评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,172评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,970评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,414评论 2 342

推荐阅读更多精彩内容