android - WorkManager alpha10 ListenableFuture 用法

Question

我在尝试实现最新的 WorkManager-alpha10 ListenableFuture 以处理流程完成时遇到一些问题。

现在我的 JobOrganizer 类中有以下内容

private fun enqueueDownloadWork(): ListenableFuture<Void> {
    val work = WorkManager.getInstance()
                   .beginWith(dwdTypologiesJob)
                   .then(dwdElementsJob)
                   .then(dwdAnomaliesJob)
    return work.enqueue()
}

private fun createDownloadWorkRequests() {
    dwdTypologiesJob = OneTimeWorkRequestBuilder<DWDAnomalyTypesJob>()
                .addTag("download_typologies_work")
                .build()
    dwdElementsJob = OneTimeWorkRequestBuilder<DWDElementsJob>()
                .addTag("download_elements_work")
                .build()
    dwdAnomaliesJob = OneTimeWorkRequestBuilder<DWDAnomaliesJob>()
                .addTag("download_anomalies_work")
                .build()
}

fun downloadData(): ListenableFuture<Void> {
    createDownloadWorkRequests()
    return enqueueDownloadWork()
}

这是我的电话，谁应该听取完成事件。

val listenable = JobOrganizer.downloadData()
listenable.addListener({
    Log.d("Listenable", "Did something 1");
}, {
    Log.d("Listenable", "Did something 2");
})

我仍然不知道 Runnable 和 Executor 如何处理这个函数。谁能解释一下？

谢谢

Answer 1

你需要同时实例化Runnable和Executor，比如当你想在当前线程直接执行Runnable时:

.addListener(
    object:Runnable {
        override fun run() {
            Log.d("Listenable", "Did something 1");
        }
    },
    object:Executor {
        override fun execute(command: Runnable?) {
            command?.run()
        }
    }

您可以在 https://developer.android.com/reference/java/util/concurrent/Executor 上找到有关执行器的更多示例