CoroutineWorker调用返回Flow的API如何规避GlobalScope实现生产级代码？

你不需要使用GlobalScope，CoroutineWorker本身就提供了和Worker生命周期绑定的协程作用域，直接在doWork的挂起函数里处理Flow即可。

当前实现的问题 #

• GlobalScope不受Worker生命周期控制，若Worker被系统取消，异步请求仍会继续运行，造成不必要的资源浪费
• 自行实现的suspendCoroutine未处理错误、空结果、协程取消场景，可能导致协程永久挂起或者内存泄漏
• 调用fetchTokens时未传入locationId参数，属于代码笔误，需要修正

改造后的生产可用代码 #

class CreateOrderFCMWorker(
    context: Context,
    workerParameters: WorkerParameters
) : CoroutineWorker(
    context,
    workerParameters
) {

    override suspend fun doWork(): Result {
        return try {
            // 从Worker的输入参数里获取locationId，原代码漏了传参逻辑
            val locationId = inputData.getString("KEY_LOCATION_ID") ?: return Result.failure()
            val tokens = fetchTokens(locationId)
            if (tokens.isEmpty()) {
                // 无有效token直接返回成功，不需要重试
                return Result.success()
            }
            sendOrderCreatedPush(tokens)
            Result.success()
        } catch (e: Exception) {
            // 遇到异常根据业务需要返回重试或者失败
            if (runAttemptCount < 3) {
                Result.retry()
            } else {
                Result.failure()
            }
        }
    }

    private suspend fun fetchTokens(locationId: String): List<String> {
        // 用first()操作符取Flow的第一个成功结果，自动适配协程生命周期
        return FetchTokensUseCase(locationId)
            .first { it is Result.Success }
            .let { (it as Result.Success).data.map { user -> user.fcmToken } }
    }

    private fun sendOrderCreatedPush(fcmTokens: List<String>) {
        // Code to send FCM push
    }
}

优化说明 #

• 完全移除了GlobalScope和自定义的suspendCoroutine，所有协程操作都和CoroutineWorker的生命周期绑定，Worker被取消时整个请求链会自动取消
• 增加了参数校验、空token处理、全局异常捕获逻辑，避免崩溃和无响应
• 增加了重试次数控制，符合WorkManager的任务调度规范，避免失败后无限重试
• 利用Flow的first()操作符直接获取第一个成功结果，代码更简洁易维护

内容的提问来源于stack exchange，提问作者Chandra Sekhar