JetPack之WorkManager

WorkManager的作用

一.确保重要的后台任务，一定会被执行，后台任务
（例如：非及时性的（请求服务器及时性）上传，下载，同步数 据等）

二.WorkManager的优势

（1）最高向后兼容到 API 14

  1. 在运行 API 23 及以上级别的设备上使用 JobScheduler
  2. 在运行 API 14-22 的设备上结合使用 BroadcastReceiver 和 AlarmManager

不同版本的调度

（2）WorkManager保证提交给系统的延时任务是依赖与数据的持久化

1.添加网络可用性或充电状态等工作约束,根据添加的约束条件智能的启动后台任务
2.调度一次性或周期性异步任务
3.监控和管理计划任务
4.将任务链接起来,可以给多个任务进行串行、并行调度,甚至多个链多个链的串行并行
确保任务执行，即使应用或设备重启也同样执行任务,依赖于room的持久化实现

（3）遵循低电耗模式等省电功能,更省电

三.调度，管理，执行的后台任务的场景，通常是可延迟的后台任务

WorkManager的主线流程.png

1.WorkManager 保证任务一定执行的？
  Android操作系统会在系统级别服务中，来判断用户的约束条件，当约束条件满足时就会执行任务，但是触发检测是采用广播的形式处理的，例如：网络连接成功 就触发任务执行。

2.WorkManager是怎么保证，当把APP杀掉后呢？
记录用户的所有信息并全部保存到数据库，而并非保存在内存中，这样做的好处，就是持久性保存记录，所有APP被杀掉后 依然可以获取所有任务信息。

3.WorkManager是干嘛用的？
处理非及时任务，举例子：每天同步一次数据到服务器，这种类似的需求，不是及时执行，但是又保证会执行的非及时任务。

四.WorkManager的使用：

单一的任务

        // 请求对象
        val request = OneTimeWorkRequest.Builder(MainWorker3::class.java)
            .build()

        //  初始化环境  初始化工作源码
        /**
         * 这是第二次执行getInstance  ---  最终返回：WorkManagerImpl
         *
         * APK清单文件里面（第一次）执行 
         * 1.初始化 数据库 ROOM 来保存你的任务 （持久性保存的） 手机重新，APP被杀掉 没关系 一定执行
         * 2.初始化 埋下伏笔  new GreedyScheduler
         * 3.初始化 配置信息 configuration  （执行的信息，线程池任务，...）
         */
        WorkManager.getInstance(this) // 这是第二次执行，        APK清单文件里面（第一次）执行  面试官
            .enqueue(request)

多个任务 顺序执行

       //多个任务 顺序执行
        val oneTimeWorkRequest3 = OneTimeWorkRequest.Builder(MainWorker3::class.java).build()
        val oneTimeWorkRequest4 = OneTimeWorkRequest.Builder(MainWorker4::class.java).build()
        val oneTimeWorkRequest5 = OneTimeWorkRequest.Builder(MainWorker5::class.java).build()
        val oneTimeWorkRequest6 = OneTimeWorkRequest.Builder(MainWorker6::class.java).build()

        // 顺序执行 3 4 5 6
        WorkManager.getInstance(this)
            .beginWith(oneTimeWorkRequest3) // 检查的任务
            .then(oneTimeWorkRequest4) // 业务1任务
            .then(oneTimeWorkRequest5) // 业务2任务
            .then(oneTimeWorkRequest6) // 最后检查工作任务
            .enqueue()

        // 需求：先执行  3  4    最后执行 6
        val oneTimeWorkRequests: MutableList<OneTimeWorkRequest> = ArrayList()
        oneTimeWorkRequests.add(oneTimeWorkRequest3) // 先同步日志信息
        oneTimeWorkRequests.add(oneTimeWorkRequest4) // 先更新服务器数据信息
        WorkManager.getInstance(this).beginWith(oneTimeWorkRequests)
            .then(oneTimeWorkRequest6) // 最后再 检查同步
            .enqueue()

重复执行后台任务 非单个任务，多个任务

         // 重复的任务  多次/循环/轮询  , 哪怕设置为 10秒 轮询一次,   那么最少轮询/循环一次 15分钟（Google规定的）
        // 不能小于15分钟，否则默认修改成 15分钟
        val periodicWorkRequest =
            PeriodicWorkRequest.Builder(MainWorker3::class.java, 10, TimeUnit.SECONDS).build()

        // 【状态机】  为什么一直都是 ENQUEUE，因为 你是轮询的任务，所以你看不到 SUCCESS     [如果你是单个任务，就会看到SUCCESS]
        // 监听状态
        WorkManager.getInstance(this).getWorkInfoByIdLiveData(periodicWorkRequest.id)
            .observe(this, { workInfo ->
                Log.d(MainWorker2.TAG, "状态：" + workInfo.state.name) // ENQUEEN   SUCCESS
                if (workInfo.state.isFinished) {
                    Log.d(MainWorker2.TAG, "状态：isFinished=true 同学们注意：后台任务已经完成了...")
                }
            })
        WorkManager.getInstance(this).enqueue(periodicWorkRequest)

约束条件，约束后台任务执行

         // 约束条件，必须满足我的条件，才能执行后台任务 （在连接网络，插入电源 并且 处于空闲时）
        val constraints = Constraints.Builder()
            .setRequiredNetworkType(NetworkType.CONNECTED) // 网络链接中...
            /*.setRequiresCharging(true) // 充电中..
                .setRequiresDeviceIdle(true) // 空闲时.. (例如：你没有玩游戏，你没有看片)*/
            .build()

        /**
         * 除了上面设置的约束外，WorkManger还提供了以下的约束作为Work执行的条件：
         * setRequiredNetworkType：网络连接设置
         * setRequiresBatteryNotLow：是否为低电量时运行 默认false
         * setRequiresCharging：是否要插入设备（接入电源），默认false
         * setRequiresDeviceIdle：设备是否为空闲，默认false
         * setRequiresStorageNotLow：设备可用存储是否不低于临界阈值
         */

        // 请求对象
        val request = OneTimeWorkRequest.Builder(MainWorker3::class.java)
            .setConstraints(constraints) // Request关联 约束条件
           .build()

        // 加入队列
        WorkManager.getInstance(this).enqueue(request)

任务的取消、暂停

        //取消所有

        WorkManager.getInstance(this).cancelAllWork()

        //取消某一个 如saveRequest

        WorkManager.getInstance().cancelWorkById(saveRequest.getId())

        //按标记取消 WorkRequest会取消所有具有此标记的工作

        WorkManager.getInstance().cancelAllWorkByTag(request.getStringId())

        //取消所有未完成的工作的工作链的名字:unique

        WorkManager.getInstance(this).cancelUniqueWork("unique")

有高级玩法,比如取消当前的执行任务并将其 REPLACE 为新工作链

任务链

1.多任务组合一个任务链

                WorkManager.getInstance(this)

                //request,request2并发执行

                .beginWith(Arrays.asList(request, request2))

                //request1 request2顺序执行

                .then(request1).then(request2)

                .then(Arrays.asList(request1, request2))

                .enqueue();

2.多任务链合并一个任务链

        //两个任务链

        val begin = WorkManager.getInstance(this).beginWith(Arrays.asList(request, request2));

         val then = WorkManager.getInstance(this).beginWith(request).then(request1);

        //多任务链合并，

        val thenEnd = WorkContinuation.combine(Arrays.asList(begin, then)).then(request);

        //多任务链执行

        thenEnd.enqueue()

如果需要创建一个唯一单次工作链可以使用WorkManager.beginUniqueWork(String, ExistingWorkPolicy, OneTimeWorkRequest)代替 beginWith()

//创建一个唯一周期重复工作链 
    WorkManager.getInstance(base)
      .enqueueUniquePeriodicWork(
        TAG_Unique, 
        ExistingPeriodicWorkPolicy.REPLACE,
        mPeriodicWorkRequest)