Android 技术分享| 利用 Kotlin 协程，多任务并行，测试 RTM SDK 性能

2022 年 6 月 01 日
本文字数：1131 字
阅读完需：约 4 分钟

创建并登录多个实例并统计登录时间

常规写法

Thread.join
Synchronized
CountDownLatch
RxJava
等等

上面写法都过于麻烦，示例代码就不贴了，直接看用协程改造后的吧。

//原始rtmClient1.login("","123",object :ResultCallback<Void>{      override fun onSuccess(var1: Void?) {           }      override fun onFailure(var1: ErrorInfo?) {          }  })

复制代码

协程写法

首先是登录，这是一个很常见的异步接口回调形式的方法，如果我们要统计每个 Client 从登录到成功的耗时，平均耗时，用常规方法是非常不容易的。于是我们可以利用协程，第一步将其改造为同步的方式。

suspend fun Login() = suspendCoroutine<Long>{    val startTime = System.currentTimeMillis()     rtmClient1.login("","123",object :ResultCallback<Void>{       override fun onSuccess(var1: Void?) {         it.resume(System.currentTimeMillis()-startTime)         }       override fun onFailure(var1: ErrorInfo?) {         it.resume(0)         }        })    }

复制代码

上面我们已经将一个普通的异步回调写成一个 suspend 挂起方法

 lifecycleScope.launch(Dispatchers.IO) {        val result1 = Login() // 第一个登录结果耗时       val result2 = Login() // 第二个登录结果耗时       val result3 = Login() // 第三个登录结果耗时   }     //总耗时302ms

复制代码

我们将其放在协程中执行，可见改造后的方法变得非常的简单且符合我们的直觉也是最简单的流程。利用 suspendCoroutine，我们可以将一个异步任务挂起，再得到结果后返回，这就是协程的一个魅力，以同步的方式写异步代码。

以上任务，还只是串行。所谓的串行，指的就是任务 1 完成再执行任务 2，按顺序执行,如果任务平均耗时 100ms，那执行 n 个就要 n*100ms 才能完成，这不是我们想要的，我们要的是多个任务同时执行，也就是所谓的并行，接着改造。

并行执行

val loginNum = 10
lifecycleScope.launch(Dispatchers.IO) {      (0 until loginNum).map { async { Login() }}.awaitAll()          .apply {                Log.d("result","总耗时：${sum()}")                Log.d("result","平均耗时：${average()}")                Log.d("result","最大耗时：${maxOrNull()}")                Log.d("result","最小耗时：${minOrNull()}")            }        }  //总耗时 100ms

复制代码

这里我们使用 async 和 await 改善代码，整个流程还是非常的简单，而且多个任务同时执行变得更加高效了。

以上就是使用协程写法，测试多个 Client 从登录到成功的案例。按照同样的思路，我们还可以测试多个 Client 同时发送消息，接收消息等任务，利用协程，可以写出简单高效的代码。

发布于: 刚刚阅读数: 5

原文链接:【http://xie.infoq.cn/article/bf373b7905ea03135f882332c】。文章转载请联系作者。

anyRTC开发者

关注

实时交互，万物互联! 2020.08.10 加入

实时交互，万物互联，全球实时互动云服务商领跑者！

发布

暂无评论

创作场景

Android 技术分享| 利用 Kotlin 协程，多任务并行，测试 RTM SDK 性能

创建并登录多个实例并统计登录时间

常规写法

协程写法

并行执行

anyRTC开发者

评论