更高级的 Android 启动任务调度库

无标题.png

在之前的文章中,我介绍了自研的 Android 启动任务调度工具 AndroidStartup。近期,因为在组件化项目中运用该项目的需要,我对这个库做了一番升级。在最新的 2.2 版本中,我新增了一些特性。相比于目前市面上其他的启动任务调度库,使其具备了更多的优势。这里我只介绍下经过新的版本迭代之后该项目与其他项目的不同点。对于其基础的实现原理,可以参考我之前的文章 《异步、非阻塞式 Android 启动任务调度库》

1、支持多种线程模型

这是相对于 Jetpack 的启动任务库的优势,在指定任务的时候,你可以通过 ISchedulerJobthreadMode() 方法指定该任务执行的线程,当前支持主线程(ThreadMode.MAIN)和非主线程(ThreadMode.BACKGROUND)两种情况。前者在主线程当中执行,后者在线程池当中执行,同时,该库还允许你自定义自己的线程池。关于这块的实现原理可以参考之前的文章或者项目源码。

2、非阻塞的任务调度方式

在之前的文章中也提到了,如果说采用 CountDownLatch 等阻塞的方式来实现任务调度,虽然不会占用主线程的 CPU,但是子线程会被阻塞,一样会导致 CPU 空转,影响程序执行的性能,尤其启动的时候大量任务执行时的情况。所以,在这个库的设计中,我们使用了通知唤醒的方式进行任务调度。也就是,

首先,它会将所有的需要执行的任务收集起来;然后,它会根据任务的依赖关系指定分发和调度任务的子任务;最后,当当前任务执行完毕,该任务会通知所有的子任务按照顺序执行。大致实现逻辑如下,

override fun execute() {
    val realJob = {
        // 1. Run the task if match given process.
        if (matcher.match(job.targetProcesses())) {
            job.run(context)
        }

        // 2. Then sort children task.
        children.sortBy { child -> -child.order() }

        // 3. No matter the task invoked in current process or not,
        // its children will be notified after that.
        children.forEach { it.notifyJobFinished(this) }
    }

    try {
        if (job.threadMode() == ThreadMode.MAIN) {
            // Cases for main thread.
            if (Thread.currentThread() == Looper.getMainLooper().thread) {
                realJob.invoke()
            } else {
                mainThreadHandler.post { realJob.invoke() }
            }
        } else {
            // Cases for background thread.
            executor.execute { realJob.invoke() }
        }
    } catch (e: Throwable) {
        throw SchedulerException(e)
    }
}

3、非 Class 的依赖方式

之前在本项目中,以及其他的项目中可能采用了基于 Class 的形式进行任务依赖。这种使用方式存在一些问题,即在组件化开发的时候,Class 之间需要直接进行引用。这导致各个组件之间的强耦合。这显然不是我们希望的。

所以,为了更好地支持组件化,在该库的新版本中,我们允许通过 name() 方法执行任务的名称,以及通过 dependencies() 方法指定该任务依赖的其他任务的名称。name() 默认使用任务 Class 的全限定名。这样,当多个组件之间进行相互依赖的时候,只需要通过字符串指定名称而无需引用具体的类。

比如,一个任务在一个组件中定义如下,

@StartupJob class BlockingBackgroundJob : ISchedulerJob {

    override fun name(): String = "blocking"

    override fun threadMode(): ThreadMode = ThreadMode.BACKGROUND

    override fun dependencies(): List<String> = emptyList()

    override fun run(context: Context) {
        Thread.sleep(5_000L) // 5 seconds
        L.d("BlockingBackgroundJob done! ${Thread.currentThread()}")
        toast("BlockingBackgroundJob done!")
    }
}

在另一个组件中的另一个任务需要依赖上述任务的时候,定义如下,

@StartupJob class SubModuleTask : ISchedulerJob {

    override fun dependencies(): List<String> = listOf("blocking")

    override fun run(context: Context) {
        Log.d("SubModuleTask", "runed ")
    }
}

这样我们就实现组件化场景中的依赖关系了。

4、支持任务的优先级

在实际开发中,我们可能会遇到需要为所有的根任务或者一个任务的所有的子任务指定执行的先后顺序的场景。或者在组件化中,存在依赖关系,但是我们希望某个根任务优先执行,但是不想为每个子任务都执行依赖关系的时候,我们可以通过指定这个任务的优先级为最高来使其最先被执行。你可以通过 priority() 方法传递一个 0 到 100 的整数来指定任务的优先级。

@StartupJob class TopPriorityJob : ISchedulerJob{

    override fun priority(): Int = 100

    override fun run(context: Context) {
        L.d("Top level job done!")
    }
}

优先级局限于依赖关系相同的任务,所以是依赖关系的补充,不会造成歧义。

5、支持指定任务执行的进程,可自定义进程匹配策略

如果我们的项目支持多进程,而我们希望某些启动任务只在某个进程中执行而其他进程不需要执行,以此避免没必要的任务来提升任务执行的性能的时候,我们可以通过指定任务执行的进程来进行优化。你可以通过 targetProcesses() 传递一个进程的列表来指定该任务执行的所有进程。默认列表为空,表示运行在所有的进程。

对于进程的匹配,我们提供了 IProcessMatcher 这个接口,

interface IProcessMatcher {
    fun match(target: List<String>): Boolean
}

你可以通过指定这个接口来自定义线程的匹配策略。

6、支持注解形式的组件化调用

在之前的版本中,通过 ContentProvider 的形式我们一样可以实现所有组件内任务的收集和调用。但是使用 ContentProvider 存在一些不便之处,比如 ContentProvider 的初始化实际在 Application 的 attachBaseContext(),如果我们的任务中一些操作需要放到 Application 的 onCreate() 中执行的时候,通过 ContentProvider 默认装载任务的调度方式就存在问题。而通过基于注解 + APT的形式,我们可以随意指定任务收集、整理和执行的时机,灵活性更好。

为了支持组件化,我们在之前的项目上做了一些拓展。之前的项目虽然也是基于注解发现机制,但是在组件化的应用中存在问题。在新的版本中,我们只是处理了组件化应用场景中的问题,但是使用方式上面完全兼容,只不过你需要为每个组件在 gradle.build 中增加一个行信息来指定组件的名称(就像 ARouter 一样),

javaCompileOptions {
    annotationProcessorOptions {
        arguments = [STARTUP_MODULE_NAME: project.getName()]
    }
}

也就是说你还是通过 @StartupJob 注解将任务标记为启动任务,然后通过

launchStartup(this) {
    scanAnnotations()
}

这行代码启动扫描并执行任务。

在新的版本中,所有生产的代码会被统一放到包 me.shouheng.startup.hunter 下面,然后通过 JobHunter$$组件名 的形式为每个组件生成自己的类,然后在扫描任务的时候通过加载这个包名之下的所有的代码来找到所有要执行的任务。如果你对组件化感兴趣可以直接阅读这块的源码实现。

总结

启动任务调度库的设计不算复杂,但是我却在之前的面试中两次被问到如何设计。这种类型的问题能很好地考察代码设计能力。相信阅读这个库的代码之后,此类的问题再也难不倒你。如果你对 APT+注解 的组件化实现方式等感兴趣一样可以阅读这个库的代码。

以上介绍了这个库的一些特性和优势,没用过多地介绍其源码实现,感兴趣的同学可以直接阅读项目的源码,相信你能够从代码中学到一些东西。对于示例项目,除了阅读这个项目的示例,还可以参考 Android-VMLib 这个项目。该项目地址:https://github.com/Shouheng88/AndroidStartup

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

推荐阅读更多精彩内容