Android Handler消息机制源码分析

概述

Handler通常被我们开发者用来从子线程中发送消息通知主线程跟新UI,但是这只是Handle的冰山一角,本文从源码的角度彻底解析Handler消息机制的原理。
Handler机制只要涉及的几个类:


01.png

主要从以下方面来分析整个源码:

  • Handler、Looper、MessageQueue、Message的源码
  • mainThread 的 handler 和 looper(从ActivityThread.main开始)
  • 整个消息发送的流程
  • 分析每个环节的代码细节
  • Handler、Looper和Thread之间的关系
  • 由handler造成的内存泄露问题

整个消息发送、接收流程的大致梳理

02.png

第一步:handle.sendMessage()把消息发送给对应线程的Looper的消息列队(每个looper持有一个MessageQueue)
第二步:Looer.loop()不断轮询取出消息
第三步:取出消息后发送给对应的Handler


系统主线程中的Handler

Handler在Android的整个架构中间不仅仅只是负责更新UI的作用,通过分析AcitivityThread的源码可以看到,系统一开始帮我们初始化一个主线程的Handler和Looper,Activity、Service等的生命周期的消息都是经过Handler来处理的,可见Handler的重要性。我们都知道Java的程序入口是main函数,Android自然也是一样

AcitivityThread#main
final H mH = new H();
public static void main(String[] args) {
    ...
    //在main线程里初始化一个Looper
    Looper.prepareMainLooper();
    //开启死循环,不断轮询MessageQueue一旦有消息,从列队中取出发送
    Looper.loop();
    ...
}

private class H extends Handler {
}

首先调用Looper.prepareMainLooper(),初始化一个Looper将Looper和main线程绑定,然后在AcitivityThread里面懒加载了一个H变量,H继承的Handler,最后Looper.loop()开启死循环,不断轮询MessageQueue一旦有消息,从列队中取出发送。
接下来看看H.handleMessage()干了哪些事情,抽取几个分析:

public void handleMessage(Message msg) {
      ...
      case BIND_SERVICE://绑定服务
      ...
      case PAUSE_ACTIVITY://Activity的生命周期控制
      ...
      case EXIT_APPLICATION://退出应用
              Looper.myLooper().quit();
              break;
}

可以看到Android系统的消息机制、事件反馈机制等的消息都是由Handler来进行分发的。
看到这里可能大家会有这么一个疑问,那就是看到AcitivityThread.main方法里面就寥寥几行代码,main方法运行完了整个App程序不也就退出了吗?为什么App能够一直存在呢?因为Looper.loop()里面执行了一个死循环。循环退出了,main函数执行完了,程序也就退出了,这就是上面Looper.myLooper().quit()退出looper的死循环就退出应用的原因。
到这里,我们看到要通过Handler向一个线程发送消息要有这几个步骤:

  • 初始化一个Looper和线程绑定起来,一个线程最多只能有一个Looper(具体原因后面分析)
  • 初始化一个Handler,用来发送消息给Looper的MessageQueue
  • Looper.loop()开启死循环,不断轮询MessageQueue取出消息发送

我们平时常在主线程中new的Handler不用经历这些步骤,那是应为在app启动的时候系统帮我们已经做好了。
到这里,有几个疑问就是:

Handler是怎么和Looper绑定的呢?明明new Handle的时候和Looper半毛钱关系都没有
多个Handler怎么可以同时向一个Looper的MessageQueue发送消息呢?(ActicityThread中的H和我们平时用的handler就是)


Looper

前面提到的,Handler的使用第一步就是Looper.prepare(),初始化Looper与线程绑定。

public class Looper {
    //全局的sThreadLocal 
    private static final ThreadLocal sThreadLocal = new ThreadLocal();
    // Looper内的消息队列
    final MessageQueue mQueue;
    // 当前线程
    Thread mThread;
    // 。。。其他属性

    // 每个Looper对象中有它的消息队列,和它所属的线程
    private Looper() {
        mQueue = new MessageQueue();
        mRun = true;
        mThread = Thread.currentThread();
    }

    // 我们调用该方法会在调用线程的TLS中创建Looper对象
    public static final void prepare() {
        //从当前线程拿Looper
        if (sThreadLocal.get() != null) {
           //如果线程中已经初始化了Looper,则抛出异常,这就是为什么一个线程只能有Looper
            throw new RuntimeException("Only one Looper may be created per thread");
        }
         //new 一个Looper存放到线程
        sThreadLocal.set(new Looper());
    }
    // 其他方法
}

prepare()首先调用sThreadLocal.get(),会去检测当前线程中是否已经初始化了Looper,如果已经有Looper,则抛异常,这里就规定了一个线程只能有一个Looper。如果多次调用Looper.prepare的话就会抛异常。然后调用sThreadLocal.set(new Looper()),将Looper保存到对应的Thread中。发现没有Looper的构造是private的,所有的Looper实列化都必须通过prepare(),Looper构造里面初始化了MessageQueue对象,所以每个Looper拥有一个消息队列。
Looper和Thread能够绑定的关键在于sThreadLocal.set(),ThreadLocal是用于线程安全的,具体的不做讨论。sThreadLocal是一个静态变量,系统初始化的时候就存在的。进一步看sThreadLocal.set()的源码

public void set(T value) {
        //获取当前线程
        Thread currentThread = Thread.currentThread();
         //拿到Thread中的localValues变量
        Values values = values(currentThread);
        if (values == null) {
            values = initializeValues(currentThread);
        }
        //将全局的ThreadLocal(Looper.sThreadLocal)作为键,Looper作为值存到线程的ThreadLocal.Values localValues变量中
        values.put(this, value);
}

Values values(Thread current) {   
       return current.localValues;
}

class Thread{
    ThreadLocal.Values localValues;
}

首先拿到当前线程,获取Thread的一个变量localValues,Values 是ThreadLocal的一个内部类,以键值对存放数据,是一个散列链表,和HashMap类似。Looper就是这样和Thread绑定的。

looper()方法:

public static final void loop() {
        Looper me = myLooper();  //得到当前线程Looper
        MessageQueue queue = me.mQueue;  //得到当前looper的MQ
        // 开始循环
        for (;;) {
            Message msg = queue.next(); // 取出message
            if (msg != null) {
                if (msg.target == null) {
                    // message没有target为结束信号,退出循环
                    return;
                } 
                // 非常重要!将真正的处理工作交给message的target,即后面要讲的handler
                msg.target.dispatchMessage(msg);
               ...
               msg.recycleUnchecked();
            }
        }
    }

myLooper()方法主要是通过sThreadLocal去拿到当前线程的Looper对象
然后拿到消息队列mQueue

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

再通过queue.next()从消息队列中取出消息msg,然后msg.target.dispatchMessage(msg);把消息发送给handler,msg.target就是handler的引用,是在Handler.sendMessage的时候赋值的,调用handler.dispatchMessage()方法最后会调用我们熟悉的handler.handlerMessage()方法,来让我们处理消息。
最后一步msg.recycleUnchecked()把消息回收放入消息池内。

小结
Looper.prepare()方法初始化一个Looper对象同时为Looper实例化了一个MessageQueue,并且通过全局变量sThreadLocal将初始化Looper的线程和Looper对象关联,将Looper对象存储在当前Thread变量中。
Looper.loop()方法正式将Looper运行起来,不断循环从消息队列取消、发送消息、回收消息。

Handler

Handler使用的时候分两步:
new Handler 、handler.sendMessage()或者handler.post(),这时候Looper影子都没见着,Handler是怎么把消息发送到线程的Looper.mQueue中去的呢?答案就在Handler的构造中:

 public Handler(Callback callback, boolean async) {
      ...
        //拿到当前线程的Looper
        mLooper = Looper.myLooper();
        //这里表示在初始化Handler之前,必须初始化Looper,不然抛异常
        if (mLooper == null) {
            throw new RuntimeException(
                "Can't create handler inside thread that has not called Looper.prepare()");
        }
        //拿到消息列队
        mQueue = mLooper.mQueue;
        //自定义回调 
        mCallback = callback;
        mAsynchronous = async;
 }

首先在构造里面会去拿到与当前线程(也就是初始化Handler的线程)的Looper、MessageQueue,赋值给Handler的成员变量,这里就解释了Handler怎么和Looper怎么关联起来的了而且多个handler可以同时向同一个Looper的消息列队发送消息,因为他们拿到的是同一个Looper,中间的纽带就是Thread。
在来看sendMessage(),通过几个重载的方法最终调用下面函数:

private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) {
        msg.target = this;
        if (mAsynchronous) {
            msg.setAsynchronous(true);
        }
        //直接把关联looper的MessageQueue 作为自己的MessageQueue ,因此它的消息将发送到关联looper的MessageQueue 上
        return queue.enqueueMessage(msg, uptimeMillis);
    }

可以看到msg.target = this将当前的Handler赋值给了Message的变量,这就是为什么Looper在取出Message的时候能够准确的发送给相应的Handler。最终把消息放入消息队列。uptimeMillis是延时发送的时间,最终在queue.enqueueMessage(msg, uptimeMillis)会存入msg中。
在Handler中的另外几个点:
1、handler.post(runnable)

public final boolean post(Runnable r)
    {
       return  sendMessageDelayed(getPostMessage(r), 0);
    }

最终同样也是调用sendMessageAtTime(),以前老以为这里Runable是和线程有关,看源码才知道和线程半毛钱关系都没有,仅仅只是一个接口,在看getPostMessage(r):

private static Message getPostMessage(Runnable r, Object token) {
        //得到一个消息实例
        Message m = Message.obtain();
        m.obj = token;
       //把Runable对象赋值给了Message的一个变量最终返回msg
        m.callback = r;
        return m;
    }

Runnable 对象赋值给了Message的一个变量,最终还是把返回的Msg,之后流程和handler.sendMessage()一样的了.
在Looper.loop()中msg.target.dispatchMessage(msg)来发送消息最终调用的是Handler.dispatchMessage()方法,

public void dispatchMessage(Message msg) {
        //如果是handler.post(Runable)走这里
        if (msg.callback != null) {
            handleCallback(msg);
        } else {
            if (mCallback != null) {//自定义回调
                if (mCallback.handleMessage(msg)) {
                    return;
                }
            }
            //常规的回调
            handleMessage(msg);
        }
    }

首先会去检查msg是否有callback 也就是上面讲的Runable对象,如果有则是我们常用的handler.post()这种调用方式,接下来回去判断mCallback 是否为空,这个mCallback 是Handler的内部类,在Handler的重载的构造中赋值,如果是自定义的回调则调用mCallback.handleMessage(),这样就不会回调handler.handlerMessage(),最后调用handler.handlerMessage();

到此消息发送、接收的原理和流程就分析完了。这里还有个经典的案列:向子线程中发送消息。
其实Looper的源码注释已经写得很明白了,也给出了示例代码:

public Handler mHandler;
class LooperThread extends Thread { 
  *      public void run() {
  *          Looper.prepare();
  *
  *          mHandler = new Handler() {
  *              public void handleMessage(Message msg) {
  *                  // process incoming messages here
  *              }
  *          };
  *
  *          Looper.loop();
 }

mHandler.sendMessage();

首先:初始化子线程的Looper,关联Looper和子线程
其次:初始化Hander,拿到当前线程的Looper赋值给Handler最为成员变量
最后:Looper.loope()死循环,不断从消息列队取消息
最终handler.handlerMessage()在Looper.loop()中被调用,所以handlerMessage()运行在子线程中。

未完

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,445评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,889评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,047评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,760评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,745评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,638评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,011评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,669评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,923评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,655评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,740评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,406评论 4 320
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,995评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,961评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,023评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,483评论 2 342

推荐阅读更多精彩内容