如何使用 kotlin 协程优化这段用 Anko 编写的异步代码

如何解决如何使用 kotlin 协程优化这段用 Anko 编写的异步代码

总而言之，目标是在 10000 毫秒 [10 秒] 之前尝试找到所需的值，在此时间之后将通知用户结果。

我编写了这个小例子来模拟真实项目的行为，其中 10 次调用依次调用阻塞函数 [requestToInternet() 在这种情况下]，随机响应可能需要 1ms 到 1000ms。此阻塞函数可能会导致异常或 0 到 100 [是否需要] 之间的随机值。

为了模拟我编码的异常，如果响应值是 3 的倍数，这些异常会被抛出并模拟所需的值与否，我已经编码为所需的值是数字 1，任何其他值都会然后是一个不需要的值。

执行此示例后的最佳情况是在第一次调用中获得所需的值，延迟为 1 毫秒。

但在最坏的情况下，这 10 次调用将依次进行，在这种情况下将无法获得所需的值，并且花费的总时间等于或大于 10000 毫秒 [10 次调用 * 1000 毫秒]。

所以我想通过 kotlin 协程并行优化这个例子，这样 10 个调用将同时进行而不是顺序进行，在最坏的情况下最多只需要大约 1000 毫秒，提供了可能性在相同的总时间内执行更多的调用。但是由于我对 kotlin 中的协程缺乏经验，我遇到了几个疑问，例如：

1：如果找到所需的值，如何取消其余正在执行的协程并停止执行新的协程。 2：如何使每个协程最后，如果没有得到想要的值，则再次运行，以此类推，连续运行10次。

之前（使用 Anko）： 11000ms = 10 次连续调用 * 每次调用 1000ms [所以只能进行 10 次调用]

之后（使用 Corroutines）： 11000 毫秒 = 10 次并行调用 * 每次调用 1000 毫秒 [因此可以同时进行 100 次调用]

private val tag = "Test"
var requestsCount = 0
var exceptionsCount = 0
var initTime: Long? = null

private fun makeRequest() {
    if(initTime == null){initTime = System.currentTimeMillis()}
    var success = false
    var exceptionRequest: Exception? = null
    doAsync {
        try {
            when(requestToInternet(requestsCount + exceptionsCount)){
                1 -> success = true
            }
        } catch (e: Exception) {
            exceptionRequest = e
        }
        uiThread {
            if(exceptionRequest == null){
                if (requestsCount + exceptionsCount < 9){
                    if (success) {
                        Log.d(tag,"SUCCESS in ${System.currentTimeMillis() - initTime!!} ms")
                    } else {
                        requestsCount++
                        makeRequest()
                    }
                } else {
                    Log.d(tag,"BAD in ${System.currentTimeMillis() - initTime!!} ms")
                }
            } else {
                if(requestsCount + exceptionsCount < 9){
                    exceptionsCount++
                    makeRequest()
                } else{
                    Log.d(tag,"BAD in ${System.currentTimeMillis() - initTime!!} ms")
                }
            }
        }
    }
}

private fun requestToInternet(requestNumber: Int): Int {
    val sleepValue = Random.nextLong(1,10 * 1000)
    Log.d(tag,"Request ${requestNumber+1} will finished in: $sleepValue ms")
    Thread.sleep(sleepValue)
    val resp =  Random.nextInt(0,100)
    Log.d(tag,"The response was $resp")
    return if(resp%3 == 0) {throw Exception()} else {resp}
}

The output in the Logcat