Handler

public Handler(@Nullable Callback callback, boolean async) {
    mLooper = Looper.myLooper();
    if (mLooper == null) {
        throw new RuntimeException(
            "Can't create handler inside thread " + Thread.currentThread()
                    + " that has not called Looper.prepare()");
    }
    mQueue = mLooper.mQueue;
    mCallback = callback;
    mAsynchronous = async;
}
  • 創(chuàng)建handler會獲取looper對象
public static @Nullable Looper myLooper() {
    return sThreadLocal.get();
}
public T get() {
    Thread t = Thread.currentThread();
    ThreadLocalMap map = getMap(t);
    if (map != null) {
        ThreadLocalMap.Entry e = map.getEntry(this);
        if (e != null) {
            @SuppressWarnings("unchecked")
            T result = (T)e.value;
            return result;
        }
    }
    return setInitialValue();
}
ThreadLocalMap getMap(Thread t) {
    return t.threadLocals;
}
  • looper從ThreadlocalMap中獲取拘哨,ThreadLocalMap通過Thread的一個成員變量threadLocals賦值,內(nèi)部維護(hù)了一個Entry數(shù)組,存儲了對應(yīng)的ThreadLocal和Looper對象撇寞,根據(jù)Threadlocal獲取對應(yīng)的Looper對象绍撞。
  • ThreadLocal可以當(dāng)做是ThreadlocalMap的包裝類,提供get()和set()
private static void prepare(boolean quitAllowed) {
    if (sThreadLocal.get() != null) {
        throw new RuntimeException("Only one Looper may be created per thread");
    }
    sThreadLocal.set(new Looper(quitAllowed));
}
public void set(T value) {
    Thread t = Thread.currentThread();
    ThreadLocalMap map = getMap(t);
    if (map != null)
        map.set(this, value);
    else
        createMap(t, value);
}
public static void main(String[] args) {
    Looper.prepareMainLooper();
    ActivityThread thread = new ActivityThread();
    thread.attach(false, startSeq);

    if (sMainThreadHandler == null) {
        sMainThreadHandler = thread.getHandler();
    }

    if (false) {
        Looper.myLooper().setMessageLogging(new
                LogPrinter(Log.DEBUG, "ActivityThread"));
    }
    Looper.loop();

    throw new RuntimeException("Main thread loop unexpectedly exited");
}
  • 在Looper.prepare()中創(chuàng)建Looper對象蜻韭,并從當(dāng)前Thread中將ThreadLocal和創(chuàng)建的Looper對象存儲進(jìn)ThreadLocalMap對象悼尾。在主線程中不需要執(zhí)行prepare()方法是因為在ActivityThread的main()中已經(jīng)執(zhí)行了
private Looper(boolean quitAllowed) {
    mQueue = new MessageQueue(quitAllowed);
    mThread = Thread.currentThread();
}
  • 在創(chuàng)建Looper對象時,會創(chuàng)建MessageQueue對象肖方。所以一個線程對應(yīng)一個Looper闺魏,對應(yīng)一個MessageQueue
handler.sendMessage()
handler.sendMessageAtTime()
handler.sendMessageDelayed()
  • 幾種發(fā)送消息的方法,最后都會走到sendMessageAtTime(Message msg, long delayMillis)方法中俯画,只是delayMeillis參數(shù)修改
private boolean enqueueMessage(@NonNull MessageQueue queue, @NonNull Message msg,
        long uptimeMillis) {
    msg.target = this;
    msg.workSourceUid = ThreadLocalWorkSource.getUid();

    if (mAsynchronous) {
        msg.setAsynchronous(true);
    }
    return queue.enqueueMessage(msg, uptimeMillis);
}
  • 發(fā)送消息時會將msg.targe賦值為當(dāng)前的handler析桥,后續(xù)分發(fā)消息時也是通過該標(biāo)志,找到對應(yīng)的handler
boolean enqueueMessage(Message msg, long when) {
    synchronized (this) {
        msg.markInUse();
        msg.when = when;
        Message p = mMessages;
        boolean needWake;
        if (p == null || when == 0 || when < p.when) {
            // New head, wake up the event queue if blocked.
            msg.next = p;
            mMessages = msg;
            needWake = mBlocked;
        } else {
            needWake = mBlocked && p.target == null && msg.isAsynchronous();
            Message prev;
            for (;;) {
                prev = p;
                p = p.next;
                if (p == null || when < p.when) {
                    break;
                }
                if (needWake && p.isAsynchronous()) {
                    needWake = false;
                }
            }
            msg.next = p; // invariant: p == prev.next
            prev.next = msg;
        }
    }
    return true;
}
  • MessageQueue是一個鏈表結(jié)構(gòu)艰垂,根據(jù)delay的時間來修改next指向烹骨。以上是往消息隊列中添加消息的流程
for (;;) {
    Message msg = queue.next();
}
  • 通過Looper.loop()方法取出消息,該方法是一個死循環(huán)材泄,通過next()方法獲取下一個需要處理的消息
for (;;) {
    if (nextPollTimeoutMillis != 0) {
        Binder.flushPendingCommands();
    }

    nativePollOnce(ptr, nextPollTimeoutMillis);  //nextPollTimeoutMillis 0立即返回  -1 一直阻塞  >0 阻塞時長
if (msg != null) {
    if (now < msg.when) {
        // Next message is not ready.  Set a timeout to wake up when it is ready.
        nextPollTimeoutMillis = (int) Math.min(msg.when - now, Integer.MAX_VALUE);
    } else {
        // Got a message.
        mBlocked = false;
        if (prevMsg != null) {
            prevMsg.next = msg.next;
        } else {
            mMessages = msg.next;
        }
        msg.next = null;
        if (DEBUG) Log.v(TAG, "Returning message: " + msg);
        msg.markInUse();
        return msg;
    }
} else {
    // No more messages.
    nextPollTimeoutMillis = -1;
}
  • 獲取消息沮焕,通過nativePollOnce設(shè)置阻塞狀態(tài),假如下一消息時間未到則阻塞等待的時長拉宗,假如沒有沒有消息則傳入-1峦树,一直阻塞。喚醒會通過添加消息enqueueMessage()#nativeWake()旦事,或者quit()#nativeWake()
msg.target.dispatchMessage(msg);
public void dispatchMessage(@NonNull Message msg) {
    if (msg.callback != null) {
        handleCallback(msg);
    } else {
        if (mCallback != null) {
            if (mCallback.handleMessage(msg)) {
                return;
            }
        }
        handleMessage(msg);
    }
}
  • 取出消息后通過handler#dispatchMessage()進(jìn)行分發(fā)魁巩,并根據(jù)handler創(chuàng)建的方式回調(diào)到對應(yīng)的位置
public final void runOnUiThread(Runnable action) {
    if (Thread.currentThread() != mUiThread) {
        mHandler.post(action);
    } else {
        action.run();
    }
}
public final boolean post(@NonNull Runnable r) {
   return  sendMessageDelayed(getPostMessage(r), 0);
}
  • runOnUiThread使用的也是handler的方法,在非UI線程時姐浮,取主線程的handler谷遂。在子線程中發(fā)送消息,最后會將消息發(fā)送到handler對應(yīng)的messageQueue中卖鲤,再通過Loop()方法去除消息處理肾扰,而Looper.loop()方法是在主線程中啟動的,所以線程切換到主線程
public final boolean postDelayed(
        @NonNull Runnable r, @Nullable Object token, long delayMillis) {
    return sendMessageDelayed(getPostMessage(r, token), delayMillis);
}
  • 至于其他的postDelayed()方法原理都類似
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末蛋逾,一起剝皮案震驚了整個濱河市集晚,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌区匣,老刑警劉巖偷拔,帶你破解...
    沈念sama閱讀 218,607評論 6 507
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異,居然都是意外死亡莲绰,警方通過查閱死者的電腦和手機欺旧,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,239評論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來蛤签,“玉大人切端,你說我怎么就攤上這事∏晏洌” “怎么了踏枣?”我有些...
    開封第一講書人閱讀 164,960評論 0 355
  • 文/不壞的土叔 我叫張陵,是天一觀的道長钙蒙。 經(jīng)常有香客問我茵瀑,道長,這世上最難降的妖魔是什么躬厌? 我笑而不...
    開封第一講書人閱讀 58,750評論 1 294
  • 正文 為了忘掉前任马昨,我火速辦了婚禮,結(jié)果婚禮上扛施,老公的妹妹穿的比我還像新娘鸿捧。我一直安慰自己,他們只是感情好疙渣,可當(dāng)我...
    茶點故事閱讀 67,764評論 6 392
  • 文/花漫 我一把揭開白布匙奴。 她就那樣靜靜地躺著,像睡著了一般妄荔。 火紅的嫁衣襯著肌膚如雪泼菌。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,604評論 1 305
  • 那天啦租,我揣著相機與錄音哗伯,去河邊找鬼。 笑死篷角,一個胖子當(dāng)著我的面吹牛焊刹,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播恳蹲,決...
    沈念sama閱讀 40,347評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼虐块,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了阱缓?” 一聲冷哼從身側(cè)響起非凌,我...
    開封第一講書人閱讀 39,253評論 0 276
  • 序言:老撾萬榮一對情侶失蹤举农,失蹤者是張志新(化名)和其女友劉穎荆针,沒想到半個月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,702評論 1 315
  • 正文 獨居荒郊野嶺守林人離奇死亡航背,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,893評論 3 336
  • 正文 我和宋清朗相戀三年喉悴,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片玖媚。...
    茶點故事閱讀 40,015評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡箕肃,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出今魔,到底是詐尸還是另有隱情勺像,我是刑警寧澤,帶...
    沈念sama閱讀 35,734評論 5 346
  • 正文 年R本政府宣布错森,位于F島的核電站吟宦,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏涩维。R本人自食惡果不足惜殃姓,卻給世界環(huán)境...
    茶點故事閱讀 41,352評論 3 330
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望瓦阐。 院中可真熱鬧蜗侈,春花似錦、人聲如沸睡蟋。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,934評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽戳杀。三九已至叫倍,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間豺瘤,已是汗流浹背吆倦。 一陣腳步聲響...
    開封第一講書人閱讀 33,052評論 1 270
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留坐求,地道東北人蚕泽。 一個月前我還...
    沈念sama閱讀 48,216評論 3 371
  • 正文 我出身青樓,卻偏偏與公主長得像桥嗤,于是被迫代替她去往敵國和親须妻。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 44,969評論 2 355

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