Kotlin学习—— 协程Coroutine基础

Posted 2022-11-24 刘某人程序员

其实在Kotlin中，还有很多的概念没有去讲解，在后续的文章再去补充，我们先来一篇协程的基础介绍吧，协程是kotlin for android 中的一个重要概念，我们在加载一段数据的时候，最开始的使用方式是加载数据-等待数据-使用数据，这里是阻塞线程的一个操作，那么势必会出现卡顿等表现，后来我们有了回调，那么这个时候我们的操作步骤就变成加载数据 - 执行其他操作 - 回调数据 - 使用数据，不过回调很多人并不满意，觉得他麻烦和啰嗦，哪怕有Lambda表达式来简化这一层的操作，仍然不尽人意，而协程，就是改变这种方式的一个途径，协程主要是让原来要使用的异步 + 回调的方式简化成看似同步的方案。

要学习协程，可以先去温习一下java中的Thread，然后添加如下依赖：

implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.2'

我们先来看一段官方给出的例子

在这段例子中，我们虽然还不知道是什么意思，但是从注释中可以看到，我们启动了一个协程延迟一秒钟打印World，那么我们来看下日志的打印

可以看到，这段代码本身就是子线程的异步操作，如果我们换成Java的Thread，那么就是如下的代码了：

而打印的结果如下：

本质上，协程就是轻量级的线程。

一.挂起函数
在上面的协程代码中，我们可以看到，我们使用了一个函数delay来延迟一秒，看源码可以可以知道，他是一个suspend修饰的函数，我们称之为挂起函数，需要注意一点的是，挂起函数只能在协程内部使用，并且delay是非阻塞的，而Thread.sleep是阻塞的，而如果在kotlin中我们要想实现阻塞，实际上是有一个函数 runBlocking。

二. runBlocking 函数
我们还是回到最开始官方给出的那段代码中，我们启动了一个协程后，为了防止主进程直接结束了，所以我们通过Thread.sleep(2000L)来阻塞主线程 2 秒钟来保证 JVM 存活，这就是阻塞了线程直到内部的任务全部执行完毕，我们如果使用runBlocking来阻塞

代码差不多，看一下就能理解，我们也可以直接让我们的main函数包装，这也是我们的常用写法

runBlocking的设计之初并不是用来当做普通协程函数来使用的，而是用来桥接普通阻塞代码和挂起风格的非阻塞代码，比如在main函数或者测试案例当中。

三.join
我们通过延迟一段时间来等待程序结束，这很明显是不正确的，也就意味着，我们至始至终都要等待这么多的时候，那么我们为什么不等待这个协程结束就结束程序呢？为什么不呢？其实是可以的，我们来看下如下的这段代码

这段代码就比较自然了，等待这个协程结束就结束了。

四.结构化并发
结构化并发的概念取决于我们使用GlobalScope.launch创建一个协程的时候，实际上是创建了一个顶层的协程，也可以理解为是一个全局的协程，但是这样的话是有一个弊端的，也就是说我们如果挂起的时间过长，或者说创建的协程过多又没有去join，资源占用也会越来越大，那么我们这个时候如果使用结构化并发，就可以很好的解决这个问题了。

我们来看这段代码，我们包装了一个runBlocking，然后launch启动协程，外部协程有一个特点就是等到内部所有的任务执行后就会退出，也就是说，我们先打印Hello,再打印World后就帮助我们退出了。

五.作用域
当然，我们使用runBlocking前面也提到他是阻塞的，实际上我们还有一个非阻塞的作用域，那就是coroutineScope，我们来看下这段代码

这个执行顺序是什么知道吗？

可以看到，先走的是coroutineScope中的100L延迟，紧接着是200L，最后才是500L

六.取消
协程的取消只需要调用一下cancel就好了

七.超时
超时机制有时候对一些任务是非常有必要的，而且超时协程实现起来也简单

这段代码肯定会在三秒后超时，而超时则会出现如下异常

Github地址：
https://github.com/LiuGuiLinAndroid/Kotlin

如果有兴趣的话，可以加入我的Kotlin学习小组

我的公众号，期待你的关注