每秒调用API并收集Kotlin Flow是否正确？是否会新增收集器？

核心结论 #

1. 不会每秒新增Flow收集器：你的getOrderInfoUseCase返回的是单次发射的冷Flow（请求完成后Flow就会结束），每次collect会等到请求完成后才进入下一次while循环迭代，同一时间只会有一个Flow收集器在运行。
2. 当前实现不满足“每秒发送请求”的需求：当前逻辑是上一次请求完成后，延迟1秒再发起下一次请求。如果API请求耗时（比如0.5秒），两次请求的间隔会变成1.5秒，而非严格的1秒。
3. 不存在无限Flow的问题：你的getOrderInfoUseCase中的Flow只会发射一次结果就结束，collect不会无限挂起，while循环会持续执行直到isGettingOrders变为false。

潜在问题与改进方案 #

问题点

• 请求间隔依赖上一次请求的耗时，无法保证严格的每秒一次触发
• 如果API请求超时或阻塞，会导致后续请求全部延迟

改进方案1：严格每秒触发一次请求（自动取消未完成的旧请求）

适合只需要最新请求结果的场景，用flatMapLatest自动取消未完成的前序请求：

private fun fetchOrder() {
    serviceScope.launch {
        kotlinx.coroutines.flow.interval(1000)
            .takeWhile { isGettingOrders }
            .flatMapLatest {
                getOrderInfoUseCase(outletId)
            }
            .flowOn(Dispatchers.IO)
            .collect { result ->
                result.onSuccess {
                    if (currentOrderId != it.orderId) {
                        currentOrderId = it.orderId
                        _order.emit(it)
                    }
                }.onFailure {
                    printLog("${it.message}")
                }
            }
    }
}

改进方案2：保证请求串行执行（上一次完成后间隔1秒再发下一次）

适合需要所有请求都执行完成的场景，保留原逻辑但优化写法：

private fun fetchOrder() {
    serviceScope.launch(Dispatchers.IO) {
        while (isGettingOrders) {
            runCatching {
                getOrderInfoUseCase(outletId).first()
            }.getOrElse {
                Result.failure(it)
            }.let { result ->
                // 统一处理结果
                result.onSuccess {
                    if (currentOrderId != it.orderId) {
                        currentOrderId = it.orderId
                        _order.emit(it)
                    }
                }.onFailure {
                    printLog("${it.message}")
                }
            }
            delay(1000)
        }
    }
}

这里用first()直接获取Flow的唯一结果，避免显式collect，代码更简洁。

额外注意事项 #

• currentOrderId如果在多协程环境下访问，建议改用AtomicReference或MutableStateFlow保证线程安全
• 如果_order是MutableSharedFlow/MutableStateFlow，emit操作本身是线程安全的，但建议在同一协程上下文内处理，避免跨线程发射问题

内容的提问来源于stack exchange，提问作者Eugene Myname