MessageQueue里的消息会以时间顺序(执行的先后顺序)来排序,使用Handler的postDealy后,MessageQueue里的消息会进行重新排序。
根据源码一步步分析:
public final boolean postDelayed(@NonNull Runnable r, long delayMillis) {
return sendMessageDelayed(getPostMessage(r), delayMillis);
}
public final boolean sendMessageDelayed(@NonNull Message msg, long delayMillis) {
if (delayMillis < 0) {
delayMillis = 0;
}
return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis);
}
public boolean sendMessageAtTime(@NonNull Message msg, long uptimeMillis) {
......
return enqueueMessage(queue, msg, uptimeMillis);
}
private boolean enqueueMessage(@NonNull MessageQueue queue, @NonNull Message msg,
long uptimeMillis) {
......
return queue.enqueueMessage(msg, uptimeMillis);
}
根据调用一步一步走,最后会调用如下代码:
boolean enqueueMessage(Message msg, long when) {
if (msg.target == null) {
throw new IllegalArgumentException("Message must have a target.");
}
if (msg.isInUse()) {
throw new IllegalStateException(msg + " This message is already in use.");
}
synchronized (this) {
if (mQuitting) {
IllegalStateException e = new IllegalStateException(
msg.target + " sending message to a Handler on a dead thread");
Log.w(TAG, e.getMessage(), e);
msg.recycle();
return false;
}
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应该插入的位置
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;
}
如上所示,首先会根据消息的时间(当前时间+延迟时间)与消息队列里面的消息的时间进行对比查找,找到需要插入的位置然后插入。在MessageQueue中,所有的Message是以链表的形式组织在一起。为啥叫消息队列,大概是因为从MessageQueue有着队列的性质,只能从队首删除,队尾添加(MessageQueue不只是可以从队尾添加)。在使用时都是通过Looper.loop()从消息队列中取出消息,而且loop方法就是从MessageQueue的队首开始取出消息。
总结
使用Handler的postDealy后消息队列可能会进行重新排序。消息队列里消息按执行先后时间进行排序,先执行的在前,后执行的在后。postDealy发送的消息会根据延迟时间与消息队列里存在的消息的执行时间进行比较,然后寻找插入位置插入消息。
网友评论