在Android中主線程與子線程的通信十分重要，Google工程師為我們提供了Handler-Message機(jī)制來(lái)解決他們之間的交互問(wèn)題。今天，我們就來(lái)簡(jiǎn)單理解Handler-Message機(jī)制的原理，在Java中簡(jiǎn)單模擬該機(jī)制。代碼示例Github地址HandlerDemo

成都創(chuàng)新互聯(lián)致力于互聯(lián)網(wǎng)網(wǎng)站建設(shè)與網(wǎng)站營(yíng)銷，提供成都網(wǎng)站建設(shè)、成都做網(wǎng)站、網(wǎng)站開(kāi)發(fā)、seo優(yōu)化、網(wǎng)站排名、互聯(lián)網(wǎng)營(yíng)銷、小程序開(kāi)發(fā)、公眾號(hào)商城、等建站開(kāi)發(fā)，成都創(chuàng)新互聯(lián)網(wǎng)站建設(shè)策劃專家，為不同類型的客戶提供良好的互聯(lián)網(wǎng)應(yīng)用定制解決方案，幫助客戶在新的全球化互聯(lián)網(wǎng)環(huán)境中保持優(yōu)勢(shì)。

首先，看一下簡(jiǎn)單流程圖（不太專業(yè)）

由上圖可知，流程中主要相關(guān)類有Handler、Message、MessageQueue、Looper；下面，我們就圍繞它們來(lái)簡(jiǎn)單分析該流程圖：

1.我們一般在主線程創(chuàng)建Handler，接著開(kāi)啟子線程完成指定任務(wù)，再將任務(wù)數(shù)據(jù)封裝Message，交由Handler發(fā)出；

2.接著，MessageQueue接收Handler發(fā)來(lái)的Message，將其根據(jù)Message中的屬性when（時(shí)刻值）進(jìn)行排序，重組隊(duì)列；
（在這插一段MessageQueue的由來(lái)：MessageQueue的創(chuàng)建其實(shí)是跟隨著Looper的創(chuàng)建，而Looper的一個(gè)特性就是一個(gè)線程只允許有一個(gè)Looper，緩存在ThreadLocal中，而Looper的創(chuàng)建Looper.prepare()是要在創(chuàng)建Handler之前調(diào)用的，這 樣就保證了一個(gè)MessageQueue所緩存的隊(duì)列消息均是需要分發(fā)到該Looper所在線程的。）

3.接下來(lái)，通過(guò)Looper.loop()取出MessageQueue中的消息，而Looper.loop()以及MessageQueue中的next()均是堵塞線程的，所以和永動(dòng)機(jī)一般，可以不停地取出消息；

4.最后，Looper.loop()取出的Message通過(guò)Message中的target（Handler）實(shí)現(xiàn)消息分發(fā)，而dispatchMessage(Message)方法為Handler中的方法，這樣就實(shí)現(xiàn)了“誰(shuí)發(fā)出的消息誰(shuí)處理”，所以一個(gè)線程中的多個(gè)Handler可以實(shí)現(xiàn)相對(duì)獨(dú)立的工作。

接下來(lái)，看一下示例代碼及其運(yùn)行效果

代碼示例：

package com.wkp.test;

import android.wkp.Handler;
import android.wkp.Looper;
import android.wkp.Message;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

public class Main {

    public static void main(String[] args) {
        //主線程Looper準(zhǔn)備
        Looper.prepareMainLooper();
        //創(chuàng)建Handler
        final MainHandler handler = new MainHandler();
        //開(kāi)啟線程池
        Executor executor = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            final int position = i + 1;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(1000 * position);
                        //子線程傳任務(wù)到主線程
                        handler.postDelayed(new Runnable() {
                            @Override
                            public void run() {
                                System.out.println(Thread.currentThread().getName() + " : " + position);
                            }
                        },1000);

                        Thread thread = Thread.currentThread();
                        //子線程傳消息到主線程
                        Message.obtain(handler,position,position,position,"主線程，你好！我是線程："+thread.getName()).sendToTarget();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }
        //消息隊(duì)列循環(huán)
        Looper.loop();
    }

    /**
     * 主線程處理子線程傳回的消息
     */
    private static class MainHandler extends Handler{
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case WhatConstants.WHAT_ONE:
                    String obj1 = (String) msg.obj;
                    System.out.println(obj1);
                    break;
                case WhatConstants.WHAT_TWO:
                    String obj2 = (String) msg.obj;
                    System.out.println(obj2);
                    break;
                case WhatConstants.WHAT_THREE:
                    String obj3 = (String) msg.obj;
                    System.out.println(obj3);
                    break;
                case WhatConstants.WHAT_FOUR:
                    String obj4 = (String) msg.obj;
                    System.out.println(obj4);
                    break;
                case WhatConstants.WHAT_FIVE:
                    String obj5 = (String) msg.obj;
                    System.out.println(obj5);
                    break;
                case WhatConstants.WHAT_SIX:
                    String obj6 = (String) msg.obj;
                    System.out.println(obj6);
                    break;
                case WhatConstants.WHAT_SEVEN:
                    String obj7 = (String) msg.obj;
                    System.out.println(obj7);
                    break;
                case WhatConstants.WHAT_EIGHT:
                    String obj8 = (String) msg.obj;
                    System.out.println(obj8);
                    break;
                case WhatConstants.WHAT_NINE:
                    String obj9 = (String) msg.obj;
                    System.out.println(obj9);
                    break;
                case WhatConstants.WHAT_TEN:
                    String obj10 = (String) msg.obj;
                    System.out.println(obj10);
                    break;
            }
        }
    }
}

運(yùn)行效果：

主線程，你好！我是線程：pool-1-thread-1
main : 1
主線程，你好！我是線程：pool-1-thread-2
main : 2
主線程，你好！我是線程：pool-1-thread-3
main : 3
主線程，你好！我是線程：pool-1-thread-4
主線程，你好！我是線程：pool-1-thread-5
main : 4
main : 5
主線程，你好！我是線程：pool-1-thread-6
主線程，你好！我是線程：pool-1-thread-7
main : 6
main : 7
主線程，你好！我是線程：pool-1-thread-8
main : 8
主線程，你好！我是線程：pool-1-thread-9
主線程，你好！我是線程：pool-1-thread-10
main : 9
main : 10

最后，歡迎親友們留言交流

如果大家想更深入的了解，可以觀看源碼Github地址，源碼中有詳盡的注釋。大家如果有更好的意見(jiàn)或建議以及好的靈感，請(qǐng)郵箱作者，謝謝！

QQ郵箱：1535514884@qq.com

163郵箱：15889686524@163.com

Gmail郵箱：wkp15889686524@gmail.com