kotlin - Kotlin协程:暂停后续访问 token 续订请求

Question

我有一个可以通过后端进行身份验证的应用程序，该应用程序可以接收长期的刷新 token 和短期的访问 token 。我们使用访问 token 来授权请求​​，并且每次过期时，我们都会触发 token 更新(使用刷新 token )，然后使用新 token 重试API调用。很标准的东西。

可以同时(异步)触发多个网络调用，但是如果它们都具有无效的访问 token ，我们只希望第一个通过并刷新 token ，而后续的调用则等待初始的调用完成才能继续。目前，我们已经实现了以下方式:

private var renewingDeferred: Deferred<Unit>? = null

suspend fun renewTokens() {
    coroutineScope {
        if (renewingDeferred == null) {
            renewingDeferred = async {
                try {
                    tokens = tokensApi.renew().await()
                } finally {
                    renewingDeferred = null
                }
            }
        } else {
            renewingDeferred?.await()
        }
    }
}

这个想法是，每个具有无效访问 token 的请求都将调用 renewTokens()，然后使用新的 header 重试。 renewTokens()的调用者不必关心它实际上是续签还是只是等待先前的续签完成，只要它知道一旦函数返回就续签了 token (不再挂起)。据我所知，它可以正常工作，但是我不确定代码，特别是 renewingDeferred = null块的 finally部分。

例如，说请求A开始更新，请求B被触发并开始等待请求A，然后A完成，将 renewingDeferred设置为 null，但是将该值设置为 null会以某种方式影响请求B的等待状态吗？

另外，如果在调用API时抛出异常怎么办？我没有 catch块，有点假设 await()在延迟抛出时会以某种方式重新抛出，但是协程中的异常处理并不是我真正的强项。希望就此获得一些建议。

此外，如果有人对应如何以其他方式解决此问题有一个一般的想法，欢迎提出所有建议!

Answer 1

您可以使用Mutex解决此问题。
创建一个协程锁定属性，并在调用renewToken时锁定Mutex，直到 token 更新为止。