Handler源码解析

今天来分析一波handler的源码,先从发送消息开始



调用sendMessageAtTime方法,传递了一个当前系统时间加上一个传递的时间


这里首先将当前handler对象赋值给Message对象的target,然后调用MessageQueue的enqueueMessage方法,传递了2个参数,一个为message对象,一个为当前系统时间+传递的时间,进入到MessageQueue


可以看到,message是一个链表结构,通过时间排序,插入到队列中,时间越早,越排在前面

前面这部分是发送消息,作一个小结,当handler发送一个消息后,会将消息发送到messageQueue中,用链表实现的时间优先级队列,时间是当前系统时间加上发送消息传递的时间,发送时间默认为是0+,然后通过时间的排序,时间最早的消息放在队列的前面,接下来我们再来看取消息

首先看ActivityThread的main方法



main方法中有2个关键的方法,Looper.prepareMainLooper(); 和 Looper.loop();进去看看

先看prepareMainLooper方法



这里使用了ThreadLocal,关于threadLoca的原理可以看看我之前的文章

来分析下这几段代码

首先在prepareMainLooper方法中调用了prepare方法,然后会new一个Looper出来,在new之前会判断threadLocal是否get到值,如果get不等于null,则会抛出异常,在看Looper的构造方法,会创建一个MessageQueue

由此可以看出,一个线程中只能有一个Looper对象,否则会抛异常,同理一个线程也只会有一个messageQueue,这里我们再回头看前面的这一段代码


前面使用handler发送消息时,是发送到哪个messageQueue中去了呢,看看这个mQueue对象的赋值


结合这2张图,是不是就明白了,在handler的构造方法中,获取当前线程的looper,然后再获取当前looper的messageQueue,messageageQueue是Looper的成员属性,一个Looper对应一个messageQueue.

然后我们接着看Looper的loop方法


代码有些长,我们一段一段的来看

首先获取当前线程的MessageQueue,然后在一个死循环中,调用MessageQueue的next方法,取出一个message。那么来看一看next方法


代码没有全部贴出来,不过了解这部分就够了。

首先会调用 nativePollOnce(ptr, nextPollTimeoutMillis); 这会调用到native层进行阻塞,这里我们不作研究。

然后我们从350行开始看,首先拿到队列的头一个message,然后与当前系统时间进行判断,如果大于,说明此消息执行的时间还未到,则会计算差值(需要等待的时间),赋值给nextPollTimeoutMillis,在下一次for循环再次调用 nativePollOnce(ptr, nextPollTimeoutMillis)就会阻塞相应的时间

再看else中,360行,重新赋值队列头的消息指向下一个,再把这个消息返回,由此从messageQueue中的头部取出了一个消息。

接下来再来看343行,同步消息屏障。这个同步消息屏障是怎么回事呢

比如说系统要发送一个立马需要执行的消息,就会用到同步屏障,首先会发送一个target=null的message,(前面的代码我们可以看到当我们发送一个消息时,message的target指向当前handler本身。),然后再发送一个打了标签的异步message,就像代码中的 !msg.isAsynchronous()

同步屏障消息的逻辑就是,当判断到有一个message的target=null,则说明有一个异步消息需要马上处理,然后while循环在队列中找到这个异步消息,再返回。

next取消息分析完了,我们再回到loop方法中


在loop方法中,取到消息后,因为前面我们已经知道了msg的target对象为handler本身,则会调用handler的dispatchMessage方法


到这里消息就得到了执行。

最后消息执行完毕之后


可以看到,消息执行完了之后,会清除message中的数据,并保存在pool中,默认保存50个,然后在Message的obtain方法中创建消息,会进行复用。到这里我们应该知道了创建一个消息应该使用obtain()方法 = =。

到这里就基本分析完了,最后总结一下。

Handler发送消息,会发送到messageQueue中,使用链表结构实现的优先级队列,时间越早越排在前面,这个messageQueue是Looper的成员,

Looper对象的创建使用了threadLocal,并保证了一个线程只能有一个Looper,主线程的Looper的创建是在ActivityThread的main方法中,并开启了Looper的loop方法,进行死循环,调用当前looper中的messageQueue的next方法拿出队列头消息,如果消息执行时间未到,则会阻塞,拿到消息后通过message的target的最终调用handler的dispatchMessage方法,最后得到了执行,执行完毕后会清空message对象的数据,并保存到spool中,进行复用。 最后取消息和发送消息都使用synchronized关键字加锁,保证了线程安全。

最后如果在子线程中,创建handler对象,需要手动调用Looper的prepare方法来创建当前线程的looper对象,并开启loop方法循环取消息,不然会报错的,主线程不需要是因为源码已经开启了。


分析结束,不足之处,请多指教。

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