Message在MessageQueue中的入列和出列流程

1、首先看Handler发送一条消息到MessageQueue,最终会调用MessageQueue中的enqueueMessage(Message msg, long when)方法,我们来看一下这个方法中的核心代码,看如何将消息添加到MessageQueue中。

先上Handler消息机制流程图

《Message在MessageQueue中的入列和出列流程》 3.Handler运行机制.png

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为第一条消息,或执行时间早的时候

《Message在MessageQueue中的入列和出列流程》 消息入列流程1.png

然后,我们再看,如果新消息的执行时间比队列里面的消息,执行时间晚的时候

《Message在MessageQueue中的入列和出列流程》 消息入列流程2.png

2、消息的入列就说完了,再来看一下消息的出列流程 我们都知道,取出消息的逻辑是在Looper.loop()方法里面,里面最主要的是一个死循环,早一点的版本里面用的while(true)循环

for (;;) {    
  //取出消息队列的消息,可能会阻塞
  Message msg = queue.next(); // might block
  //解析消息,分发消息
  msg.target.dispatchMessage(msg);
}

这里要给大家说一下,Linux的一个进程间通信机制:管道(pipe)。
原理:在内存中有一个特殊的文件,这个文件有两个句柄(引用),一个是读取句柄,一个是写入句柄

主线程Looper从消息队列读取消息,当读完所有消息时,进入睡眠,主线程阻塞。子线程往消息队列发送消息,并且往管道文件写数据,主线程即被唤醒,从管道文件读取数据,主线程被唤醒只是为了读取消息,当消息读取完毕,再次睡眠。

《Message在MessageQueue中的入列和出列流程》 管道流原理图.png

然后看消息是怎么取出来的,我们看取出消息的逻辑,把关键代码挑出来

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;
  }
} 

示范一个简单的出列流程

《Message在MessageQueue中的入列和出列流程》 消息出列流程.png

现在消息的入列和出列就说完了

    原文作者:xiaobug
    原文地址: https://www.jianshu.com/p/a8708d315039
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞