java - 为什么我的协程异步只能在runBlocking内部工作？

我试图理解协程，并且似乎比预期的要难理解，也许有人可以为我提供正确的方法。

我希望有一个端点（简单的hello world）将调用暂停的函数。

为此，我做到了：

@GET
@Path("/test")
suspend fun test() : String {
    coroutineScope {
        async {
            doSomething()
        }.await()
    }
    return "Hello"
}

在doSomething（）上我很简单

private fun doSomething(){
   logger.info("request")
}

看起来非常简单和直观，阅读异步https://kotlinlang.org/docs/reference/coroutines/composing-suspending-functions.html需要一个协程范围https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/async.html，因此在我的代码上应该可以工作。

但是当我调用我的方法时，我得到了：

! kotlin.KotlinNullPointerException: null
! at kotlin.coroutines.jvm.internal.ContinuationImpl.getContext(ContinuationImpl.kt:105)
! at kotlinx.coroutines.CoroutineScopeKt.coroutineScope(CoroutineScope.kt:179)

NPE对此

 public override val context: CoroutineContext
        get() = _context!!

将coroutineScope移到runBlocking时有效。知道我缺少什么吗？我该如何进行这项工作？（我试图避免使用GlobalScope.async）

我正在使用dropwizard作为框架

最佳答案

不要将您的控制器功能设为暂停功能。只能从其他暂停函数或协程调用它们。

我不知道您的端点是如何构建的，没有错误，但是由于它是被执行的-内部没有协程上下文-因为我们没有定义任何上下文！这就是为什么您需要上下文的NPE。

顺便说一句，下面的代码将没有异步行为，因为您会立即等待-就像普通的顺序代码一样：

async {
    doSomething()
}.await()

为了快速解决您的问题，请按以下说明进行改写：

@GET
@Path("/test")
fun test() : String {
    GlobalScope.launch { // Starts "fire-and-forget" coroutine
       doSomething() // It will execute this in separate coroutine
    }
    return "Hello" // will be returned almost immediately
}

要了解有关上下文的更多信息，请阅读this。 TLDR：使用Kotlin的构建器和函数创建上下文-如runBlocking

编辑

为了避免使用GlobalScope.功能，我们可以使用runBlocking

@GET
@Path("/test")
fun test() : String = runBlocking {
    val deferredResult1 = async { doSomething() } // Starts immediately in separate coroutine
    val deferredResult2 = async { doSomethingElse() } // Starts immediately in separate coroutine

    logger.print("We got:${deferredResult1 .await()} and ${deferredResult2 .await()}")

    "Hello" // return value - when both async coroutines finished
}

Coroutines

java - 为什么我的协程异步只能在runBlocking内部工作？