WorkManager调研分析


  • 背景:通常我们在开发过程中处理后台任务的时候可能是自己维系一个线程池或者通过一个后台任务来完成我们的工作,然后对于某些特定的需求还需要自己进行网络条件,电量等信息的拦截判断处理。这个实现过程比较繁琐,而且每个类似的需求都写一套相同的逻辑就显得很累赘了。通过谷歌新推出的WorkManager SDK能很好的解决上述问题
  • 原理:根据当前系统的API版本和当前应用的存活状态来选择对应的方式来执行任务,当应用在运行的时候,会在应用进程中开启一个子线程来执行任务,如果应用被杀掉了,WorkManager会根据当前系统API版本来选择是使用JobScheduler(API21)还是AlarmManager(API14-API20)来执行任务(具体的执行时机在某些国产系统上可能会发生变化)。
  • 结论:对于可延时的执行的后台任务建议迁移到WorkManager上,节约APP的电量消耗(如日志上报等),而对于需要立刻执行的任务建议还是使用ThreadPool或者前台服务等

一、基本功能


  • 1.1 运作流程

    • 通过WorkManager将Woker任务添加到任务队列中,在添加的过程中可以指定约束条件(充电状态、WIFI状态、手机存储空间等等)。只有当约束条件满足时才会执行我们的Worker。
  • 1.2 Worker

    • 表示一个要执行的任务,我们需要继承并显示该类,并在doWork方法中实现我们自己的任务逻辑,通过不同的返回值表示当前Work的执行情况
      • Worker.Result.SUCCES 表示任务执行成功,如果有下一个任务会接着执行下一个任务
      • Worker.Result.FAILURE 表示任务执行失败,整个任务链就此中断
      • Worker.Result.RETRY 通过WorkManager根据重试策略尝试执行该任务
  • 1.3 WorkRequest

    • Worker的包装类,最后添加到WorkManager中的就是当前WorkRequest对象,通过WorkRequest对象可以给我们的Worker附加额外的功能
      • 执行任务时的约束条件(电量、网络等)
      • 当Worker执行失败时的重试策略
      • 设置当前Worker的入参(执行任务时可携带额外的参数给Worker使用)
      • 设置当前Worker接受的入参合并策略(仅当上一个任务存在多个并行的Worker且返回相同的KEY时有作用,在下面的入参和出参模块会详细介绍)
    • 两个子类
      • OneTimeWorkRequest
      • PeriodicWorkRequest(下方模块有介绍)
  • 1.4 WorkManager
    * 主要用来管理任务请求和任务队列,将Worker的包装者WorkRequest对象入队,同时还可以指定多个任务执行的先后顺序,实现串行或者并行的任务链。

  • 1.5 Constraints(添加约束条件)

    • setRequiredNetworkType(设置网络相关的约束条件)
      • NetworkType.NOT_REQUIRED【对网络没有要求】
      • NetworkType.CONNECTED【网络连接】
      • NetworkType.UNMETERED【不计费的网络比如WIFI下执行】
      • NetworkType.NOT_ROAMING【非漫游网络状态】
      • NetworkType.METERED 【计费网络比如3G,4G下执行。】
    • setRequiresDeviceIdle (设置设备是否空闲)
    • setRequiresCharging(设置设备是否处于充电状态)
    • setRequiresBatteryNotLow(设备电量是否不应低于临界阀值)
    • setRequiresStorageNotLow(设备存储空间低于临界阀值)
    • addTriggerContentUri【API24】(对某个ContentUri的内容变化进行监听)
      • 通过内容提供者修改联系人,当联系人修改时,触发这个监听回调
        注:因为内容提供者的修改可能会短时间内多次调用,为了不影响监听线程,这里需要另起新的线程或者来执行

二、高级功能


  • 2.1 任务类型
    • OneTimeWorkRequest 【只执行一次的任务】
      •   OneTimeWorkRequest myWorkRequest = new OneTimeWorkRequest.Builder(MyWorker.class).build();
        
    • PeriodicWorkRequest 【一定周期间隔内重复执行的任务】
      • 周期性任务,官方设定最短执行周期为15分钟,同时因为系统的优化策略,后面周期性的任务执行可能会有一定的时间延迟,无法做到精准时间执行。
    •    PeriodicWorkRequest build = new PeriodicWorkRequest.Builder(MyWorker.class, 25, TimeUnit.MILLISECONDS).build();
      
  • 2.2 任务链
    • 串行链
      •   WorkManager.getInstance().beginWith(workRequestA)
              .then(workRequestB)
              .then(workRequestC)
              .enqueue()
        
      • 依次执行workRequestA ,workRequestB,workRequestC。每个阶段完成之后通过在doWork方法中返回Worker.Result.SUCCES来进入下一个workRequest。如果其中任何一个workRequest返回Worker.Result.FAILURE,那么后续的workRequest都不会执行了,就此中断
    • 并发链
      •  WorkManager.getInstance()
             .beginWith(workA1, workA2, workA3)
             .then(workB1, workB2)
             .then(workC1, workC2)
             .enqueue();
        
      • 首先并行执行workA1, workA2, workA3任务,等待这三个任务都执行完之后再并发执行workB1, workB2任务,等待着两个任务执行完毕之后再继续并发执行workC1, workC2任务。
    • 组合链
      •     //A,B任务链
            WorkContinuation continuationAB = WorkManager.getInstance().beginWith(requestA).then(requestB);
            //C,D任务链
            WorkContinuation continuationCD = WorkManager.getInstance().beginWith(requestC).then(requestD);
            // 对AB和CD进行组合
            WorkContinuation.combine(continuationAB, continuationCD).then(requestE).enqueue();
        
      • A/B串行执行,C/D串行执行,最后让A/B和C/D这两个组合任务并发执行。
  • 2.3 任务标签
    • 作用:对WorkerRequest进行标签分组,同时还可以操作同一分组标签,比如取消该标签下的所有任务,或者获取该标签下的所有任务,然后查询各个任务现在的执行状态
    •  OneTimeWorkRequest cacheCleanupTask =new OneTimeWorkRequest.Builder(WorkerA.class)
            .addTag("groupA")
            .build();
      
  • 2.4 任务参数传递
    • 作用:当我们在执行单个任务或者一个任务链的时候,我们可能需要将参数带入到第一个任务中,或者需要将第一个任务执行后的返回结果带入到第二个任务中。
    • 初始化任务时传递参数:
      •     Data workData = new Data.Builder() // Data大小需要控制在10k内
                     .putInt("NAME", "Android Develop") // 参数可以为任意类型
                     .putInt("AGE", 101)
                     .build();
            OneTimeWorkRequest workRequestA = new OneTimeWorkRequest.Builder(WorkerA.class)
                     .setInputData(workData)
                     .build();
            WorkManager.getInstance().enqueue(mathWork);
        
    • 将当前任务的执行结果传递给下一个任务
      •     public class MathWorker extends Worker {
               @Override
               public Worker.WorkerResult doWork() {
                   String sourceName = getInputData().getString("NAME", "");
                   int sourceAge = getInputData().getInt("AGE", 0);
                   int formatAge = sourceAge + 101;
                   Data output = new Data.Builder()
                        .putInt("AGE", formatAge)
                        .build();
                   setOutputData(output);
                   return WorkerResult.SUCCESS;
           }}
        
    • 多个相同参数来源的合并
      • 参数合并:当需要将多个任务的输出作为一个任务的输入时就会涉及到一个参数合并的问题,如果多个任务的输出中由好几个key都是一样的,那么需要由开发者自己来决定应该使用什么样的参数合并规则
      • 合并规则之ArrayCreatingInputMerger
        •  OneTimeWorkRequest workerRequestA = new OneTimeWorkRequest.Builder(WorkerA.class).setInputMerger(ArrayCreatingInputMerger.class).build();
          
        • 对于该合并规则来说,同一个的Key对应的Value都会放在一个数组中,数据会随着入参的增多而变大,对于下游任务想要获取数据的方法为getXXXArray(),如getIntArray();
      • 合并规则之OverwritingInputMerger
        • OneTimeWorkRequest workerRequestB = new OneTimeWorkRequest.Builder(WorkerA.class).setInputMerger(OverwritingInputMerger.class).build();
          
        • 顾名思义,后到的key-value会覆盖已存在的key-value
      • 自定义合并规则
        • 需要自定义类,然后继承抽象类InputMerger,覆写merge方法,实现自己的merge逻辑

三、存在的限制

  • 周期任务最小时间间隔为15分钟
  • 任务队列最大限制为100个
  • 参数传递最大数据量为10kb
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,658评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,482评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,213评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,395评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,487评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,523评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,525评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,300评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,753评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,048评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,223评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,905评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,541评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,168评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,417评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,094评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,088评论 2 352

推荐阅读更多精彩内容