Kotlin async/await 语法不会阻塞调用者

我想知道 Kotlin 是否可以取代我们当前处理异步代码的方式。现在，我们使用CompletableFutures处理异步代码。下面是这种方法的一个例子：

public void onBalanceRequest(Client client, String name) {
  db.fetchBalance(name)
    .thenAccept(balance -> {
       client.sendMessage("Your money: " + balance);
    });
}

这里重要的一点是onBalanceRequest从主线程调用，不得被阻塞。在内部，db.fetchBalance运行异步操作并在完成时解析 future，因此给定的调用不会阻塞主线程。

在查看了有关协程的 Kotlin 文档后，我希望我们可以做一些类似于 JavaScript 的 async/await 的事情。例如，我们可以在 JavaScript 中执行以下操作：

async function onBalanceRequest(client, name) {
  let balance = await db.fetchBalance(name);
  client.sendMessage("Your money: " + balance);
}

现在，我尝试将现有的 API 连接到 Kotlin 项目：

private fun onBalanceRequest(client: Client) = runBlocking {
    val money = db.fetchBalance(client.name)
    client.sendMessage("Your money: $money")
}

suspend fun fetchBalance(player: String): Double? {
    var result: Double? = null
    GlobalScope.launch {
        originalFetchBalance(player).thenAccept {
            result = it
        }
    }.join()
    return result
}

然而，自从我使用runBlocking，执行onBalanceRequest正在阻塞主线程。所以我问你，我是否可以用 Kotlin 实现类似于 async/await 的东西。

谢谢。

如果你的 JS 函数是async，对应的Kotlin函数应该是suspend:

private suspend fun onBalanceRequest(client: Client) {
    val money = db.fetchBalance(client.name)
    client.sendMessage("Your money: $money")
}

没有必要await，因为 Kotlin 是静态类型的，编译器已经知道哪些函数是suspend并且需要特殊对待（尽管 C# 也是静态类型的，使用async/await明确性模型）。

注意，只能直接调用suspend功能;如果你想“一劳永逸”，请使用launch:

private fun onBalanceRequest(client: Client) = GlobalScope.launch {
    val money = db.fetchBalance(client.name)
    client.sendMessage("Your money: $money")
}

并使用您的CompletableFuture-返回函数，使用kotlinx 协程-jdk8 https://github.com/Kotlin/kotlinx.coroutines/blob/master/integration/kotlinx-coroutines-jdk8/:

// should be suggested by IDE
import kotlinx.coroutines.future.await

suspend fun fetchBalance(player: String) = originalFetchBalance(player).await()