你应该知道的协程中的挂起转化小技巧

Posted 2021-06-26 陈旭金-小金子

前言

相信很多小伙伴都在 android 中使用了协程去处理各种异步的场景. 更有甚者 Flow 也能玩的如鱼得水. 这篇文章呢, 主要普及我们在使用协程的过程中, 如何转化其他代码为挂起函数, 让你的协程用起来更舒适.

另外我们应该知道的是, 协程本质上是一个线程工具.

suspendCoroutine & suspendCancellableCoroutine

当我们开启了一个协程, 如果我们遇到了其他人写的代码或者某些 sdk 中的代码. 它是以 Callback 的形式提供了结果. 那么可能代码如下：

很明显, 你还是使用了回调地狱. 极其丑陋的代码. 并且没法复用.

而使用 suspendCoroutine 可以帮助你解决这个问题. suspendCoroutine 可以转化一个异步或者callback 的代码为一个挂起函数.

suspendCoroutine 会挂起当前协程, 直到内部的 block 使用 cot.resume() 或者 cot.resumeWithException() 方法返回正确或者错误信息.

挂起的协程才会得以继续.

所以 suspendCoroutine 很重要, 可以让你整个的协程的代码摆脱回调地狱.

suspendCancellableCoroutine 顾名思义, 比 suspendCoroutine 多一个取消的回调. 意思就是在协程取消的时候, 可以让你有一个机会取消操作. 例如下面的代码：

async

我们在协程中, 常用 async 做并发, 比如下方的场景. 异步获取两个用户信息. 然后都拿到的之后做后续的处理

这个小例子中, 我们并发去获取了两个用户信息, 然后拼接两个用户的名称. 核心是：

async 会返回一个 Deferred 对象. 我们后续可调用 Deferred.await() 方法, 即可挂起协程. 居家旅行的必备呀.

Reactive

协程官方的提供了对常见的响应式流的转化.

链接是：https://github.com/Kotlin/kotlinx.coroutines/tree/master/reactive

比如提供了对 RxJava 的转化. 使用 await 开头的相关的方法即可

总结

本文中, 介绍了几个协程中常用的方式, 让你的协程中的代码是顺序执行的.

看都看完了, 关注一下我的公众号吧