Android Worker执行doWork时陷入无限循环 重复发起/test接口请求

问题根因分析 #

从你提供的代码来看，有几个典型的错误用法会导致接口调用频次远超预期，甚至看起来像无限循环：

• 唯一周期任务标识为空，且每次App启动重复执行初始化逻辑
  enqueueUniquePeriodicWork的第一个参数是任务的全局唯一标识，你传入了空字符串本身就不符合API设计预期。同时initTestWorker()在MyApp.onCreate()中执行，每次App冷启动、进程被系统杀死后重启都会触发该方法，极易重复创建多个功能相同的周期任务，多个任务各自按3小时间隔执行叠加后，就会出现接口调用频次异常的情况。
• 异步操作未等待完成就返回执行结果
  TestWorker继承的是同步执行的Worker类，你在doWork()中发起RxJava异步请求后直接返回Result.success()，WorkManager会立即标记任务执行完成，但RxJava的异步订阅还在运行。如果订阅回调中存在重试逻辑、或者Worker销毁后订阅没有及时释放，都会触发额外的接口调用。
• 网络约束触发异常
  你设置了NetworkType.CONNECTED的运行约束，当用户网络状态频繁切换（比如信号不稳定区域反复断连重连）时，WorkManager会频繁尝试触发满足约束的任务，叠加重试逻辑后也会出现多次调用的情况。

修复方案 #

1. 给周期任务设置固定的唯一标识，确保全局仅存在一个该类型的任务：

companion object {
    const val REPEAT_INTERVAL_IN_HOURS = 3L
    // 新增全局唯一的任务名称
    const val UNIQUE_TEST_WORK_NAME = "com.your.package.TestWorker"
}

// 修改初始化时的入队代码
WorkManager
    .getInstance(this)
    .enqueueUniquePeriodicWork(
        TestWorker.UNIQUE_TEST_WORK_NAME, 
        ExistingPeriodicWorkPolicy.KEEP, 
        workerRequest
    )

2. 改用支持异步的Worker类型，等待接口请求完成后再返回执行结果，同时做好资源释放：

class TestWorker(
    context: Context,
    workerParams: WorkerParameters
) : ListenableWorker(context, workerParams) {

    private var requestDisposable: Disposable? = null

    override fun startWork(): ListenableFuture<Result> {
        val resultFuture = SettableFuture.create<Result>()
        requestDisposable = XUseCase.execute()
            .backgroundToMainThread() 
            .subscribe(
                { ->
                    // 请求成功后再返回成功结果
                    resultFuture.set(Result.success())
                },
                { error ->
                    // 按需设置失败/重试逻辑
                    resultFuture.set(Result.retry())
                }
            )
        return resultFuture
    }

    override fun onStopped() {
        super.onStopped()
        // Worker停止时释放订阅，避免内存泄漏和额外调用
        requestDisposable?.dispose()
    }
}

3. 线上可增加任务状态查询逻辑，排查是否存在多个重复任务：

// 调试时打印当前任务状态
WorkManager.getInstance(context)
    .getWorkInfosForUniqueWorkLiveData(TestWorker.UNIQUE_TEST_WORK_NAME)
    .observe(lifecycleOwner) { workInfos ->
        Log.d("TestWorkerDebug", "存活任务数量：${workInfos.size}")
        workInfos.forEach { info ->
            Log.d("TestWorkerDebug", "任务ID：${info.id}，状态：${info.state}")
        }
    }

额外优化建议 #

• 给/test接口增加幂等处理，避免重复调用导致的业务异常
• 如果对调用时间精度要求不高，可以给周期任务设置弹性运行间隔，减少系统集中唤醒带来的调用频次叠加

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