这个问题来自于群里看到的一个问题,一个Handler的消息队列中只有两条消息,第一条是一个延时100ms的消息,第二条是普通消息,这时候取消息的流程是怎么样的?
这个问题我一开始也是懵的,仔细看了一下源码,发现这个问题其实也不难,但很容易忽略,特总结一下:
我们知道要发送延时消息,用的是 boolean sendMessageDelayed (Message msg, long delayMillis) 这个接口,API文档的描述其实已经给了答案:
Enqueue a message into the message queue after all pending messages before (current time + delayMillis). You will receive it in handleMessage(Message), in the thread attached to this handler.
调用这个方法时会将这个message根据delayMillis插入到MessageQueue的合适地方。也就是说之前那个问题问的其实有问题,不应该问取消息的流程是怎么样的,而应该问插入消息的流程是怎么样的,因为取消息的流程没啥特别的,还和以前一样。
具体流程在 MessageQueue.enqueueMessage 中:
boolean enqueueMessage(Message msg, long when) {
...
msg.markInUse();
msg.when = when;
Message p = mMessages;
boolean needWake;
if (p == null || when == 0 || when < p.when) {
// New head, wake up the event queue if blocked.
msg.next = p;
mMessages = msg;
needWake = mBlocked;
} else {
// Inserted within the middle of the queue. Usually we don't have to wake
// up the event queue unless there is a barrier at the head of the queue
// and the message is the earliest asynchronous message in the queue.
needWake = mBlocked && p.target == null && msg.isAsynchronous();
Message prev;
for (;;) {
//核心逻辑就是这个循环,其实很简单,就是根据message.when将新的延时message插入到消息队列中的合适位置,
//一个简单的链表插入操作。
prev = p;
p = p.next;
if (p == null || when < p.when) {
break;
}
if (needWake && p.isAsynchronous()) {
needWake = false;
}
}
msg.next = p; // invariant: p == prev.next
prev.next = msg;
}
// We can assume mPtr != 0 because mQuitting is false.
if (needWake) {
nativeWake(mPtr);
}
}
return true;
}