在Android中出现异常后我应该如何重新启动/重试Kotlin协程

Question

我很高兴我将长时间运行的任务切换为 UI 线程 到 协程。与 Android 中的 AsyncTask 或常规线程相比，它提高了性能并将内存使用量减少了 3 倍，并且所有内存泄漏都消失了。

唯一的问题是，在异常在某个时间发生...

之后，我不知道应该如何重新启动长时间运行的操作

阅读大量文章后，我觉得我根本不了解协程中的异常处理。让我知道如何实现所需的行为。

1. 我在片段中有协程范围（将在不久的将来移动到 VM）。

​

    lateinit var initEngineJob: Job
    override val coroutineContext: CoroutineContext
        get() = initEngineJob + Dispatchers.Main

​

1. 使用 async/await 长时间运行的任务。

​

fun initWorkEngineCoroutine()
    {
        launch {

            while(true) {
                val deferred = async(Dispatchers.Default) {
                    getResultsFromEngine()
                }
                    val result = deferred.await()
                    if (result != null) {
                    //UI thread
                        draw!!.showResult(result)
                    }
                }
            }

        }

fun getResultsFromEngine() :Result? {
           result = // some results from native c++ engine, which throws exception at some times
           return result
   }

我不知道我应该把try catch放在哪里。我试图用 try catch 包围 deferred.await()，但我可以不能在 catch 块中调用相同的方法来重试长时间运行的任务。我尝试了 SupervisorJob()，但也没有成功。我仍然无法再次调用 initWorkEngineCoroutine() 并 启动新的协程...

帮助终于解决了这个问题:)

Answer 1

您应该将您的代码视为线性命令式，并在代码中最符合逻辑的地方尝试/捕获。有了这种心态，您的问题可能不是关于协程，而是更多关于 try/catch 重试。你可能会这样做：

fun main() {
    GlobalScope.launch {
        initWorkEngineCoroutine()
    }
}

suspend fun initWorkEngineCoroutine() {
    var failures = 0
    val maxFailures = 3
    while(failures <= maxFailures) {
        try {
             getResultsFromEngine()?.let {
                draw!!.showResult(it)
            }
        } catch (e: Exception) {
            failures++
        }
    }
}

// withContext is like async{}.await() except an exception occuring inside 
// withContext can be caught from inside the coroutine.
// here, we are mapping getResultFromEngine() to a call to withContext and 
// passing withContext the lambda which does the work
suspend fun getResultsFromEngine() :Result? = withContext(Dispatchers.Default) {
    Result()
}

我已经包含了一些逻辑来防止无限循环。它可能不符合您的要求，但您可能会考虑采取某种措施来防止getResultsFromEngine() 立即引发异常并最终导致可能导致意外行为和潜在堆栈溢出的无限循环。