个人博客

http://www.milovetingting.cn

Kotlin的协程

前言

本文是Kotlin协程的一个简单笔记,由于刚接触Kotlin语言,如有理解错误,为避免误导别人,可留言评论,以便本人及时修改,感谢各位大佬!关于协程的进阶文章,可参考其它相关资料!

协程是什么

协程是一种并发设计模式,在 Android 平台上使用它来简化异步执行的代码。

以上是官方文档对协程的简单定义。

下面通过代码来展示协程的具体使用。

假设有以下的需求:有一个耗时的任务要执行,在执行完成后,需要在主线程刷新UI。

不使用协程

在Activity的onCreate中分别调用以下方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

io()

ui()

private fun io() {
thread {
Log.d(TAG, "io method,thread:${Thread.currentThread().name}")
delay(1000)
}
}

private fun ui() {
Log.d(TAG, "ui method,thread:${Thread.currentThread().name}")
}

输出日志:

1
2
2020-09-25 23:10:25.854 5208-5208/com.wangyz.coroutines D/Coroutine: ui method,thread:main
2020-09-25 23:10:25.855 5208-5267/com.wangyz.coroutines D/Coroutine: io method,thread:Thread-2

分别调用io()和ui()方法,两个方法分别运行在子线程和主线程中,但是由于子线程的耗时操作,主线程方法先执行了,这样就没有达到我们想要的顺序执行的效果。

修改代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
io2()

private fun io2() {
thread {
Log.d(TAG, "io method,thread:${Thread.currentThread().name}")
delay(1000)
runOnUiThread {
ui2()
}
}
}

private fun ui2() {
Log.d(TAG, "ui method,thread:${Thread.currentThread().name}")
}

在子线程中通过runOnUiThread将线程切换到主线程中来,输出结果:

1
2
2020-09-25 23:16:44.753 5597-5641/com.wangyz.coroutines D/Coroutine: io method,thread:Thread-2
2020-09-25 23:16:45.756 5597-5597/com.wangyz.coroutines D/Coroutine: ui method,thread:main

再来看下协程的实现方式

使用协程

依赖项信息

如需在Android项目中使用协程,需要将以下依赖项添加到应用的 build.gradle 文件中:

1
2
3
dependencies {
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.9'
}

协程的使用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
GlobalScope.launch(Dispatchers.Main) {
io3()
ui3()
}

private suspend fun io3(){
withContext(Dispatchers.IO){
Log.d(TAG, "io method,thread:${Thread.currentThread().name}")
delay(1000)
}
}

private fun ui3() {
Log.d(TAG, "ui method,thread:${Thread.currentThread().name}")
}

通过launch方法开启一个协程,通过设置Dispatchers.Main运行在Main线程中,在io3中,通过withContext开启一个线程,并通过设置Dispatchers.IO运行在IO线程。suspend是一个标记,表示这个方法内部会有挂起的操作,它并不会导致线程切换,真正切换线程是通过withContext来切换的。

输出结果:

1
2
2020-09-25 23:28:19.965 6017-6062/com.wangyz.coroutines D/Coroutine: io method,thread:DefaultDispatcher-worker-1
2020-09-25 23:28:20.969 6017-6017/com.wangyz.coroutines D/Coroutine: ui method,thread:main

假设我们需要同时请求多个接口,并在这些接口全部返回数据后再统一更新界面,下面用协程来模拟实现这个需求。

请求多个异步接口

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
GlobalScope.launch(Dispatchers.Main) {
val res1 = async { io4() }
val res2 = async { io5() }
val data = res1.await() + res2.await()
ui4(data)
}

private suspend fun io4() = withContext(
Dispatchers.IO
) {
delay(2000)
Log.d(TAG, "io method,thread:${Thread.currentThread().name}")
1
}

private suspend fun io5() = withContext(
Dispatchers.IO
) {
delay(3000)
Log.d(TAG, "io method,thread:${Thread.currentThread().name}")
2
}

private fun ui4(value: Int) {
Log.d(TAG, "ui method,thread:${Thread.currentThread().name},result:${value}")
}

输出结果:

1
2
3
2020-09-25 23:51:28.161 6495-6536/com.wangyz.coroutines D/Coroutine: io method,thread:DefaultDispatcher-worker-1
2020-09-25 23:51:29.389 6495-6537/com.wangyz.coroutines D/Coroutine: io method,thread:DefaultDispatcher-worker-2
2020-09-25 23:51:29.390 6495-6495/com.wangyz.coroutines D/Coroutine: ui method,thread:main,result:3

方法io4执行2秒,方法io5执行3秒,在io5执行完成后,将他们的结果相加再通过ui4更新到UI上。

参考

https://developer.android.google.cn/kotlin/coroutines