Kotlin协同程序`runBlocking`

Question

我正在学习Kotlin协同程序.我读过这runBlocking是桥接同步和异步代码的方法.但是如果runBlocking停止UI线程,性能提升是多少？例如,我需要在Android中查询数据库:

    val result: Int
    get() = runBlocking { queryDatabase().await() }

private fun queryDatabase(): Deferred<Int> {
    return async {
        var cursor: Cursor? = null
        var queryResult: Int = 0
        val sqlQuery = "SELECT COUNT(ID) FROM TABLE..."
        try {
            cursor = getHelper().readableDatabase.query(sqlQuery)
            cursor?.moveToFirst()
            queryResult = cursor?.getInt(0) ?: 0
        } catch (e: Exception) {
            Log.e(TAG, e.localizedMessage)
        } finally {
            cursor?.close()
        }
        return@async queryResult
    }
}

查询数据库会停止主线程,所以它似乎需要与同步代码相同的时间？如果我错过了什么,请纠正我.

Answer 1

runBlocking 是桥接同步和异步代码的方法

我一直碰到这句话,这是非常误导的.

runBlocking是几乎从来没有在生产中使用的工具.它解除了协同程序的异步,非阻塞性​​质.如果你碰巧已经有一些基于协同程序的代码,你想在协同程序没有提供任何价值的上下文中使用它,你可以使用它:阻塞调用.一个典型的用途是JUnit测试,其中测试方法必须坐下并等待协程完成.

您也可以在main方法中使用协同程序时使用它.

滥用runBlocking已经变得如此普遍,以至于Kotlin团队实际上试图添加一个快速失败检查,如果你在UI线程上调用它会立即崩溃你的代码.当他们这样做时,已经打破了这么多代码,他们不得不删除它.

Answer 2

实际上，您runBlocking曾经使用“阻塞”代码来调用挂起函数，否则这些代码将无法在那里调用或换句话说：您使用它来调用suspend协程上下文之外的函数（在您的示例中，传递给async该suspend函数的块就是该函数）。同样（更明显的是，顾名思义，顾名思义），该调用也是阻塞调用。因此，在您的示例中，它好像没有async到位一样被执行。它等待（可中断地阻塞），直到runBlocking-block中的所有内容完成为止。

例如，假设您的库中的函数如下：

suspend fun demo() : Any = TODO()

该方法无法从调用main。对于这种情况，您可以使用runBlocking例如：

fun main(args: Array<String>) {
  // demo() // this alone wouldn't compile... Error:() Kotlin: Suspend function 'demo' should be called only from a coroutine or another suspend function
  // whereas the following works as intended:
  runBlocking {
    demo()
  } // it also waits until demo()-call is finished which wouldn't happen if you use launch
}

关于性能提升：实际上，您的应用程序可能宁愿响应速度更快，而不是性能更高（有时性能也更高，例如，如果您有多个并行操作而不是多个顺序操作）。但是，在您的示例中，分配变量时您已经阻塞了，因此我想说您的应用程序还没有变得更加响应。您可能希望异步调用查询，然后在响应可用后立即更新UI。因此，您基本上只是省略runBlocking而宁愿使用类似的东西launch。您可能也对使用协程进行UI编程指南感兴趣。