1、首先看Handler发送一条消息到MessageQueue,最终会调用MessageQueue中的enqueueMessage(Message msg, long when)方法,我们来看一下这个方法中的核心代码,看如何将消息添加到MessageQueue中。
先上Handler消息机制流程图
boolean enqueueMessage(Message msg, long when) {
//对消息的重新排序,通过判断消息队列里是否有消息以及消息的时间对比
msg.when = when;
Message p = mMessages;
//把刚进入消息队列的消息置位消息队列的第一条消息
if (p == null || when == 0 || when < p.when) {
msg.next = p;
mMessages = msg;
needWake = mBlocked;
} else {
//根据时间排序,为刚进入队列的消息寻找合适的位置
Message prev;
for (;;) {
prev = p;
p = p.next;
}
msg.next = p; // invariant: p == prev.next
prev.next = msg;
}
}
总体来看,消息入列就是根据Message的when属性的大小进行排序,先执行的放在队列的前面。
首先看第一种:当Message为第一条消息,或执行时间早的时候
然后,我们再看,如果新消息的执行时间比队列里面的消息,执行时间晚的时候
2、消息的入列就说完了,再来看一下消息的出列流程 我们都知道,取出消息的逻辑是在Looper.loop()方法里面,里面最主要的是一个死循环,早一点的版本里面用的while(true)循环
for (;;) {
//取出消息队列的消息,可能会阻塞
Message msg = queue.next(); // might block
//解析消息,分发消息
msg.target.dispatchMessage(msg);
}
这里要给大家说一下,Linux的一个进程间通信机制:管道(pipe)。
原理:在内存中有一个特殊的文件,这个文件有两个句柄(引用),一个是读取句柄,一个是写入句柄
主线程Looper从消息队列读取消息,当读完所有消息时,进入睡眠,主线程阻塞。子线程往消息队列发送消息,并且往管道文件写数据,主线程即被唤醒,从管道文件读取数据,主线程被唤醒只是为了读取消息,当消息读取完毕,再次睡眠。
然后看消息是怎么取出来的,我们看取出消息的逻辑,把关键代码挑出来
Message msg = queue.next(); // might block
Message next() {
for (;;) {
Message prevMsg = null;
Message msg = mMessages;
if (prevMsg != null) {
prevMsg.next = msg.next;
} else {
mMessages = msg.next;
}
msg.next = null;
return msg;
}
}
示范一个简单的出列流程
现在消息的入列和出列就说完了