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

常规写法

• 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同时发送消息，接收消息等任务，利用协程，可以写出简单高效的代码。

?

?