如何让协程超出viewModelScope生命周期，viewModel销毁后仍执行完suspend函数

你的处理思路完全合理，这种「先本地落地、后台异步同步服务端」的实现是优化用户操作体验的常用方案，没有问题。

现有实现问题说明 #

当前的代码将本地数据库插入、服务端请求两个逻辑放在同一个运行在viewModelScope的suspend函数中，当ViewModel随Activity销毁时，viewModelScope会自动取消所有子协程，还没完成的服务端请求自然就被中断了。

你考虑过的GlobalScope确实不推荐使用：它没有结构化并发约束，既无法统一追踪管理运行中的任务，出现异常也没有默认的异常处理机制，很容易出现内存泄露或者任务丢失的问题。

正确解决方案 #

根据你对任务可靠性的要求，可以选两种实现方案：

方案1：仅应用进程存活时保证任务执行，用自定义应用级协程Scope #

适合对同步可靠性要求不高，进程被杀后丢失同步任务也可接受的场景：

1. 首先创建全局绑定应用生命周期的协程Scope，建议作为单例放在Application类中：

class MyApp : Application() {
    // 使用SupervisorJob保证单个子协程失败不会影响其他后台任务
    val appScope = CoroutineScope(SupervisorJob() + Dispatchers.IO + CoroutineExceptionHandler { _, throwable ->
        // 全局统一处理后台任务异常，比如打印日志、上报异常
        throwable.printStackTrace()
    })
}

2. 拆分Repository的逻辑，将本地插入和后台同步解耦：

class ItemRepository(
    private val roomDao: ItemDao, 
    private val apiService: ApiService, 
    private val appScope: CoroutineScope
) {
    // 本地插入逻辑，运行在调用方的协程上，执行完立刻返回结果
    suspend fun addItemLocal(item: Item): Long {
        return roomDao.insert(item)
    }

    // 后台同步逻辑，运行在应用级Scope，不受ViewModel生命周期影响
    fun syncItemToServer(item: Item) {
        appScope.launch {
            val res = apiService.insert(item)
            if (res is Resource.Success) {
                roomDao.update(res.value)
            }
            // 可自行添加请求失败后的重试、本地标记同步状态等逻辑
        }
    }
}

3. 调整ViewModel的调用逻辑：

fun addItem(item: Item) = viewModelScope.launch {
    val id = repository.addItemLocal(item)
    if (id > 0) {
        // 本地插入成功后触发后台同步，不需要等待结果
        repository.syncItemToServer(item.copy(id = id))
    }
    _addItemLiveData.value = id > 0
}

方案2：需要保证任务最终一定执行（哪怕应用进程被系统回收），用Jetpack WorkManager #

如果你的同步任务需要确保最终一定完成，不会因为应用进程被杀就丢失，建议使用WorkManager实现，系统会帮你管理任务生命周期和重试逻辑：

1. 定义同步任务的Worker：

class SyncItemWorker(
    context: Context,
    params: WorkerParameters
) : CoroutineWorker(context, params) {
    override suspend fun doWork(): Result {
        val itemJson = inputData.getString("item_json") ?: return Result.failure()
        val item = Gson().fromJson(itemJson, Item::class.java)
        // 执行同步逻辑
        val res = apiService.insert(item)
        if (res is Resource.Success) {
            roomDao.update(res.value)
            return Result.success()
        }
        // 失败的话自动重试，支持自定义退避策略
        return Result.retry()
    }
}

2. 在本地插入成功后，将任务加入WorkManager队列：

fun syncItemToServer(item: Item, context: Context) {
    val inputData = workDataOf(
        "item_json" to Gson().toJson(item)
    )
    val syncWorkRequest = OneTimeWorkRequestBuilder<SyncItemWorker>()
        .setInputData(inputData)
        // 仅在有网络时执行
        .setConstraints(Constraints.Builder().setRequiredNetworkType(NetworkType.CONNECTED).build())
        // 指数退避重试
        .setBackoffCriteria(BackoffPolicy.EXPONENTIAL, 1, TimeUnit.MINUTES)
        .build()
    WorkManager.getInstance(context).enqueue(syncWorkRequest)
}

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