Handler、MessageQueue胯甩、Looper 之間的關(guān)系

標(biāo)簽(空格分隔): android


前言

最近學(xué)習(xí) ios昧廷,發(fā)現(xiàn) ios 的 NSlopper 跟 Android 的 Looper 非常相似,于是就突然很想再學(xué)習(xí)一片 android 的 Looper蜡豹。

三者之間的關(guān)系

先看看大致的圖片(有點(diǎn)丑麸粮,請(qǐng)將就):
image_1aq6oq5uf1ihd123n1ape13dt1h2d9.png-51.4kB
image_1aq6oq5uf1ihd123n1ape13dt1h2d9.png-51.4kB

Handler:就是處理者,他通過方法sendEmptyMessage(int what)或sendMessage(Message msg)或sendMessageAtTime(Message msg, long uptimeMillis)等方法(想知道更多方法镜廉,自己在 as 下敲 send 就可以看到了)給 messageQueue 發(fā)送消息弄诲。
MessageQueue:就是消息隊(duì)列(其實(shí)該類是通過鏈表實(shí)現(xiàn)的),handler 給里面發(fā)送消息,Looper 在里面拿消息齐遵。
Looper 循環(huán)者 就是不停循環(huán) MessageQueue寂玲,在里面拿消息。
這是他們之間的具體作用梗摇,下面分析具體的流程

Looper

首先我們從 Looper 說起拓哟,先看看 Looper 的 prepare() 方法。

public static final void prepare() {  
    if (sThreadLocal.get() != null) {  
        throw new RuntimeException("Only one Looper may be created per thread");  
    }  
    sThreadLocal.set(new Looper());  
}  

上面出現(xiàn)了一個(gè)sThreadLocal伶授,這個(gè)是一個(gè)ThreadLocal類型的變量断序,可以用該類保存數(shù)據(jù),但是作用域是相對(duì)于線程來言的糜烹。那么這段代碼的意義就是一個(gè)線程最多只能有一個(gè) Looper违诗。我們?cè)倏纯?Looper 是怎么創(chuàng)建的:

private Looper() {  
    mQueue = new MessageQueue();  
    mRun = true;  
    mThread = Thread.currentThread();  
} 

可以看到 Looper 是持有一個(gè) MessageQueue 對(duì)象的,也持有一個(gè)當(dāng)前線程的引用(調(diào)用 prepare 的地方的線程)疮蹦。這段代碼的意義就是一個(gè)Looper 擁有一個(gè)MeesageQueue诸迟,那么就是一個(gè)線程,一個(gè) Looper愕乎,一個(gè) MessageQueue阵苇,再看看 Looper 的 loop()方法。

/**
     * Run the message queue in this thread. Be sure to call
     * {@link #quit()} to end the loop.
     */
    public static void loop() {
        final Looper me = myLooper();
        if (me == null) {
            throw new RuntimeException("No Looper; Looper.prepare() wasn't called on this thread.");
        }
        final MessageQueue queue = me.mQueue;

        // Make sure the identity of this thread is that of the local process,
        // and keep track of what that identity token actually is.
        Binder.clearCallingIdentity();
        final long ident = Binder.clearCallingIdentity();

        for (;;) {
            Message msg = queue.next(); // might block
            if (msg == null) {
                // No message indicates that the message queue is quitting.
                return;
            }

            // This must be in a local variable, in case a UI event sets the logger
            Printer logging = me.mLogging;
            if (logging != null) {
                logging.println(">>>>> Dispatching to " + msg.target + " " +
                        msg.callback + ": " + msg.what);
            }

            msg.target.dispatchMessage(msg);

            if (logging != null) {
                logging.println("<<<<< Finished to " + msg.target + " " + msg.callback);
            }

            // Make sure that during the course of dispatching the
            // identity of the thread wasn't corrupted.
            final long newIdent = Binder.clearCallingIdentity();
            if (ident != newIdent) {
                Log.wtf(TAG, "Thread identity changed from 0x"
                        + Long.toHexString(ident) + " to 0x"
                        + Long.toHexString(newIdent) + " while dispatching to "
                        + msg.target.getClass().getName() + " "
                        + msg.callback + " what=" + msg.what);
            }

            msg.recycleUnchecked();
        }
    }

1.在第9行可以拿到自己的 MessageQueue
2.17到46行:就進(jìn)入了死循環(huán)了感论。
3.18行取出消息退列的最前的一條消息绅项,可以看到注解的 might block ,意思就是沒有消息的時(shí)候會(huì)堵塞笛粘。
4.23行msg.target.dispatchMessage(msg); msg變量的類型是Message趁怔,msg.target的類型是Handler湿硝。其實(shí)就是分發(fā) message 回調(diào)給用戶處理薪前,等等詳細(xì)介紹1
5.每處理完該消息后关斜,調(diào)用msg.recycle()回收該Message對(duì)象占用的系統(tǒng)資源示括。

好了,Looper 大概流程基本完成×⌒螅現(xiàn)在來看看 MessageQueue 的作用垛膝。

MessageQueue

隊(duì)列,先進(jìn)先出丁稀,里面裝著一堆 Message 類型的變量吼拥。MessageQueue最重要的兩個(gè)函數(shù)是是next()和enquenceMessage(),分別是“取出消息”和“添加消息”到隊(duì)列中线衫。具體代碼有點(diǎn)復(fù)雜凿可,不貼出來,想知道的請(qǐng)自己看源碼= =。

Handler

我們會(huì)調(diào)用 handler的 sendEmptyMessage(int what)或sendMessage(Message msg) 方法來把 Message 添加到 MessageQueue 隊(duì)列中枯跑。

public final boolean sendMessage(Message msg)
{
    return sendMessageDelayed(msg, 0);
}

public final boolean sendEmptyMessage(int what)
{
    return sendEmptyMessageDelayed(what, 0);
}

public final boolean sendEmptyMessageDelayed(int what, long delayMillis) {
    Message msg = Message.obtain();
    msg.what = what;
    return sendMessageDelayed(msg, delayMillis);
}

public final boolean sendEmptyMessageAtTime(int what, long uptimeMillis) {
    Message msg = Message.obtain();
    msg.what = what;
    return sendMessageAtTime(msg, uptimeMillis);
}

public final boolean sendMessageDelayed(Message msg, long delayMillis)
{
    if (delayMillis < 0) {
        delayMillis = 0;
    }
    return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis);
}

public boolean sendMessageAtTime(Message msg, long uptimeMillis) {
    MessageQueue queue = mQueue;
    if (queue == null) {
        RuntimeException e = new RuntimeException(
                this + " sendMessageAtTime() called with no mQueue");
        Log.w("Looper", e.getMessage(), e);
        return false;
    }
    return enqueueMessage(queue, msg, uptimeMillis);
}

private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) {  
       msg.target = this;  
       if (mAsynchronous) {  
           msg.setAsynchronous(true);  
       }  
       return queue.enqueueMessage(msg, uptimeMillis);  
   }  

從上面代碼看到惨驶,無論哪個(gè)方法最終都會(huì)調(diào)用sendMessageAtTime(Message msg, long uptimeMillis) 這個(gè)方法×仓看看第39行粗卜,enqueueMessage(queue, msg, uptimeMillis),再調(diào)用到47行;這就是往MessageQueue中添加 Message纳击。

好了上面流程就是 handler->sendMessage->messsageQueue->looper,就差異步 looper 回掉給 Handler 的處理续扔,在上面1已經(jīng)說了,是利用 Looper 中 loop() 方法遍歷消息焕数,然后當(dāng)獲得消息后調(diào)用 msg.target.dispatchMessage(msg); msg變量的類型是Message测砂,msg.target的類型是Handler,就是調(diào)用 Handler 的 dispatchMessage() 百匆。那么看看 dispatchMessage() 代碼砌些。

/**
 * Handle system messages here.
 */
public final boolean post(Runnable r)  {  
  return  sendMessageDelayed(getPostMessage(r), 0);  
}  

private static Message getPostMessage(Runnable r) {  
  Message m = Message.obtain();  
  m.callback = r;  
  return m;  
}  

public void dispatchMessage(Message msg) {
    if (msg.callback != null) {
        msg.callback.run();
    } else {
        if (mCallback != null) {
            if (mCallback.handleMessage(msg)) {
                return;
            }
        }
        handleMessage(msg);
    }
}

第6行,這個(gè) msg.callback 就是我們 message 的 callback加匈,當(dāng)我們調(diào)用mHandler.post(Runnable r); 時(shí)候會(huì)給當(dāng)前 looper 的 message 賦值 runnable存璃,所以最終收到消息后就會(huì)調(diào)用改 runnable 方法。
第18行雕拼,mCallback 是在 new Handler 的時(shí)候指定的纵东,具體方法是public Handler(Callback callback, boolean async)。如果傳入為空啥寇,則我們就跑自身的 handleMessage(msg)方法偎球,就會(huì)調(diào)用我們自定義的實(shí)現(xiàn),就是我們常寫的方式辑甜。代碼:

private Handler mHandler = new Handler() {  
    public void handleMessage(android.os.Message msg)  
    {  
        switch (msg.what)  
        {  
        case value:  
              
            break;  

        default:  
            break;  
        }  
    };  
};  

好了衰絮,大概流程就這樣子,可以再看看這副簡陋的圖再聯(lián)想一下流程:


image_1aq6oq5uf1ihd123n1ape13dt1h2d9.png-51.4kB
image_1aq6oq5uf1ihd123n1ape13dt1h2d9.png-51.4kB

磷醋。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末猫牡,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子邓线,更是在濱河造成了極大的恐慌淌友,老刑警劉巖,帶你破解...
    沈念sama閱讀 212,454評(píng)論 6 493
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件骇陈,死亡現(xiàn)場(chǎng)離奇詭異震庭,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)你雌,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,553評(píng)論 3 385
  • 文/潘曉璐 我一進(jìn)店門器联,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人,你說我怎么就攤上這事主籍∠捌叮” “怎么了?”我有些...
    開封第一講書人閱讀 157,921評(píng)論 0 348
  • 文/不壞的土叔 我叫張陵千元,是天一觀的道長苫昌。 經(jīng)常有香客問我,道長幸海,這世上最難降的妖魔是什么祟身? 我笑而不...
    開封第一講書人閱讀 56,648評(píng)論 1 284
  • 正文 為了忘掉前任,我火速辦了婚禮物独,結(jié)果婚禮上袜硫,老公的妹妹穿的比我還像新娘。我一直安慰自己挡篓,他們只是感情好婉陷,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,770評(píng)論 6 386
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著官研,像睡著了一般秽澳。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上戏羽,一...
    開封第一講書人閱讀 49,950評(píng)論 1 291
  • 那天担神,我揣著相機(jī)與錄音,去河邊找鬼始花。 笑死妄讯,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的酷宵。 我是一名探鬼主播亥贸,決...
    沈念sama閱讀 39,090評(píng)論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼忧吟!你這毒婦竟也來了砌函?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 37,817評(píng)論 0 268
  • 序言:老撾萬榮一對(duì)情侶失蹤溜族,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后垦沉,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體煌抒,經(jīng)...
    沈念sama閱讀 44,275評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,592評(píng)論 2 327
  • 正文 我和宋清朗相戀三年厕倍,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了寡壮。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 38,724評(píng)論 1 341
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖况既,靈堂內(nèi)的尸體忽然破棺而出这溅,到底是詐尸還是另有隱情,我是刑警寧澤棒仍,帶...
    沈念sama閱讀 34,409評(píng)論 4 333
  • 正文 年R本政府宣布悲靴,位于F島的核電站,受9級(jí)特大地震影響莫其,放射性物質(zhì)發(fā)生泄漏癞尚。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 40,052評(píng)論 3 316
  • 文/蒙蒙 一乱陡、第九天 我趴在偏房一處隱蔽的房頂上張望浇揩。 院中可真熱鬧,春花似錦憨颠、人聲如沸胳徽。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,815評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽膜廊。三九已至,卻和暖如春淫茵,著一層夾襖步出監(jiān)牢的瞬間爪瓜,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,043評(píng)論 1 266
  • 我被黑心中介騙來泰國打工匙瘪, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留铆铆,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 46,503評(píng)論 2 361
  • 正文 我出身青樓丹喻,卻偏偏與公主長得像薄货,于是被迫代替她去往敵國和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子碍论,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,627評(píng)論 2 350

推薦閱讀更多精彩內(nèi)容