我对协程中的异常处理方式感到很困惑。我希望能够有一系列的挂起函数,像同步代码一样在它们之间传递异常。因此,如果例如 Retrofit 抛出了 IOException 异常,我可以在挂起函数链的开头处处理该异常,比如在 presenter 中向用户展示错误信息。
我制作了一个简单的示例来尝试协程,但是如果我取消注释
我制作了一个简单的示例来尝试协程,但是如果我取消注释
throw Exception
调用中的任何一个,那么异常后面的代码就无法运行,但是异常并不会导致应用程序崩溃。package com.example.myapplication
import android.os.Bundle
import android.support.v7.app.AppCompatActivity
import android.widget.Button
import android.widget.TextView
import kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.launch
class MainActivity : AppCompatActivity() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
val text = findViewById<TextView>(R.id.thing_text)
val button = findViewById<Button>(R.id.thing_button)
var count = 0
button.setOnClickListener {
launch {
count++
// throw Exception("Boom")
val string = delayedStringOfInt(count)
runOnUiThread { text.text = string }
}
}
}
suspend fun delayedStringOfInt(int: Int): String {
delay(1000)
// throw Exception("Boom")
return int.toString()
}
}
我已尝试使用 async
和 CoroutineExceptionHandler
。
async
和await
,但是它会抱怨Suspend function await should only be called from a coroutine or another suspend function.
。然而,将所有内容包装在runBlocking
中可以正常运行代码的异步执行。runBlocking
是一个令人困惑的名称,因为我期望它会阻塞直到内部的协程完成。在我的情况下,如果您快速点击按钮,我希望每秒钟都会得到递增的数字,而不是快速递增。我会将其标记为答案,但是将我的修复代码放在另一个答案中。 - TTransmitrunBlocking
正在阻塞UI线程,这不是我想要的。我将尝试使用回调函数。 - TTransmitkotlinx Continuation
目前只会给我带来丑陋的回调地狱。 - TTransmit