如何在返回Deferred的异步函数中延迟

Question

我有下面的科特林协程代码。< code>doWorkAsync是正常(非挂起)函数，它返回< code>Deferred

import kotlinx.coroutines.*

fun main() = runBlocking {
    val result = doWorkAsync("Hello ")
}

fun doWorkAsync(msg: String): Deferred<Int>  = async {
    log("$msg - Working")
    delay(500)
    log("$msg - Work Done")
    return@async 42
}

fun log(msg: String ) {
    println("$msg in ${ Thread.currentThread().name }")
}

我不知道如何在< code>doWorkAsync函数中使用< code>delay。

我正在使用kotlin协程版本kotlinx-coroutines-core： 1.1.1。

Answer 1

您需要指定一个范围：

fun doWorkAsync(msg: String) = GlobalScope.async {
    log("$msg - Working")
    delay(500)
    log("$msg - Work Done")
    return@async 42
}

这样，在您的lambda中，您将有一个＜code＞协程作用域。

注意:由于使用的是表达式体，所以不需要指定返回类型< code>Deferred

使用挂起函数的更灵活的解决方案

但是还有一个更好的方法。我的意思是在这种情况下，很明显函数应该是异步的。但是如果你想要一个可以被称为异步和顺序的函数呢？

这就是暂停功能发挥作用的地方。您可以这样定义函数：

suspend fun doWork(): Int {
    // ...
    delay(500)
    // ...
    return 42
}

然后，您可以在呼叫站点决定如何使用它：

val d: Deferred<Int> = GlobalScope.async { doWork() } // asnyc
val i: Int = runBlocking { doWork() } // sequential