快捷導(dǎo)航

Android線程間通信Handler源碼詳解

更新時(shí)間：2022年10月20日 14:28:18 作者：Quincy_Ye

這篇文章主要為大家介紹了Android線程間通信Handler源碼示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

在【Android】線程間通信 - Handler之使用篇主要講了 Handler 的創(chuàng)建，發(fā)送消息，處理消息 三個(gè)步驟。那么接下來(lái)，我們也按照這三個(gè)步驟，從源碼中去探析一下它們具體是如何實(shí)現(xiàn)的。本篇是關(guān)于創(chuàng)建源碼的分析。

01、用法

先回顧一下，在主線程和非主線程是如何創(chuàng)建 Handler 的。

//主線程
private val mHandler: Handler = object : Handler(Looper.getMainLooper()) {
    override fun handleMessage(msg: Message) {
        when (msg.what) {
            1 -> {}
        }
    }
}

//子線程
Thread {
    Looper.prepare()
    val handler = object : Handler() {
        override fun handleMessage(msg: Message) {
            when (msg.what) {
                1 -> {}
            }
        }
    }
    handler.sendEmptyMessage(1)
    Looper.loop()
}.start()

02、源碼

Handler 一共有 7 個(gè)構(gòu)造方法。但最后都會(huì)直接或間接使用到以下兩個(gè)構(gòu)造方法。所以我們看看兩個(gè)方法都做了什么事情吧。

//方法 1
//Handler.java
public Handler(@Nullable Callback callback, boolean async) {
    if (FIND_POTENTIAL_LEAKS) {
        final Class<? extends Handler> klass = getClass();
        if ((klass.isAnonymousClass() || klass.isMemberClass() || klass.isLocalClass()) &&
                (klass.getModifiers() & Modifier.STATIC) == 0) {
            Log.w(TAG, "The following Handler class should be static or leaks might occur: " +
                klass.getCanonicalName());
        }
    }
    mLooper = Looper.myLooper(); \\標(biāo)識(shí) 1
    if (mLooper == null) { \\ 標(biāo)識(shí) 3
        throw new RuntimeException(
            "Can't create handler inside thread " + Thread.currentThread()
                    + " that has not called Looper.prepare()");
    }
    mQueue = mLooper.mQueue; \\標(biāo)識(shí) 2
    mCallback = callback;
    mAsynchronous = async;
}
//方法 2
public Handler(@NonNull Looper looper, @Nullable Callback callback, boolean async) {
    mLooper = looper;
    mQueue = looper.mQueue;
    mCallback = callback;
    mAsynchronous = async;
}

方法 2 更加的簡(jiǎn)單，那么我們就從它入手吧。在其中對(duì) 4 個(gè)變量進(jìn)行賦值。分別是 mLooper, mQueue, mCallback, mAsynchronous。方法 1 主要也是對(duì) 4 個(gè)變量進(jìn)行賦值。它們有什么作用，我們先不管，后面會(huì)講到。我們先來(lái)看看這方法 1 和方法 2 的區(qū)別是什么？

讓我們聚焦到標(biāo)識(shí) 1 和標(biāo)識(shí) 2，mLooper, mQueue 來(lái)源是通過(guò) Looper 這個(gè)類中獲取的。那讓我們跟進(jìn)去看看。

//跟進(jìn)標(biāo)識(shí) 1
//Looper.java
public static @Nullable Looper myLooper() {
   return sThreadLocal.get();
}

看到是通過(guò) mThreadLocal.get() 獲得一個(gè) Looper 實(shí)例。那么 mThreadLocal 的 Looper 又是哪里來(lái)的呢？讓我們找找 mThreadLocal.set() 方法，就知道了！

//Looper.java
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));
}

原來(lái)是在 Looper.prepare() 中添加的。

這里需要注意！

"Only one Looper may be created per thread"，每個(gè)線程只能調(diào)用一次 prepare()，這也就意味著每個(gè)線程只有一個(gè) Looper 。

可是看回在主線程中創(chuàng)建 Handler 的時(shí)候，我們并沒(méi)有調(diào)用 Looper.prepare() 方法。但是也正常運(yùn)行了。那是為什么呢？那是因?yàn)樵?ActivityThread 中的 main()已經(jīng)調(diào)用了。

//ActivityThread.java
public static void main(String[] args) {
    //...省略無(wú)關(guān)代碼
    Looper.prepareMainLooper(); \\標(biāo)識(shí) 4
   //...
    ActivityThread thread = new ActivityThread();
    thread.attach(false, startSeq);
    if (sMainThreadHandler == null) {
        sMainThreadHandler = thread.getHandler();
    }
  //...
    Looper.loop();
}

//跟進(jìn)標(biāo)識(shí) 4
//Looper.java
public static void prepareMainLooper() {
    prepare(false);
    synchronized (Looper.class) {
        if (sMainLooper != null) {
            throw new IllegalStateException("The main Looper has already been prepared.");
        }
        sMainLooper = myLooper();
    }
}

這里需要注意！

我們不僅不用調(diào)用，也不能調(diào)用。否則將會(huì)觸發(fā) IllegalStateException("The main Looper has already been prepared.") 異常。
但是如果不是為主線程創(chuàng)建 Handler 的時(shí)候，我們就需要手動(dòng)調(diào)用 Looper.prepare(), 否則該線程中的 Looper 為空，會(huì)觸發(fā)標(biāo)識(shí) 3 的代碼塊。
即會(huì)得到RuntimeException("Can't create handler inside thread " + Thread.currentThread()+ " that has not called Looper.prepare()")異常。