當一切準備就緒后，Java層的消息循環處理，也就是Looper會在一個循環中提取并處理消息。消息的提取就是調用MessageQueue的next函數。當消息隊列為空時，next就會阻塞。MessageQueue同時支持Java層和Native層的事件，那么其next函數該怎么實現呢？具體代碼如下： **MessagQueue.java** ~~~ final Message next() { intpendingIdleHandlerCount = -1; intnextPollTimeoutMillis = 0; for(;;) { ...... //mPtr保存了NativeMessageQueue的指針，調用nativePollOnce進行等待 nativePollOnce(mPtr, nextPollTimeoutMillis); synchronized (this) { final long now = SystemClock.uptimeMillis(); //mMessages用來存儲消息，這里從其中取一個消息進行處理 final Message msg = mMessages; if (msg != null) { final long when = msg.when; if (now >= when) { mBlocked = false; mMessages = msg.next; msg.next = null; msg.markInUse(); return msg; //返回一個Message給Looper進行派發和處理 } else { nextPollTimeoutMillis =(int) Math.min(when - now, Integer.MAX_VALUE); } } else { nextPollTimeoutMillis = -1; } ...... /* 處理注冊的IdleHandler，當MessageQueue中沒有Message時， Looper會調用IdleHandler做一些工作，例如做垃圾回收等 */ ...... pendingIdleHandlerCount = 0; nextPollTimeoutMillis = 0; } } ~~~ 看到這里，可能會有人覺得這個MessageQueue很簡單，不就是從以前在Java層的wait變成現在Native層的wait了嗎？但是事情本質比表象要復雜得多，來思考下面的情況： - nativePollOnce返回后，next函數將從mMessages中提取一個消息。也就是說，要讓nativePollOnce返回，至少要添加一個消息到消息隊列，否則nativePollOnce不過是做了一次無用功罷了。 - 如果nativePollOnce將在Native層等待，就表明Native層也可以投遞Message，但是從Message類的實現代碼上看，該類和Native層沒有建立任何關系。那么nativePollOnce在等待什么呢？ 對于上面的問題，相信有些讀者心中已有了答案：nativePollOnce不僅在等待Java層來的Message，實際上還在Native還做了大量的工作。 下面我們來分析Java層投遞Message并觸發nativePollOnce工作的正常流程。 1. 在Java層投遞Message MessageQueue的enqueueMessage函數完成將一個Message投遞到MessageQueue中的工作，其代碼如下： **MesssageQueue.java** ~~~ final boolean enqueueMessage(Message msg, longwhen) { ...... final boolean needWake; synchronized (this) { if (mQuiting) { return false; } else if (msg.target == null) { mQuiting = true; } msg.when = when; Message p = mMessages; if (p == null || when == 0 || when < p.when) { /* 如果p為空，表明消息隊列中沒有消息，那么msg將是第一個消息，needWake 需要根據mBlocked的情況考慮是否觸發 */ msg.next = p; mMessages = msg; needWake = mBlocked; } else { //如果p不為空，表明消息隊列中還有剩余消息，需要將新的msg加到消息尾 Message prev = null; while (p != null && p.when <= when) { prev = p; p = p.next; } msg.next = prev.next; prev.next = msg; //因為消息隊列之前還剩余有消息，所以這里不用調用nativeWakeup needWake = false; } } if(needWake) { //調用nativeWake，以觸發nativePollOnce函數結束等待 nativeWake(mPtr); } return true; } ~~~ 上面的代碼比較簡單，主要功能是： - 將message按執行時間排序，并加入消息隊。 - 根據情況調用nativeWake函數，以觸發nativePollOnce函數，結束等待。 * * * * * **建議** 雖然代碼簡單，但是對于那些不熟悉多線程的讀者，還是要細細品味一下mBlocked值的作用。我們常說細節體現美，代碼也一樣，這個小小的mBlocked正是如此。 * * * * * 2. nativeWake函數分析 nativeWake函數的代碼如下所示： **android_os_MessageQueue.cpp** ~~~ static voidandroid_os_MessageQueue_nativeWake(JNIEnv* env, jobject obj, jint ptr) { NativeMessageQueue*nativeMessageQueue = //取出NativeMessageQueue對象 reinterpret_cast<NativeMessageQueue*>(ptr); returnnativeMessageQueue->wake(); //調用它的wake函數 } void NativeMessageQueue::wake() { mLooper->wake();//層層調用，現在轉到mLooper的wake函數 } ~~~ Native Looper的wake函數代碼如下： **Looper.cpp** ~~~ void Looper::wake() { ssize_tnWrite; do { //向管道的寫端寫入一個字符 nWrite = write(mWakeWritePipeFd, "W", 1); } while(nWrite == -1 && errno == EINTR); if(nWrite != 1) { if(errno != EAGAIN) { LOGW("Could not write wake signal, errno=%d", errno); } } } ~~~ wake函數則更為簡單，僅僅向管道的寫端寫入一個字符”W”，這樣管道的讀端就會因為有數據可讀而從等待狀態中醒來。