如何用suspend coroutine封装基于回调的登录服务异步逻辑？

你的这个实现思路其实已经踩中了回调转协程的核心点——用suspendCoroutine把传统的回调API包装成挂起函数，完美实现了“让login()直到回调触发才完成”的需求！不过我可以给你几个优化建议，让这段代码更健壮、更符合协程的最佳实践：

1. 务必处理失败回调的协程恢复 #

你当前的代码里，onLoginFailure回调没有调用continuation.resume，这会导致登录失败时协程永远挂起，进而引发线程泄漏或者死锁问题。一定要补上失败场景的恢复逻辑，比如用带错误信息的Outcome枚举：

fun login(): Outcome = runBlocking {
    suspendCoroutine<Outcome> { continuation ->
        loginService.login(
            onLoginSuccess = {
                // 执行相关操作
                continuation.resume(Outcome.SUCCESS)
            },
            onLoginFailure = { error ->
                // 处理失败逻辑
                continuation.resume(Outcome.FAILURE(error))
            }
        )
    }
}

2. 优先将login()设计为挂起函数 #

你现在用runBlocking把挂起逻辑包装成了普通函数，但如果这个login()是给其他协程场景调用的，更推荐直接把它定义为挂起函数，避免不必要的线程阻塞：

suspend fun login(): Outcome = suspendCoroutine { continuation ->
    loginService.login(
        onLoginSuccess = {
            continuation.resume(Outcome.SUCCESS)
        },
        onLoginFailure = { error ->
            continuation.resume(Outcome.FAILURE(error))
        }
    )
}

如果需要在非协程环境调用这个函数，再在调用方外层套runBlocking即可，这样更灵活，也符合协程非阻塞的设计理念。

3. 保证异常安全 #

如果回调内的业务逻辑有可能抛出异常，建议用resumeWithException来传递异常，而不是默默吞掉，这样调用方可以用标准的try-catch来处理异常：

suspend fun login(): Outcome = suspendCoroutine { continuation ->
    loginService.login(
        onLoginSuccess = {
            try {
                // 执行可能抛出异常的操作
                continuation.resume(Outcome.SUCCESS)
            } catch (e: Exception) {
                continuation.resumeWithException(e)
            }
        },
        onLoginFailure = { error ->
            continuation.resume(Outcome.FAILURE(error))
        }
    )
}

4. 防止重复回调导致的异常 #

如果你的登录服务存在触发多次回调的可能性（比如某些边缘场景下重复调用成功/失败回调），一定要确保Continuation只被调用一次——因为协程的resume方法只能执行一次，多次调用会直接抛出异常。可以加个标志位来控制：

suspend fun login(): Outcome = suspendCoroutine { continuation ->
    var isResumed = false
    loginService.login(
        onLoginSuccess = {
            if (!isResumed) {
                isResumed = true
                continuation.resume(Outcome.SUCCESS)
            }
        },
        onLoginFailure = { error ->
            if (!isResumed) {
                isResumed = true
                continuation.resume(Outcome.FAILURE(error))
            }
        }
    )
}

内容的提问来源于stack exchange，提问作者Derek Fredrickson