Handler Looper MessageQueue 源码分析
概述
Handler是Android常见的线程间通讯工具,特别是Android UI的主线程的消息循环,下文对Handler,Looper,MessageQueue 的Java和native代码做一个分析,以此加深对Android的消息模型的认识。
Looper
Looper主要是prepare()和loop()方法。
prepare()为当前线程创建新的Looper对象,存储在ThreadLocal变量里。
![](https://img.haomeiwen.com/i5320791/dc3001c03fdf2118.png)
Looper会创建Java对象MessageQueue,MessageQueue又会调用native方法nativeInit创建NativeMessageQueue对象,mPtr存储是NativeMessageQueue的地址,nativeInit代码在frameworks/base/core/jni/android_os_MessageQueue.cpp
![](https://img.haomeiwen.com/i5320791/616ba76afa60e648.png)
![](https://img.haomeiwen.com/i5320791/c3d407237bca8c13.png)
![](https://img.haomeiwen.com/i5320791/3079d0bbd04eb3c7.png)
NativeMessageQueue构造函数中回调用Native的Looper::getForThread();获取当前线程的native Looper对象,没有就创建新的,Looper代码在/system/core/libutils/Looper.cpp中。
关键的代码都在Looper的构造函数中:
1.mWakeEventFd=eventfd(0,EFD_NONBLOCK),创建文件描述符。( Linux下的eventfd)
2.调用rebuildEpollLocked(),使用epoll监听mWakeEventFd的写入事件。(Epoll)
![](https://img.haomeiwen.com/i5320791/548301ecd6e1bc42.png)
![](https://img.haomeiwen.com/i5320791/a8dfc984f14d1779.png)
![](https://img.haomeiwen.com/i5320791/7f2f8bde309be673.png)
调用loop()方法,线程会进入死循环,循环中调用Looper.mQueue的next()方法,也就是MessageQueue的next()方法,获取最新的msg,在调用msg.target.dispatchMessage(msg)方法来处理msg,msg的target就是发送msg的Handler对象。
![](https://img.haomeiwen.com/i5320791/fa881fc24f0ef21c.png)
MessageQueue.next()方法也是个死循环,先调用native方法 nativePollOnce(ptr, nextPollTimeoutMillis),再调用NativeMessageQueue的pollOnce方法,方法中调用native Looper都像的pollOnce方法,方法中调用Looper.pollInner方法,其中的关键方法代码是:
![](https://img.haomeiwen.com/i5320791/a9e0e2c134931a75.png)
epoll_wait的作用如下:
int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
epfd为用epoll_create创建之后的句柄,events是一个epoll_event*的指针,当epoll_wait这个函数操作成功之后,epoll_events里面将储存所有的读写事件。max_events是当前需要监听的所有fd。最后一个timeout是 epoll_wait的超时,为0的时候表示马上返回,为-1的时候表示一直等下去,直到有事件范围,为任意正整数的时候表示等这么长的时间,如果一直没有事件,则范围。一般如果网络主循环是单独的线程的话,可以用-1来等,这样可以保证一些效率,如果是和主逻辑在同一个线程的话,则可以用0来保证主循环的效率。
如果epoll_wait返回,就开始处理返回事件:
![](https://img.haomeiwen.com/i5320791/ab061a77e4ccb117.png)
如果有写入事件的fd是nativeInit中创建的mWakeEventFd,就调用awoken()方法,如果是其他fd,就调用pushResponse()方法,aoken()就只是从fd都8个字节数据。
![](https://img.haomeiwen.com/i5320791/fed902b9bbf489ab.png)
这时候java代码已经执行完nativePollOnce(ptr, nextPollTimeoutMillis),方法开始往下执行。
![](https://img.haomeiwen.com/i5320791/9c43c8f8b74fb423.png)
java对mMessages开始处理,mMessages本质上是一个链表中的head对象,当前mMessages对象是否是同步屏障,如果是,就找后面的异步消息,不是直接使用当前消息,判断msg的应该执行的时间是否在当前时间之前如果不是就继续等待一段时间,如果是返回消息,mMessages设为找到的消息。
到此消息的通知和处理就结束了,下面分析Handler。
Handler
1.创建Handler
![](https://img.haomeiwen.com/i5320791/e4459216136601fc.png)
Handler需要一个Looper来创建,如果不传递传递Looper会调用Looper.myLooper(),如果当前线程没有Looper就会报错,所以必须在new Handler()之前调用Looper.prepare()。
Handler发送消息
Handler发送消息调用 sendMessageAtTime()->enqueueMessage()->MessageQueue.enqueueMessage()
![](https://img.haomeiwen.com/i5320791/9813f72a774a81cf.png)
![](https://img.haomeiwen.com/i5320791/45e0f6ab27d95448.png)
根据msg.when,msg应该的发生时间,把msg插入到mMessages的链表对用的位置中,在调用nativeWake方法。
boolean enqueueMessage(Message msg, long when)
![](https://img.haomeiwen.com/i5320791/f663e459f7cc2bcb.png)
nativeWake()->NativeMessageQueue.wake方法,调用Looper->wake()方法,向mWakeEventFd写入8字节数据,此时epoll_wait停止阻塞,执行下面语句。
![](https://img.haomeiwen.com/i5320791/550aa630fbe6b14e.png)
总结
Handler Java层的消息模型类试于线程的wait/notify模型,msg数据只在Java层传递,而Android是使用epoll实现,epoll本适合大量fd,只有少量fd激活的Idle场景,Handler Java层的线程通信,也只使用了线程的阻塞和唤起机制,而epoll几个api都是系统调用,看上去性能并不如直接使用Java的BlockingQueue。Android的主线程为啥还使用Handler来进行线程间通信呢,其实Android 主线程除了处理Java 层消息还需要处理Input和Vsync事件的响应,这些消息都是直接发送到主线程的native的Looper中,Handler这样的实现就很符合主线程的场景,存粹从Java层的线程间消息通知机制来说,Handler并不比BlockingQueue这样的实现性能更高。