文章目录
- 一、MessageQueue 消息队列存储消息
- 二、MessageQueue 消息队列取出消息
- 三、消息队列完整代码
一、MessageQueue 消息队列存储消息
Message 链表 : 消息队列 MessageQueue , 内部维护了一个 Message 链表 , 存储的时候只存储第一个 Message 即可 ;
链表插入元素 : 当 Handler 在其它线程调用 sendMessage 方法 , 将 消息 Message 放入 Looper 中的 MessageQueue 时 , 针对该链表的操作就是 , 循环获取链表的下一个元素 , 最终 获取到最后一个元素 , 最后一个元素的 next 为空 ; 将 最后一个元素的 next 设置为本次要插入的 Message , 即可完成消息存储到消息队列的操作 ;
链表元素同步 : 链表为空时 , 取出链表的操作会阻塞 , 调用的是 wait 方法 , 此时有消息加入链表后 , 需要 调用 notify 唤醒阻塞 ;
消息入队的部分代码 :
代码语言：javascript复制 /**
* 该队列是一个链表 , 因此这里只给出第一个 Message 即可
*/
Message mMessage;
/**
* 将 Message 消息加入到 Message 链表中
* @param msg
*/
public void enqueueMessage( Message msg ){
// 因为 该消息队列 可能会有多个线程 通过 Handler 向消息队列中添加消息
// 因此 需要使用同步代码块包裹以下逻辑
synchronized (this){
if( mMessage == null ){
mMessage = msg;
}else{
/*
如果链表不为空
这里需要循环查找消息队列的最后一个消息
将本次传入的 Message msg 参数加入到链表尾部
*/
Message pointer = mMessage;
Message previous = pointer;
for(;;){
// 记录上一条消息, 每次遍历都将本次遍历的记录下来
previous = pointer;
// 将 pointer 指向下一条消息
pointer = pointer.next;
// 此时如果某个 Message 的 下一个元素为空
// 说明该 Message 是消息队列最后一个元素
if(pointer == null){
break;
}
}
// 将本次参数传入的 Message 放到链表最后
previous.next = msg;
}
notify();
}
}二、MessageQueue 消息队列取出消息
Looper 调用 loop 方法后 , 会一直循环 , 不断地从 消息队列 MessageQueue 中取出 Message 消息 , 然后 将 Message 消息发送给对应的 Handler 执行对应的操作 ;
从 消息队列 MessageQueue 中取出消息 , 也是 取出链表表头 的操作 , 取出该链表的表头 , 然后 将表头设置成链表的第二个元素 ;
消息同步 : 如果当前链表为空 , 此时会 调用 wait 方法阻塞 , 直到消息入队时 , 链表中有了元素 , 会调用 notify 解除该阻塞 ;
代码语言：javascript复制 /**
* 从消息队列中获取消息
* @return
*/
public Message next(){
synchronized (this){
// 本次要获取的消息, 最后要返回到 Looper 中 loop 方法中
Message result;
for (;;){
// 尝试和获取 消息队列 链表中的第一个元素
result = mMessage;
if(result == null){
// 如果当前的 Message 队列为空 , 阻塞等待 , 直到新的消息到来
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}else{
// 如果不为空 , 说明已经获取到最终的消息 , 退出循环即可
break;
}
}
// 处理链表逻辑 , 将表头指向下一个 Message
mMessage = mMessage.next;
return result;
}
}三、消息队列完整代码
package kim.hsl.handler;
public class MessageQueue {
/**
* 该队列是一个链表 , 因此这里只给出第一个 Message 即可
*/
Message mMessage;
/**
* 将 Message 消息加入到 Message 链表中
* @param msg
*/
public void enqueueMessage( Message msg ){
// 因为 该消息队列 可能会有多个线程 通过 Handler 向消息队列中添加消息
// 因此 需要使用同步代码块包裹以下逻辑
synchronized (this){
if( mMessage == null ){
mMessage = msg;
}else{
/*
如果链表不为空
这里需要循环查找消息队列的最后一个消息
将本次传入的 Message msg 参数加入到链表尾部
*/
Message pointer = mMessage;
Message previous = pointer;
for(;;){
// 记录上一条消息, 每次遍历都将本次遍历的记录下来
previous = pointer;
// 将 pointer 指向下一条消息
pointer = pointer.next;
// 此时如果某个 Message 的 下一个元素为空
// 说明该 Message 是消息队列最后一个元素
if(pointer == null){
break;
}
}
// 将本次参数传入的 Message 放到链表最后
previous.next = msg;
}
notify();
}
}
/**
* 从消息队列中获取消息
* @return
*/
public Message next(){
synchronized (this){
// 本次要获取的消息, 最后要返回到 Looper 中 loop 方法中
Message result;
for (;;){
// 尝试和获取 消息队列 链表中的第一个元素
result = mMessage;
if(result == null){
// 如果当前的 Message 队列为空 , 阻塞等待 , 直到新的消息到来
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}else{
// 如果不为空 , 说明已经获取到最终的消息 , 退出循环即可
break;
}
}
// 处理链表逻辑 , 将表头指向下一个 Message
mMessage = mMessage.next;
return result;
}
}
}
