EventBus内部如何将事件发送给订阅者

EventBus非常好用,可以说直接把开发中的数据通信方式从飞鸽传书带到了打电话模式。那么,这么神奇的框架它是怎么把事件交到接收者手中的呢。

看一下post方法,它是从ThreadLocal类型的final常量currentPostingThreadState中取出事件队列,然后将要发送的事件添加到队列中,然后在while循环中进入到postSingleEvent方法去发送事件。


这里大概解释一下ThreadLocal,该类主要用于存储线程的私有变量。在其内部,实际是使用一个属于线程的map映射,key就是当前ThreadLocal本身,value则是要保存的值。如下,


接下来看看postSingleEvent方法,eventInheritance默认为true,然后在lookupAllEventTypes去获取注册了该事件的所有类,包括接口,在循环中把事件给到postSingleEventForEventType方法去处理,若subscriptionFound为false,则表明没有任何类注册了接受该事件。


再看postSingleEventForEventType方法,仍然是将事件给到了关键的发送方法postToSubscription去处理。我们直接看postToSubscription,


在这个方法中,首先判断了订阅方法的threadMode类型,threadMode就是编写订阅方法时设置的,分为 MAIN,POSTING,BACKGROUND,ASYNC四种。MAIN比较常用,MAIN类型的订阅者是主线程;POSTING的订阅者是当前线程;BACKGROUND的订阅者是在子线程;而ASYNC模式特殊,发送出去的事件都会开启新线程接受处理。

可以看到,POSTING模式直接调用了invokeSubscriber方法,眼熟吗,没错,他就是采用了反射的方式;看一下这个方法内部,


直接反射调用了订阅方法。

MAIN模式,如果是发送事件也在主线程,那么直接也采用反射,如果是在子线程,这个mainThreadPoster实际是一个handler,并且是一个属于主线程的handler,看下图,


也即是说在子线程中发送的事件交给了handler去处理,怎么处理的呢。看看enqueue方法,


图1

首先,获取了一个包含事件及其订阅者的封装类PendingPost,并且PendingPost内部是复用模式,并没有频繁创建新对象这种占据大量内存的操作。它维护了一个保存PendingPost的集合,并且加了同步锁,保证了线程安全性。看下图,

接下来,回到enqueue方法中(图1),在同步锁的保护下,将PendingPost添加到了PendingPostQueue队列中,sendMessage方法启动消息循环,并且就在本handler自己的handmessage方法中,从PendingPostQueue队列中poll出PendingPost消息对象,并且在同步锁和非同步锁两种情况下判断若取出的PendingPost为空,那handler则回到未激活状态,不再从队列中取消息。

最关键的一步,eventBus.invokeSubscriber(pendingPost),没错,还是反射。因为这个时候事件已经从发送线程交给了订阅者所在的线程,继续采用反射调用订阅方法。所以handler作用是起到了一个快递运输的作用,把事件搬运到订阅者线程。如下图,


以上是MAIN模式下的处理方式,相反的,BACKGROUND模式下,若发送线程也是在当前子线程,则直接反射调用,若不是,也是使用handler,此时的handler是属于子线程的handler罢了。

ASYNC模式不常用,它是在新线程中处理事件,并且最后也是调用了反射。


这里用到了ExecutorService这种优于 new Thread的方式来创建线程,且其内部默认使用线程池来管理线程。

本次的浅析到此为止。

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

推荐阅读更多精彩内容