有人可以提供一个好的 Listenable worker 示例吗？

Question

我一直在研究ListenableWorker 类以使用新的工作管理器创建服务。但我在任何地方都找不到任何例子。任何描述工作经理的来源，都给出了 Worker 类的例子，它有一个很好的 doWork 方法，但它不符合我的要求。所以我希望你的帮助写一个很好的服务使用ListenableWorker 可以处理ListenableFuture

我已经尝试过 android 开发人员的文档，在他们的文档中，他们写过关于使用 guava 和使用并发期货的文章，两者都没有提供任何示例来编写简单的服务。我还观看了 workmanager 发布视频，其中 google 工程师解释了新 API，但他们的示例都在 Kotlin 中，我没有使用这些类。

import android.content.Context;

import androidx.annotation.NonNull;
import androidx.concurrent.futures.CallbackToFutureAdapter;
import androidx.work.ListenableWorker;
import androidx.work.WorkerParameters;

import com.google.common.util.concurrent.ListenableFuture;


public class DistanceWorker extends ListenableWorker {

    public DistanceWorker(Context context, WorkerParameters workerParameters){
        super(context, workerParameters);
    }
    @NonNull
    @Override
    public ListenableFuture<Result> startWork() {
        //what to write here ?
    }
}

我只想返回一个未来，并想知道在我的工作完成后如何解决或拒绝那个未来。请帮助我理解它。

Answer 1

我也有关于如何使用 Kotlin 使用 ListenableWorkers 的问题。所以我构建了这个小例子来检索位置，我相信这是使用它的最常见的情况。

https://github.com/febaisi/ListenableWorkerExample

这是一个通用的基本用法（未经测试） - 我相信检查我的项目更容易，我在其中添加了完整的测试版本。 我从 Github 项目的 worker 中获取数据，在这里很难举例说明。

    //Enqueue work
    val anyWorkListenableWorker = OneTimeWorkRequest.Builder(AnyWorkListenableWorker::class.java).build()
    workManagerInstance.enqueueUniqueWork("ANY_WORK", ExistingWorkPolicy.KEEP, anyWorkListenableWorker)

class AnyWorkListenableWorker(appContext: Context, workerParams: WorkerParameters)
    : ListenableWorker(appContext, workerParams) {

    private val future : ResolvableFuture<Result> = ResolvableFuture.create()

    override fun startWork(): ListenableFuture<Result> {
        //MAIN THREAD

        CoroutineScope(Default).launch {
            //Launch scope to do work out of the main thread
            doAnyWork()
        }

        return future
    }

    private fun doAnyWork() {
        //Do long work
        future.set(Result.success())
    }
}

Answer 2

你可以这样做

override fun startWork(): ListenableFuture<ListenableWorker.Result> {
    // Do your work here

    return CallbackToFutureAdapter.getFuture {
      it.set(Result.success())
    } 
}

Answer 3

Worker、CoroutineWorker 或 RxWorker 都是 ListenableWorkers。以下是来源链接：

https://android.googlesource.com/platform/frameworks/support/+/androidx-master-dev/work/workmanager/src/main/java/androidx/work/Worker.java

https://android.googlesource.com/platform/frameworks/support/+/androidx-master-dev/work/workmanager-ktx/src/main/java/androidx/work/CoroutineWorker.kt#37