Kotlin 协程看这一篇就够了-阿里云开发者社区

Kotlin 协程看这一篇就够了

2022-03-03 2220

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Kotlin 协程看这一篇就够了

前言

Kotlin协程是什么，如何使用？如何结合Retrofit使用？Kotlin协程的优势在哪里？相信看完这一篇你一定有所收获！

协程基本使用

若使用协程，首先我们得引入协程相关的开发包

implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.7-mpp-dev-11'
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.7-mpp-dev-11'

上面一个是java环境的，下面一个是android环境下的，这里我们都引入进来。

协程最简单的使用，我们可以使用GlobalScope.launch去开启一个协程代码如下所示：

GlobalScope.launch {
    Log.d(TAG, Thread.currentThread().name)
}

运行结果如下所示：

说明这段代码是运行在一个子线程中的，当然我们可以再launch中传递参数，让他运行在主线程中：

GlobalScope.launch(Dispatchers.Main) {
    Log.d(TAG, Thread.currentThread().name)
}

这样里面的这段代码就运行在主线程中了，由此可见协程是什么？简单的说就是协程可以让我们开启一个线程，是一个线程框架。当然实际项目中，开启协程我们不会使用上面的方法。别急，我们要循序渐进~

协程和线程相比有什么优势

协程和线程相比的优势，我们直接用一个例子来说明，比如当前我们要去请求网络，拿到数据后将数据显示出来，这里我们模拟两个方法，分别为网络请求获取数据和将数据显示在UI上，我们定义方法如下:

/**
 * 从服务器取信息
 */
private fun getMessageFromNetwork(): String {
    for (i in 0..1000000) {
        //这里模拟一个耗时操作
    }
    var name = "Huanglinqing"
    return name
}
/**
 * 显示信息
 * @message :信息
 */
private fun showMessage(message: String) {
    tvName.text = message
}

由于getMessage是一个耗时操作，所以我们将他放在子线程中，而在Android中 UI更新操作不能放在子线程中，所以我们必须将showMessage方法放在UI线程中，在之前我们实现这种需求只能自己去执行切线程的代码，代码如下所示

/**
 * 从服务器取信息
 */
private fun getMessageFromNetwork() {
    for (i in 0..1000000) {
        //这里模拟一个耗时操作
    }
    var name = "Huanglinqing"
    runOnUiThread {
        showMessage(name)
    }
}

在onCreate中执行如下代码：

Thread {
    getMessageFromNetwork()
}.start()

这样呢看起来还好，但是如果现在需求改为：请求第一个后显示出来，再请求第二个显示出来呢，代码就是这个样子

private fun getMessageFromNetwork() {
    for (i in 0..1000000) {
        //这里模拟一个耗时操作
    }
    var name = "Huanglinqing"
    runOnUiThread {
        showMessage(name)
        Thread{
            getMessageFromNetwork1()
            runOnUiThread{
            }
        }.start()
    }
}

依次类推，我们可以想到，如果请求很多的话，第一代码结构会很难看，第二写着写着就很乱了，那么协程就可以很好的解决这个问题，下面我们来看使用协程的方式怎么写.

首先，对于一个耗时的操作，我们需要将他切换到后台线程执行，withContext函数可以构建一个协程作用域，他必须在挂起函数或者协程中执行，suspend关键字是kotlin为我们提供的用于标记挂起函数的关键字。我们修改getMessageFromNetwork方法如下:

/**
 * 从服务器取信息
 */
private suspend fun getMessageFromNetwork(): String {
    var name = ""
    withContext(Dispatchers.IO) {
        for (i in 0..1000000) {
            //这里模拟一个耗时操作
        }
        name = "Huanglinqing1111"
    }
    return name
}

在onCreate中协程中直接这样写：

GlobalScope.launch(Dispatchers.Main) {
    var name = getMessageFromNetwork()
    showMessage(name)
}

运行结果如下所示：

如果我们有多个请求呢，那就再多加几个

GlobalScope.launch(Dispatchers.Main) {
    var name = getMessageFromNetwork()
    showMessage(name)
    var name1 = getMessageFromNetwork()
    showMessage(name1)
    var name2 = getMessageFromNetwork()
    showMessage(name2)
}

这样getMessageFromNetwork在后台执行，showMessage在前台执行，由此看来。

协程比线程的优势在什么地方？

1、协程可以帮我们自动切线程

2、摆脱了链式回调的问题

Retrofit 如何使用协程

从Retrofit2.6.0开始，retrofit就自动支持协程了，这里我们从「聚合数据」上找到一个开放api

我们先来看之前我们怎么使用的，首先在Apiservice中定义一个接口如下：

@GET("https://wanandroid.com/article/listproject/0/json")
fun queryData(): Call<BaseReqData<DataReqBean>>

在activity中添加如下代码：

var retrofit = Retrofit.Builder()
    .baseUrl("http://v.juhe.cn/")
    .addConverterFactory(GsonConverterFactory.create())
    .build()
val apiService = retrofit.create(ApiService::class.java)
tvName.setOnClickListener {
    apiService.queryData("top","04ea095cbea56775e2d1669713f34cc2")
        .enqueue(object :Callback<BaseReqData<NewBean>>{
            override fun onFailure(call: Call<BaseReqData<NewBean>>, t: Throwable) {
                tvName.text = t.toString()
                Log.d("网络请求错误", t.toString())
            }
            override fun onResponse(
                call: Call<BaseReqData<NewBean>>,
                response: Response<BaseReqData<NewBean>>
            ) {
                tvName.text = response.code().toString()
            }
        })
}

这里我们将返回结果的状态码显示在view上，运行结果如图所示：

上面代码看起来没有什么问题，如果我们用到了mvp模式什么的，便于职责单一，还要单独放一个类中，这样就需要添加回调才能获取返回结果。

那么协程中怎么使用呢?

首先我们在ApiService中新增一个函数，声明为挂起函数，类型不需要添加Call

@GET("toutiao/index")
suspend fun queryDataKotlin(@Query("type") type: String?, @Query("key") key: String?): BaseReqData<NewBean>

在onCreate中代码如下所示：

GlobalScope.launch(Dispatchers.Main) {
    try {
        var result = apiService.queryDataKotlin("top", "04ea095cbea56775e2d1669713f34cc2")
        tvName.text = result.toString()
    }catch (e:Exception){
        tvName.text = e.toString()
    }
}

没错就是这么简单，没有什么回调，因为queryDataKotlin是一个挂起函数，当运行到挂起函数的时候，协程会处于等待状态，等返回结果后，主动切回主线程，执行下面的方法。

而try catch的作用，就等同于上面onFailure的回调，这个时候你可能会说了，我去！还要写try catch ，好low的感觉，别忘了，协程的另一个优势就是可以减少回调，如果仍然有成功方法或者失败方法那还是走了回调的逻辑！

协程提升效率

协程可以提升什么效率，假设，我们现在有两个接口请求，需要等到两个接口都请求完毕的时候显示出结果，如果在之前会怎么样，先请求接口1 接口1有结果后再请求结果2，而协程可以做到，接口1和接口2同时请求，等请求结束后将结果合并显示过来，这里我们请求统一接口来模拟请求两个不同的接口

GlobalScope.launch(Dispatchers.Main) {
    try {
        var result1 =
            async { apiService.queryDataKotlin("top", "04ea095cbea56775e2d1669713f34cc2") }
        var result2 =
            async { apiService.queryDataKotlin("top", "04ea095cbea56775e2d1669713f34cc2") }
        tvName.text = result1.await().toString() + "\n==\n" + result2.await().toString()+"接口2"
    } catch (e: Exception) {
        tvName.text = e.toString()
    }
}

运行结果如下所示：

这样，本来要分步做的两件事情可以同时做了，当然可以提高效率了，async函数必须在协程作用域中调用，会创建一个新的子协程，并返回一个Deferred对象，调用这个对象的await方法就可以获取执行结果。

在线上项目中如何使用协程

创建协程的方法有很多，有我们上面说的GlobalScope.launch方法，还有runBlocking方法

GlobalScope.launch 创建的是顶级协程，runBlocking创建的协程在协程作用域的代码没有执行完毕前会一直阻塞线程，所以上面。两个方法都不建议使用。

coroutineScope函数是一个挂起函数，它会继承外部的协程作用域并创建一个子协程,只能在协程作用域或者挂起函数中调用

launch函数必须在协程的作用域中才能调用。

说了这么多在项目中我们改如何创建协程呢？

我们可以直接创建一个CoroutineScope对象，如下所示：

var coroutineScope = CoroutineScope(Dispatchers.Main)

coroutineScope.launch {
}

这样我们就创建了一个协程，可以按照上面的方法使用了

如果在页面打开的时候，我们在协程中进行网络请求，当页面销毁的时候我们也要将协程任务取消以免造成不必要的问题

如何取消协程任务

coroutineScope 直接调用cancle方法即可，如果我们使用的是GlobalScope.launch方法，它会返回一个job对象我们使用job.cancle即可取消协程任务。

最后的最后，协程的强大远远不止上述

在项目中使用Jetpack 对kotlin的扩展,可以更加便捷的创建和使用协程.

如下：

lifecycleScope.launch { 
}

或

viewModelScope.launch {
}

可那又是另外一个故事了~

Android JetPack系列文章已完结

Kotlin 协程看这一篇就够了

前言

协程基本使用

协程和线程相比有什么优势

Retrofit 如何使用协程

协程提升效率

在线上项目中如何使用协程

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Kotlin 协程 看这一篇就够了

前言

协程基本使用

协程和线程相比 有什么优势

Retrofit 如何使用协程

协程提升效率

在线上项目中如何使用协程

热门文章

最新文章

相关课程

相关电子书

相关实验场景

Kotlin 协程看这一篇就够了

协程和线程相比有什么优势