Android WorkManager使用RxWorker时Result.success()被多次触发问题

常见触发原因及修复方案 #

• 观察者重复注册
  若你在页面生命周期方法（如onCreate/onStart）中注册观察者，未在对应销毁生命周期中移除旧观察者，每次页面重建都会新增一个观察者实例，任务状态变更时所有实例都会收到回调。
  修复方案：使用生命周期感知的observe方法时传入正确的LifecycleOwner；使用observeForever注册的观察者，必须在页面销毁时调用removeObserver主动移除。
• 未过滤任务中间状态
  WorkManager 观察者会接收任务的全量状态变更回调，单个任务从入队到完成会经历ENQUEUED、RUNNING、SUCCEEDED/FAILED/CANCELLED多个状态，每个状态变更都会触发一次回调。
  修复方案：在回调逻辑中先判断workInfo.state.isFinished为true时，再执行后续的结果处理逻辑，过滤中间状态的无效触发。
• 多任务监听的全量回调特性
  如果你通过标签/唯一任务名批量监听所有上传任务，只要其中任意一个任务的状态发生变更，所有任务的全量WorkInfo列表都会回调给观察者，哪怕其他任务状态未发生变化，也会触发一次回调。
  修复方案：本地维护已处理完成的任务ID集合，每次回调时只处理状态变为已完成、且未被处理过的任务条目，避免重复执行业务逻辑。
• 集合操作线程不安全
  你维护的图片列表、任务列表如果在Worker工作线程和主线程同时操作，未加同步锁的情况下会出现移除逻辑执行异常，导致同一个任务的结果被多次处理。
  修复方案：使用线程安全的集合类（如CopyOnWriteArrayList），或者将所有集合操作都切换到主线程执行。

参考实现代码 #

// 注册观察者示例
WorkManager.getInstance(context)
    .getWorkInfosByTagLiveData("upload_image_tag")
    .observe(lifecycleOwner) { workInfoList ->
        // 过滤出所有已完成、且未被处理的任务
        val unprocessedFinishedWork = workInfoList.filter { 
            it.state.isFinished && taskList.contains(it.id) 
        }
        unprocessedFinishedWork.forEach { workInfo ->
            val taskId = workInfo.id
            // 处理上传结果
            if (workInfo.state == WorkInfo.State.SUCCEEDED) {
                val uploadUrl = workInfo.outputData.getString("key_upload_url")
                urlList.add(uploadUrl)
            }
            // 移除本地缓存的对应条目
            taskList.remove(taskId)
            imageList.removeIf { it.associatedTaskId == taskId }
        }
        // 所有任务处理完成后更新UI
        if (taskList.isEmpty()) {
            updateUrlListUI(urlList)
        }
    }

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