原文地址:https://android.jlelse.eu/exploring-jetpack-scheduling-tasks-with-work-manager-fba20d7c69bf
18年I/O大会,google发布了 Android Jetpack.它是一些列的库,工具和架构指南,可以帮助你轻松快速的构建以优秀的App。在Android Jetpack中,Google团队中发布了一个专门用于调度和管理后台任务的库,它被称为WorkManager。
在这部分中,你将了解调度程序的演变,什么是工作管理器,如何使用它以及何时使用。在西一部分,你将了解如何连接所有的任务并且有序的执行。
你可能会说,我们在Android操作系统内部安排了Job Scheduler API来调度任务。我们还有GCM网络管理员,Firebase Job Dispatcher,Evernote的Android Job以及许多其他库,可以调度后台任务。为什么我们需要另一个新库来调度任务?
为了回答这个任务,我相处了后台任务调度器进化矩阵,将此视为时间便的四大支柱
让我们一个一个开始讨论:
1. 易于调度
- 后台工作程序只能在特定条件下调度任务(例如只有设备处于充电状态,该任务才会运行)
- 一旦你调度了任务,就可以忘记任务的存在,调度程序应该提供在所需条件匹配的情况下保证任务运行。
- 每个任务可以与另外一个任务并行链接,以并行或顺序运行多个任务。
易于取消
- 你必须拥有对任务的控制权,调度程序应该提供API以轻松取消计划任务。
易于查询
- 你的应用程序可能会需要显示任务的状态。
- 假设你要上传照片并且需要在界面上显示上传的百分比。
- 调度程序必须提供API以轻松获取任务的当前状态,如果任务完成之后可以传递一些结果数据,那就更棒了!
支持所有的Android版本
- 调度程序API应该在所有的Android版本中都一样。
让我们根据上面的标准来评估WorkManager。
WorkManager API的不同之处
根据官方文档
1. 易于调度
- WorkManager API可以轻松创建可延迟的异步任务,并允许您指定应该何时执行。
- 你可以创建任务并将该任务交给WorkManager,以便立即或在设备处于特定条件下运行该任务。
- WorkManager提供了保证,即使您的应用程序强制退出或设备重新启动,你的任务仍会在特定条件匹配时执行。
2. 易于取消
WorkManager给每个任务分配了UUID,使用这个唯一的ID你就可以随时取消任务。
3.易于查询
- 你可以使用分配给每个任务的唯一标识来询问任务的状态,无论是正在运行,挂起还是已完成。
- WorkManager API超越了任务的当前状态,允许任务一键值对格式返回数据。
- WorkManager使用LiveData来干会任务的数据和状态,所以,你的Activity可以观察这个LiveData,并且每当任务完成时都会得到通知。
4.支持Android所有版本
- WorkManager支持Android API 14及以上
- WorkManager根据设备API级别和应用程序状态等因素选择适当的方式来运行你的任务。
- 如果应用程序正在运行,WorkManager将创建新的线程来运行任务。
- 如果应用程序没有运行,那么他将使用JobScheduler API或Firebase Job APIs调度者或Alarm manager API运行调度任务。
类和概念
Work manager APIs建立在几个类上,你必须继承一些抽象类来安排任务。
- Worker:在WorkManager世界中,Worker等同于需要在后台执行的任务或作业。这是一个抽象类。你需要继承它。您的Worker类包含有关如何执行该任务的信息,但它没有关于何时运行的信息。
- WorkRequest:它代表了工作调度请求。每个工作必须在安排工作之前创建工作请求。 WorkRequest将包含工作的唯一标识,约束条件说明应在哪种情况下执行任务。这是一个抽象类。该库提供了这个类的两个直接子类:OneTimeWorkRequest和PeriodicWorkRequest。
- WorkManager:它是基于WorkRequest中定义的约束来管理和调度任务的类。
- WorkStatus:这个类包装了任何work请求的状态,你可以通过唯一的id来查询任何work的状态。
工作流程
让我们了解如何创建和安排新的work
1.创建work:
- 创建一个Worker的子类,这个类有一个抽象方法doWork(),顾名思义,你需要在后台执行你想要做的工作,该方法将在后台/工作线程中调用,编写以执行此方法中的任务。
- 在返回中,你必须返回WorkerResult。返回WorkerResult.SUCCESS表明您执行的任务已成功完成。返回WorkerResult.RETRY告诉WorkManager再次重试该工作。返回WorkerResult.FAILURE表示发生了一个或多个错误。
class DownloadWorker : Worker() {
// Define the parameter keys:
private val KEY_X_ARG = "X"
private val KEY_Y_ARG = "Y"
private val KEY_Z_ARG = "Z"
// The result key:
private val KEY_RESULT = "result"
/**
* This will be called whenever work manager run the work.
*/
override fun doWork(): WorkerResult {
// Fetch the arguments (and specify default values):
val x = inputData.getLong(KEY_X_ARG, 0)
val y = inputData.getLong(KEY_Y_ARG, 0)
val z = inputData.getLong(KEY_Z_ARG, 0)
val timeToSleep = x + y + z
Thread.sleep(timeToSleep)
//...set the output, and we're done!
val output = Data.Builder()
.putInt(KEY_RESULT, timeToSleep.toInt())
.build()
outputData = output
// Indicate success or failure with your return value.
return WorkerResult.SUCCESS
}
}
2.定义约束:
- 定义约束条件以告诉WorkManager合适安排任务执行,如果没有提供任何约束条件,那么该任务将立即运行。
- 以下是仅在设备充电和限制时才运行任务的约束。
val myConstraints = Constraints.Builder()
.setRequiresDeviceIdle(true)
.setRequiresCharging(true)
.build()
3.创建work request
- 你可以创建OneTimeWorkRequest来运行一次任务。
val request = OneTimeWorkRequest.Builder(DownloadWorker::class.java)
.setConstraints(myConstraints)
.build()
- 如果你想定期运行一个任务,那么创建一个PeriodicWorkRequest并设置工作的时间间隔。
val request = PeriodicWorkRequest
.Builder(DownloadWorker::class.java, 1, TimeUnit.HOURS)
.setConstraints(myConstraints)
.build()
4.执行请求
WorkManager.getInstance().enqueue(request)
输入参数和返回值:
设置输入参数
- 在创建工作请求时,可以将输入参数的androidx.work.Data传递给工作(可以将数据映像为Bundle类型,它将数据保存在键值对中。)
- 使用必须的键值对创建新的Data,然后通过调用setInputData创建工作请求时设置数据。
val myData = Data.Builder()
.putLong(KEY_X_ARG, 42)
.putLong(KEY_Y_ARG, 421)
.putLong(KEY_Z_ARG, 8675309)
.build()
val request = OneTimeWorkRequest.Builder(DownloadWorker::class.java)
.setInputData(myData)
.build()
你可以通过调用getInputData来读取所有这些输入参数,执行完任务后,可以调用setOutputData为该worker设置输出数据。
class DownloadWorker : Worker() {
// Define the parameter keys:
private val KEY_X_ARG = "X"
private val KEY_Y_ARG = "Y"
private val KEY_Z_ARG = "Z"
// The result key:
private val KEY_RESULT = "result"
/**
* This will be called whenever work manager run the work.
*/
override fun doWork(): WorkerResult {
// Fetch the arguments (and specify default values):
val x = inputData.getLong(KEY_X_ARG, 0)
val y = inputData.getLong(KEY_Y_ARG, 0)
val z = inputData.getLong(KEY_Z_ARG, 0)
val timeToSleep = x + y + z
Thread.sleep(timeToSleep)
//...set the output, and we're done!
val output = Data.Builder()
.putInt(KEY_RESULT, timeToSleep.toInt())
.build()
outputData = output
// Indicate success or failure with your return value.
return WorkerResult.SUCCESS
}
}
观察输出数据
- Work manager为所有工作请求管理工作状态和LiveData,应用程序可以观察到LiveData在工作状态发生变化时得到通知。
- 你也可以通过调用getOutputData()来读取输出数据。
什么时候使用work manager?
你可能会觉得work manager APIs使用起来如此简单,如果我们使用它来运行我的所有后台任务,该怎么办?请学习下一篇。