PeriodicWorkRequest监听失效：Worker执行成功但日志未打印

核心问题：周期性WorkRequest不会进入SUCCEEDED状态 #

PeriodicWorkRequest的状态流转逻辑和一次性任务完全不同：

• 一次性任务（OneTimeWorkRequest）：ENQUEUED → RUNNING → SUCCEEDED/FAILED/CANCELLED
• 周期性任务：ENQUEUED → RUNNING → ENQUEUED（执行完成后会立刻回到等待队列，准备下一次执行）

所以你监听WorkInfo.State.SUCCEEDED永远不会触发，这就是日志没打印的根本原因。

解决方案 #

1. 监听RUNNING状态（确认任务启动） #

如果只是需要确认Worker开始执行，修改监听逻辑为监听RUNNING状态：

workManager.getWorkInfoByIdLiveData(notificationWorker.id).observeForever { workInfo ->
    when(workInfo.state) {
        WorkInfo.State.RUNNING -> {
            Log.e("workinfo", "任务正在执行")
        }
        WorkInfo.State.ENQUEUED -> {
            Log.e("workinfo", "任务已进入等待队列，等待下一次执行")
        }
        // 可按需监听其他状态
        else -> {}
    }
}

2. 在Worker内部传递执行完成信号（感知每次执行结束） #

如果需要知道每次Worker执行完成，可以通过以下两种方式实现：

方式一：使用WorkInfo的OutputData

在NotificationWorker中设置输出数据标记执行完成：

class NotificationWorker(context: Context, params: WorkerParameters) : Worker(context, params) {
    override fun doWork(): Result {
        // 执行通知创建逻辑
        createNotification()
        
        // 设置输出数据
        val outputData = Data.Builder()
            .putBoolean("EXECUTED_SUCCESS", true)
            .build()
        return Result.success(outputData)
    }
}

在ViewModel中监听输出数据变化：

workManager.getWorkInfoByIdLiveData(notificationWorker.id).observeForever { workInfo ->
    if (workInfo.state == WorkInfo.State.RUNNING && workInfo.outputData.getBoolean("EXECUTED_SUCCESS", false)) {
        Log.e("workinfo", "本次任务执行成功")
    }
}

方式二：使用全局LiveData传递状态

在ViewModel中定义LiveData，Worker执行完成后发送事件：

// TasksViewModel.kt
val workerExecutionState = MutableLiveData<Boolean>()

// NotificationWorker.kt
override fun doWork(): Result {
    // 执行通知逻辑
    val viewModel = ViewModelProvider(
        ApplicationProvider.getApplicationContext<Context>() as ViewModelStoreOwner
    )[TasksViewModel::class.java]
    viewModel.workerExecutionState.postValue(true)
    return Result.success()
}

// 在ViewModel中监听状态
workerExecutionState.observeForever { success ->
    if (success) {
        Log.e("workinfo", "本次任务执行成功")
        // 重置状态避免重复触发
        workerExecutionState.postValue(false)
    }
}

3. 改用OneTimeWorkRequest（非周期性场景） #

如果你的需求并不是真正需要周期性执行，只是延迟执行一次，直接替换为OneTimeWorkRequest，此时就能正常监听SUCCEEDED状态：

val notificationWorker = OneTimeWorkRequestBuilder<NotificationWorker>()
    .setInitialDelay(10, TimeUnit.SECONDS)
    .build()

workManager.enqueueUniqueWork("TAG", ExistingWorkPolicy.KEEP, notificationWorker)

workManager.getWorkInfoByIdLiveData(notificationWorker.id).observeForever {
    if(it.state == WorkInfo.State.SUCCEEDED){
        Log.e("workinfo", "succeeded")
    }
}

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