android Handler运行原理总结复习

下了7.0系统的源码,打算要赶在过阴历年之前,看一些东西!不能再这么颓废下去了!
早上又复习了Handler的运行流程,看了源码后,感觉和几年前看的时候真是大不相同!

这里写图片描述

OK,不皮了,进入正题!

嗯,从ActivityThread开始吧!因为它是隐藏的,在你的IDE中是看不到的!所以在你解压系统源码后的android-7.1.0_r1\frameworks\base\core\java\android\app这个目录下,你可以找道这个文件!当然,如果你觉得系统源码有点大,自己的网速有很烂下载不方便,你可以在这个网址在线看

http://grepcode.com/file/repo1.maven.org/maven2/org.robolectric/android-all/5.0.0_r2-robolectric-1/android/app/ActivityThread.java#ActivityThread.%3Cinit%3E%28%29

在ActivityThread这个文件的末尾,你会看到一个main函数,这个就是程序的入口了。


这里写图片描述

OK,功力有限,其它的我们先不考虑,我们先来看我们能看的懂的。
看到 Looper.prepareMainLooper();//.......Looper.loop();应该知道为啥我们可以在主线程中直接使用Handler了吧!哈哈..
我们看看Looper.prepareMainLooper();做了哪些操作。

这里写图片描述

这几行英文注释很简单,大意呢就是,android系统为创建了一个当前线程的looper,作为我们的application的主looper。看到 我们熟悉的prepare(false);我们还是点进去瞅瞅

这里写图片描述

看仔细点,这是两个方法,一个带参数的,一个不带参数的,同样的都是为我们Handler提供一个Looper的,带参数的跟不带参数有什么区别呢?嗯,还是看注释,当你的参数是true的时候,我们自己创建的looper会自动调用quit(),进行注销操作,回到上面的Looper.prepareMainLooper(),它的方法体中传的false,也就是说,我们系统在创建主线程的Looper是不会自动销毁的,为什么要销毁呢?下面我们看loop()方法体的时候,你就明白了!

我们接着看prepare(boolean quitAllowed)中的代码,sThreadLocal.get(),sThreadLocal是啥玩意,跟上去看看

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

直接实例化了,还是静态的!点进去,只有这么简单的一行描述:

[图片上传失败...(image-afd390-1514970145505)]

创建一个线程局部变量!!emmm,不太明白,那我们先跳过看它怎么给参数的:

sThreadLocal.set(new Looper(quitAllowed));
这里写图片描述

嗯,大概明白了,sThreadLocal维护的是一个保存当前运行线程变量信息的HashMap!
它的get方法如下:

这里写图片描述

我们再捋一遍哈!当执行Loop的 prepare()方法的时候,会判断当前的线程信息,也就是为啥会抛出一个线程只允许创建一次prepare()的异常;

这里写图片描述

接着,如果当前线程还没prepare();,我们也就创建出了Looper的实例,并将其塞入ThreadLocal

这里写图片描述

实例化这步中,我们就为我们当前的线程创建出了MessageQueue(消息队列),并拿到当前线程的各个信息!

OK!至此,我们总算是搞清楚了Looper的实例化,是在prepare(),中完成,并且,并且,并且(重要的事情说三遍!我们也创建出了当前线程的一个消息循环器。

当前线程的消息循环器创建好了,但是我们还没有启动它!那怎么启动呢?

终于到Looper.loop();他就是启动轮询器的执行方法体了!

 /**
     * Run the message queue in this thread. Be sure to call
     * {@link #quit()} to end the 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;

        // Make sure the identity of this thread is that of the local process,
        // and keep track of what that identity token actually is.
        Binder.clearCallingIdentity();
        final long ident = Binder.clearCallingIdentity();

        for (;;) {
            Message msg = queue.next(); // might block
            if (msg == null) {
                // No message indicates that the message queue is quitting.
                return;
            }

            // This must be in a local variable, in case a UI event sets the logger
            final Printer logging = me.mLogging;
            if (logging != null) {
                logging.println(">>>>> Dispatching to " + msg.target + " " +
                        msg.callback + ": " + msg.what);
            }

            final long traceTag = me.mTraceTag;
            if (traceTag != 0 && Trace.isTagEnabled(traceTag)) {
                Trace.traceBegin(traceTag, msg.target.getTraceName(msg));
            }
            try {
                msg.target.dispatchMessage(msg);
            } finally {
                if (traceTag != 0) {
                    Trace.traceEnd(traceTag);
                }
            }

            if (logging != null) {
                logging.println("<<<<< Finished to " + msg.target + " " + msg.callback);
            }

            // Make sure that during the course of dispatching the
            // identity of the thread wasn't corrupted.
            final long newIdent = Binder.clearCallingIdentity();
            if (ident != newIdent) {
                Log.wtf(TAG, "Thread identity changed from 0x"
                        + Long.toHexString(ident) + " to 0x"
                        + Long.toHexString(newIdent) + " while dispatching to "
                        + msg.target.getClass().getName() + " "
                        + msg.callback + " what=" + msg.what);
            }

            msg.recycleUnchecked();
        }
    }

我们一行一行来吧!

这里写图片描述

根据下面抛出的异常,我们应该可以知道些什么!跳进去:

这里写图片描述

阿西吧,这不就是prepare()的时候塞进去的那个Looper嘛!

final MessageQueue queue = me.mQueue;

这行不就是,Looper实例化创建的那个MessageQueue嘛

这里写图片描述

一个不可打断的死for循环!无限循环的消息队列是不是用Looper.loop();搞定了!

并且,我们是不是看到一个熟悉的方法调用?哈哈!

msg.target.dispatchMessage(msg);

是Handler的方法体吧!!!

OK,到这里,当前线程无限循环的消息队列是创建成功了!

那么问题又来了?Handler是怎么把消息存到当前线程无限循环的消息队列呢?

默认Handler实例化

这里写图片描述

this方法体:


这里写图片描述

看到执行了!!!

mLooper = Looper.myLooper();//获取当前线程Looper

mQueue = mLooper.mQueue;//获取当前线程的消息队列

OK,初始化完成,拿到当前线程的Looper了,拿到了当前线程Looper关联的消息队列mQueue.

再接着,我们发送一个最简单的消息进行处理!

这里写图片描述

嗯,接着走!

这里写图片描述

我们看一下这两行代码发生了什么!

 Message msg = Message.obtain();
        msg.what = what;

给的注释说我们 从公共池中返回一个新的消息实例,让我们避免在许多情况下分配新对象。

解释一下吧!上面多截出来的几个变量很重要,sPool是一个全局的Message的索引,这也是就注释的第一句话的意思,当前对象中如果存在Message对象,我们不需要创建新的实例对象,然后会将当前Message的各个信息补充完整,它的next也是一个Message对象,我们会将当前存在的Message对象生成一个新的Message节点,就酱!那如果没有的话,则返回一个新的new Message(),我们面试常问到的Handler绑定,也就是target的赋值,还没到,大家不要急!

回到Handler,我们接着往下走!

这里写图片描述

没有什么有用的信息,接着往下走!

这里写图片描述

们初始化Handler的时候mQueue,被赋给别人了!

接着走!

这里写图片描述

来了,此时将Handler附在Message上了!!!!

接着看return queue.enqueueMessage(msg, uptimeMillis);
从字面理解,是将Message和执行的时间点存入了MessageQueue中!我们也跟进去看看!

    boolean enqueueMessage(Message msg, long when) {
        if (msg.target == null) {
            throw new IllegalArgumentException("Message must have a target.");
        }
        if (msg.isInUse()) {
            throw new IllegalStateException(msg + " This message is already in use.");
        }

        synchronized (this) {
            if (mQuitting) {
                IllegalStateException e = new IllegalStateException(
                        msg.target + " sending message to a Handler on a dead thread");
                Log.w(TAG, e.getMessage(), e);
                msg.recycle();
                return false;
            }

            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 {
                // Inserted within the middle of the queue.  Usually we don't have to wake
                // up the event queue unless there is a barrier at the head of the queue
                // and the message is the earliest asynchronous message in the queue.
                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;
            }

            // We can assume mPtr != 0 because mQuitting is false.
            if (needWake) {
                nativeWake(mPtr);
            }
        }
        return true;
    }

这段代码就是将Message插入MessageQueue中,主要的几行代码,我标出来了!哈哈

这里写图片描述

其实没什么可说的这个方法,主要是按照when(执行时间点)来插入队列中!当没有消息可插入的时候,就会跳出这个循环!

总结:
实例化Handler(拿到当前线程的Looper,MessageQueue),发送消息(将生成的携带Handler标记的Message插入MessageQueue),完成了消息的生成存储流程!之后的Looper.loop();方法就将开无限循环处理消息了!

这篇写的有些简陋,感觉主要是整个流程框架有点庞大复杂,整体的把握还是有些不足!这是我这边的复习总结!个人感觉吧,大家还是自己看看源码比较好!哈哈!话说回来,面试的时候这个问道的概率很大很大!掌握其中的各个关键点和整体的架构把握很重要!

OK,据扯到这了!

每天进步一点点,时间会让你成为巨人!加油!

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

推荐阅读更多精彩内容