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

大佬教程收集整理的这篇文章主要介绍了如何使用 kotlin 协程优化这段用 Anko 编写的异步代码，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

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

开发过程中遇到如何使用 kotlin 协程优化这段用 Anko 编写的异步代码的问题如何解决？下面主要结合日常开发的经验，给出你关于如何使用 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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）