Android線程通信之Handler

handler是安卓中通信的常用東西御毅,雖然常用明白其中的原理相當重要漂洋,本文記錄方便后面自己鞏固每界!

基本使用

   /**
     * 防止內(nèi)存泄漏
     */
    open class ChildHandler : Handler()
  /**
         * 一般的消息發(fā)送
         */
        messageSend.setOnClickListener {
            val handler = @SuppressLint("HandlerLeak")
            object : ChildHandler() {
                override fun handleMessage(msg: Message?) {
                    super.handleMessage(msg)
                    val par1 = msg?.what
                    val par2 = msg?.arg1
                    val par3 = msg?.arg2
                    val par4 = msg?.data?.getString("key1")
                    val par5 = (msg?.obj as HandlerData).info
                    Log.e("消息結(jié)果:", "$par1  $par2  $par3  $par4  $par5")
                }
            }
            Thread(Runnable {
                handler.sendMessage(getMessage())
                SystemClock.sleep(2000)
                handler.postDelayed({ handler.sendMessage(getMessage()) }, 0)
                SystemClock.sleep(2000)
                handler.post { toast("我是子線程中的post") }
            }).start()
        }
    }

handler的使用其實很簡單捷泞,可以發(fā)送的類別基本如下:

  fun getMessage(): Message {
            val msg = Message()
            msg.what = 1
            msg.arg1 = 2
            msg.arg2 = 3
            val bundle = Bundle()
            bundle.putString("key1", "4")
            msg.data = bundle
            msg.obj = HandlerData("5")
            return msg
        }

獲取Message載體也可以使用下面這種方法:

 fun getMessageInfo(handler: Handler): Message {
            return handler.obtainMessage()
        }

與new Message的區(qū)別就是:
obtainmessage()是從消息池中拿來一個msg 不需要另開辟空間new
new需要重新申請声搁,效率低黑竞,obtianmessage可以循環(huán)利用

上面在一個子線程中有這樣一句代碼:

handler.post { toast("我是子線程中的post") }
            }).start()

為什么可以在子線程更新UI呢?看起代碼似乎是在子線程疏旨,其實不然很魂,整個更新UI的操作還是在主線程,有興趣的可以參考這篇文章檐涝,總結(jié)的很好:
handler.post方法的終極最直觀的理解與解釋

在主線程中使用handler

獲取handler對象

 /**
     * handler接受消息
     */
    private fun initData() {
        val handler = @SuppressLint("HandlerLeak")
        object : Handler() {
            override fun handleMessage(msg: Message?) {
                super.handleMessage(msg)
                msg?.what?.let { Toast.makeText(this@MainActivity, "主線程接受到消息----$it", Toast.LENGTH_SHORT).show() }
            }
        }
    }

這個handler是new在主線程中的屬于主線程的handler

發(fā)送消息

        /**
         * 主線程通信  handler屬于主線程
         */
        findViewById<AppCompatButton>(R.id.sendMessage).setOnClickListener {
            Thread(Runnable {
                SystemClock.sleep(5000)
                handler!!.sendEmptyMessage(0)
            }).start()
        }

這里是點擊按鈕后開啟一個子線程遏匆,并且在子線程沉睡5秒后發(fā)送一個消息

結(jié)果

按照Toast彈出了正確的顯示框

在子線程中使用handler

findViewById<Button>(R.id.childThread).setOnClickListener { view ->
            Thread(Runnable {
                // SystemClock.sleep(5000)
                Looper.prepare()
                mHandlerThread = @SuppressLint("HandlerLeak")
                object : Handler() {
                    override fun handleMessage(msg: Message?) {
                        super.handleMessage(msg)
                        msg?.what?.let {
                            //(view as Button).text="子線程接受到消息----$it"
                            Toast.makeText(this@MainActivity, "子線程接受到消息----$it", Toast.LENGTH_SHORT).show()
                        }
                    }
                }
                Looper.loop()
            }).start()
            SystemClock.sleep(5000)
            mHandlerThread!!.sendEmptyMessage(0)

        }

同樣是點擊一個按鈕后開啟一個線程并且獲取handler對象,在點擊按鈕后主線程沉睡5秒后給子線程發(fā)送一個消息谁榜,并且顯示出消息

結(jié)果

正確的顯示出消息

注意其中有句代碼

 //(view as Button).text="子線程接受到消息----$it"

這是來檢測是否在子線程中幅聘,所以更新ui失敗證明了是在子線程中。

源碼解讀

主線程中使用handler是沒有什么問題的窃植,但是在子線程中使用handler多了兩句代碼分別是:

 Looper.prepare()
 Looper.loop()
Looper.prepare()

先來分析Looper.prepare()帝蒿,進入源碼可以看到:

 /** Initialize the current thread as a looper.
      * This gives you a chance to create handlers that then reference
      * this looper, before actually starting the loop. Be sure to call
      * {@link #loop()} after calling this method, and end it by calling
      * {@link #quit()}.
      */
    public static void prepare() {
        prepare(true);
    }

再往下

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));
    }

這里我們看到了一個sThreadLocal,他的定義在里面是這樣的:

 static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();

ThreadLocal并不是線程巷怜,它的作用是可以在每個線程中存儲數(shù)據(jù)葛超,這里儲存的就是一個Looper。
我們繼續(xù)分析looper延塑,當上面的sThreadLocal.set(new Looper(quitAllowed))執(zhí)行時候巩掺,他會走到這里:

  private Looper(boolean quitAllowed) {
        mQueue = new MessageQueue(quitAllowed);
        mThread = Thread.currentThread();
    }

這里獲取一個looper對象的時候需要一個MessageQueue對象,這個MessageQueue就是來獲取消息的對象和一個線程對象页畦,再看looper類的定義

public final class Looper {
    //省略代碼...
    final MessageQueue mQueue;
    final Thread mThread;
    }

到這里基本上就可以明白

使用Looper.prepare()這個方法是在當前的線程中獲取到是否有l(wèi)ooper對象胖替,如果沒有的話就重新設(shè)置一個looper到當前的對象,并將這個對象與當前線程進行綁定豫缨,其中l(wèi)ooper對象里面包含了一個MessageQueue(消息隊列)

Looper.loop()

我們繼續(xù)分析looper在線程中的作用独令,進入Looper.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;
        
        ...省略代碼...
        
        for (;;) { ...省略代碼...}
        }

其中的myLooper()方法是:

  /**
     * Return the Looper object associated with the current thread.  Returns
     * null if the calling thread is not associated with a Looper.
     */
    public static @Nullable Looper myLooper() {
        return sThreadLocal.get();
    }

這里可以恍然大悟,這里獲取的looper就是前面我們調(diào)用Looper.prepare()設(shè)置的looper好芭,并且將當前的這個looper中的MessageQueue(消息隊列)對象拿了出來燃箭,再往下走是一個死循環(huán)代碼:

 for (;;) { ...省略代碼...}

這個循環(huán)里做的事其實就是用當前l(fā)ooper中去循環(huán)的取出MessageQueue中的Message,并將這個message交給相應(yīng)的handler進行處理舍败,其他線程傳過來的消息是放在message中的招狸,這里再對相應(yīng)的幾個對象做下說明

Handler:線程間通信的方式敬拓,主要用來發(fā)送消息及處理消息 ,消息的發(fā)送是不區(qū)分線程的裙戏,但是消息的接受是要區(qū)分線程的 
Looper:為線程運行消息循環(huán)的類乘凸,循環(huán)取出MessageQueue中的Message;消息派發(fā)累榜,將取出的Message交付給相應(yīng)的Handler营勤。 
MessageQueue:存放通過Handler發(fā)過來的消息,遵循先進先出原則壹罚。 
Message:消息葛作,線程間通信通訊攜帶的數(shù)據(jù)。

結(jié)論:

一個線程需要接受其他線程傳遞過來的消息猖凛,必須其中有一個與當前線程進行綁定的looper消息循環(huán)器和一個處理消息的handler赂蠢,這個looper中包含了一個MessageQueue,這個MessageQueue中包含的就是其他線程傳遞過來的Message消息對象辨泳,這個looper是一直在循環(huán)的取出消息隊列中的消息客年,并將這個消息信息傳遞給當前線程中的handler對象進行處理,handler消息的發(fā)送是不區(qū)分線程的漠吻,但是消息的接受是要區(qū)分線程的量瓜,當前handler在哪個線程中就在哪個線程中處理消息!

主線程中使用handler為什么代碼中不用寫Looper.prepare()途乃,Looper.loop()绍傲?

我們找到整個項目的函數(shù)入口,代碼如下:

 public static void main(String[] args) {
       ...省略代碼...
        Looper.prepareMainLooper();
        ActivityThread thread = new ActivityThread();
        if (sMainThreadHandler == null) {
            sMainThreadHandler = thread.getHandler();
        }
        Looper.loop();
        throw new RuntimeException("Main thread loop unexpectedly exited");
    }

進入到Looper.prepareMainLooper():

 public static void prepareMainLooper() {
        prepare(false);
        synchronized (Looper.class) {
            if (sMainLooper != null) {
                throw new IllegalStateException("The main Looper has already been prepared.");
            }
            sMainLooper = myLooper();
        }
    }

進入 prepare(false)

 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));
    }

這里就很清楚了耍共,這里其實就已經(jīng)準備好了looper烫饼,再進入上邊的myLooper():

    public static @Nullable Looper myLooper() {
        return sThreadLocal.get();
    }

其實這里返回的就是上邊準備的looper,主函數(shù)入口處并且有了Looper.loop()试读,這里大家就清楚了為什么主線程不需要操作looper了吧杠纵,因為主線程已經(jīng)準備好了looper,并且準備的方式跟我們上面再子線程中準備的方式是一樣的钩骇!

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末比藻,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子倘屹,更是在濱河造成了極大的恐慌银亲,老刑警劉巖,帶你破解...
    沈念sama閱讀 219,110評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件纽匙,死亡現(xiàn)場離奇詭異务蝠,居然都是意外死亡,警方通過查閱死者的電腦和手機烛缔,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,443評論 3 395
  • 文/潘曉璐 我一進店門馏段,熙熙樓的掌柜王于貴愁眉苦臉地迎上來轩拨,“玉大人,你說我怎么就攤上這事院喜⊥鋈兀” “怎么了?”我有些...
    開封第一講書人閱讀 165,474評論 0 356
  • 文/不壞的土叔 我叫張陵够坐,是天一觀的道長。 經(jīng)常有香客問我崖面,道長元咙,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,881評論 1 295
  • 正文 為了忘掉前任巫员,我火速辦了婚禮庶香,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘简识。我一直安慰自己赶掖,他們只是感情好,可當我...
    茶點故事閱讀 67,902評論 6 392
  • 文/花漫 我一把揭開白布七扰。 她就那樣靜靜地躺著奢赂,像睡著了一般。 火紅的嫁衣襯著肌膚如雪颈走。 梳的紋絲不亂的頭發(fā)上膳灶,一...
    開封第一講書人閱讀 51,698評論 1 305
  • 那天,我揣著相機與錄音立由,去河邊找鬼轧钓。 笑死,一個胖子當著我的面吹牛锐膜,可吹牛的內(nèi)容都是我干的毕箍。 我是一名探鬼主播,決...
    沈念sama閱讀 40,418評論 3 419
  • 文/蒼蘭香墨 我猛地睜開眼道盏,長吁一口氣:“原來是場噩夢啊……” “哼而柑!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起荷逞,我...
    開封第一講書人閱讀 39,332評論 0 276
  • 序言:老撾萬榮一對情侶失蹤牺堰,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后颅围,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體伟葫,經(jīng)...
    沈念sama閱讀 45,796評論 1 316
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,968評論 3 337
  • 正文 我和宋清朗相戀三年院促,在試婚紗的時候發(fā)現(xiàn)自己被綠了筏养。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片斧抱。...
    茶點故事閱讀 40,110評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖渐溶,靈堂內(nèi)的尸體忽然破棺而出辉浦,到底是詐尸還是另有隱情,我是刑警寧澤茎辐,帶...
    沈念sama閱讀 35,792評論 5 346
  • 正文 年R本政府宣布宪郊,位于F島的核電站,受9級特大地震影響拖陆,放射性物質(zhì)發(fā)生泄漏弛槐。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,455評論 3 331
  • 文/蒙蒙 一依啰、第九天 我趴在偏房一處隱蔽的房頂上張望乎串。 院中可真熱鬧,春花似錦速警、人聲如沸叹誉。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,003評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽长豁。三九已至,卻和暖如春忙灼,著一層夾襖步出監(jiān)牢的瞬間蕉斜,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,130評論 1 272
  • 我被黑心中介騙來泰國打工缀棍, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留宅此,地道東北人。 一個月前我還...
    沈念sama閱讀 48,348評論 3 373
  • 正文 我出身青樓爬范,卻偏偏與公主長得像父腕,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子青瀑,可洞房花燭夜當晚...
    茶點故事閱讀 45,047評論 2 355

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