2024年4月1日发(作者：)
1.活用Android线程间通信的Message机制
e
代码在中。
函数：有多个obtain函数，主要功能一样，只是参数不一样。作用是从Message Pool中
取出一个Message，如果Message Pool中已经没有Message可取则新建一个Message返回，同时用对
应的参数给得到的Message对象赋值。
Message Pool：大小为10个；通过->（Message并且）-> （Message
并且）-> （Message并且）...构造一个Message Pool。Message Pool的
第一个元素直接new出来，然后把（static类的static变量）指向它。其他的元素都是使
用完的 Message通过Message的recycle函数清理后放到Message Pool（通过Message Pool最后一个
Message的next指向需要回收的Message的方式实现）。下图为Message Pool的结构：
eQueue
MessageQueue里面有一个收到的Message的对列：
ges(static变量)->( Message并且)-> ( Message并且
)->...，下图为接收消息的消息队列：
上层代码通过Handler的sendMessage等函数放入一个message到MessageQueue里面时最终会调用
MessageQueue的 enqueueMessage函数。enqueueMessage根据上面的接收的Message的队列的构
造把接收到的Message放入队列中。
MessageQueue的removeMessages函数根据上面的接收的Message的队列的构造把接收到的Message
从队列中删除，并且调用对应Message对象的recycle函数把不用的Message放入Message Pool中。
Looper对象的创建是通过prepare函数，而且每一个Looper对象会和一个线程关联
Java代码
1.
2.
3.
4.
5.
6.
public static final void prepare() {
if (() != null) {
throw new RuntimeException("Only one Looper may be created per thread");
}
(new Looper());
}
Looper对象创建时会创建一个MessageQueue，主线程默认会创建一个Looper从而有MessageQueue，
其他线程默认是没有 MessageQueue的不能接收Message，如果需要接收Message则需要通过prepare
函数创建一个MessageQueue。具体操作请见示例代码。
Java代码
1.
2.
3.
4.
5.
private Looper() {
mQueue = new MessageQueue();
mRun = true;
mThread = tThread();
}
prepareMainLooper函数只给主线程调用（系统处理，程序员不用处理），它会调用prepare建立Looper
对象和MessageQueue。
Java代码
1.
2.
3.
4.
5.
6.
7.
public static final void prepareMainLooper() {
prepare();
setMainLooper(myLooper());
if (tsProcesses()) {
myLooper().llowed = false;
}
}
Loop函数从MessageQueue中从前往后取出Message，然后通过Handler的dispatchMessage函数进行
消息的处理（可见消息的处理是Handler负责的），消息处理完了以后通过Message对象的recycle函数
放到Message Pool中，以便下次使用，通过Pool的处理提供了一定的内存管理从而加速消息对象的获取。
至于需要定时处理的消息如何做到定时处理，请见 MessageQueue的next函数，它在取Message来进
行处理时通过判断MessageQueue里面的Message是否符合时间要求来决定是否需要把Message取出
来做处理，通过这种方式做到消息的定时处理。
Java代码
1.
2.
3.
4.
5.
6.
7.
8.
9.
public static final void loop() {
Looper me = myLooper();
MessageQueue queue = ;
while (true) {
Message msg = (); // might block
//if (!) {
// break;
//}
if (msg != null) {
发布评论