第3章 协程在埋点上报中的典型用法：async、await、withContext、launch

埋点上报链路的核心挑战在于：并发采集（多个埋点同时等待网络）、异步回调（网络请求不可阻塞主线程）、上下文切换（从 UI 线程切换到 IO 线程再切回）。Kotlin 协程提供的四种构造块 —— launch、async、await、withContext —— 恰好覆盖了这些场景。本章将逐一剖析它们在上报链路中的真实用法，并给出可复用代码片段。

3.1 四类协程构造块的作用域对比

3.2 launch：发后即忘的埋点采集

最基础的埋点上报场景：用户触发某个事件后，只需将埋点数据异步发送至服务器，不关心返回结果。此时 launch 是最简洁的写法。

// 在 ViewModel 或全局协程作用域中
fun reportEvent(eventName: String, params: Map<String, String>) {
    viewModelScope.launch {
        try {
            val result = apiService.sendEvent(eventName, params)
            // 可选：记录成功日志
        } catch (e: Exception) {
            // 重试或落本地缓存
            localCache.savePendingEvent(eventName, params)
        }
    }
}

• 优势：无需管理回调，失败处理集中在 try/catch 内。
• 注意事项：不可在 launch 内部直接修改 UI 状态而不切换调度器（除非已指定 Dispatchers.Main）。

3.3 async/await：并发聚合埋点数据

当一次上报需要合并多个埋点来源时（例如同时获取设备信息、用户画像、页面停留时长），async 可并行发起请求，通过 await 等待所有结果就绪后再组装。

data class ReportPayload(
    val deviceInfo: DeviceInfo,
    val userProfile: UserProfile,
    val pageDuration: Long
)

suspend fun collectReportPayload(): ReportPayload = coroutineScope {
    val deviceDeferred = async(Dispatchers.IO) { deviceInfoProvider.get() }
    val profileDeferred = async(Dispatchers.IO) { userProfileProvider.get() }
    val durationDeferred = async(Dispatchers.Main) { pageTracker.getDuration() }

    // 并发等待三个结果
    ReportPayload(
        deviceInfo = deviceDeferred.await(),
        userProfile = profileDeferred.await(),
        pageDuration = durationDeferred.await()
    )
}

• 关键点：async 默认继承父协程的调度器，这里显式指定 Dispatchers.IO 避免主线程阻塞。
• 异常处理：任何一个 async 抛出异常，await 会重新抛出，建议使用 try/catch 包裹整个 coroutineScope。

3.4 withContext：线程切换与上下文保留

埋点上报告警需要经过加密、序列化等 CPU 密集型操作，之后回到主线程组装 UI 回调。使用 withContext 显式切换调度器并保持协程上下文。

suspend fun prepareAndReport(rawData: String): Boolean = withContext(Dispatchers.IO) {
    // 1. 加密（同步阻塞）
    val encrypted = encrypt(rawData)
    // 2. 压缩（同步阻塞）
    val compressed = compress(encrypted)
    // 3. 发送（仍要挂起，但 using Retrofit suspend 函数自动在 IO 线程）
    apiService.upload(compressed)
}

3.5 四种构造块在埋点上报中的协作流程

下图为一次典型埋点上报的协程调度流程：

3.6 常见错误与避坑指南

3.7 性能优化：避免不必要的线程切换

• 合并 IO 操作：多个 async(Dispatchers.IO) 可以共用同一个 IO 线程池，但不要为每个埋点字段新建一个 async（建议按数据源分组）。
• 复用协程作用域：在 Application 级别定义与 Activity 无关的埋点上报作用域，避免 ViewModelScope 被销毁时任务丢失。
• 使用 newSingleThreadContext 或 newFixedThreadPoolContext：对于极端高频的埋点（如每秒上报），可自定义调度器减少线程创建开销。