Android中handler机制原理详解

1、handler的作用

handler是android线程之间的消息机制,主要的作用是将一个任务切换到指定的线程中去执行,(准确的说是切换到构成handler的looper所在的线程中去出处理)android系统中的一个例子就是主线程中的所有操作都是通过主线程中的handler去处理的。

2、handler的架构

Handler的运行需要底层的 messagequeue和 looper做支撑。

3、handler原理

3 .1 、首先说messagequeue,messagequeue 是 一 个 消 息 队 列 , 它是采用单链表的数据结构来存储消息的,因为单链表在插入删除上 的效率非常高。(Meaasgequeue主要包含一个是插入消 息的 enqueuemessage方法,和一个取出一条消息的next方法。)

3.2、然后说 looper,looper在安卓的消息机制中是扮演着消息调度的角色,具体来说就是他会不停的从 messagequeue中查看 是否有新消息,如果有,并且这个消息需要执行,就从队列中取出这个消息进行执行,(死循环遍历消息:取消息的线程会先阻塞一段时间(队头消息的执行时间减去当前时间),然后从队列中取出队头消息),否则会一直阻塞在messagequeue的next那里。(构成 一个 looper是需要一个 messagequeue,而构成一个 handler则需 要一个 looper,)另外looper一般是调用Looper.prepare()方法使用 threadlocal在线程的ThreadLocalMap中存储一个looper的,线程中有了looper之后就可以在这个线程中创建一个 handler了。

3.2、然后说 looper,looper在安卓的消息机制中是扮演着消息调度的角色。

Looper取消息的过程是这样的:

如果队列中有消息:
1、判断队头消息的执行时间是否大于当前时间,如果大于,就调用nativePollOnce阻塞一段时间(队头消息的执行时间-当前时间)然后取出队头消息进行执行。
2、否则就立即取出队头消息进行执行。
3、如果队列中没有消息,就一直阻塞,直到下一个消息来到,才唤醒取消息的线程继续上述循环。

Message next() {
         ...
        int pendingIdleHandlerCount = -1; // -1 only during first iteration
        int nextPollTimeoutMillis = 0;
        for (;;) {
            if (nextPollTimeoutMillis != 0) {
                Binder.flushPendingCommands();
            }
            nativePollOnce(ptr, nextPollTimeoutMillis);
            synchronized (this) {
                // Try to retrieve the next message.  Return if found.
                final long now = SystemClock.uptimeMillis();
                Message prevMsg = null;
                Message msg = mMessages;
                if (msg != null && msg.target == null) {
                    // Stalled by a barrier.  Find the next asynchronous message in the queue.
                    //发现屏障消息,优先执行队列中的异步消息
                    do {
                        prevMsg = msg;
                        msg = msg.next;
                     //之所以要循环,是因为队列是按时间排序的,异步消息不一定位于队头
                    } while (msg != null && !msg.isAsynchronous());
                }
                if (msg != null) {
                    if (now < msg.when) {
                        // Next message is not ready.  Set a timeout to wake up when it is ready.
                         //队头消息没到执行时间,休眠nextPollTimeoutMillis
                        nextPollTimeoutMillis = (int) Math.min(msg.when - now, Integer.MAX_VALUE);
                    } else {
                        // Got a message.
                        //得到一个需要立即执行的消息
                        mBlocked = false;
                        if (prevMsg != null) {
                            prevMsg.next = msg.next;
                        } else {
                            mMessages = msg.next;
                        }
                        msg.next = null;
                        msg.markInUse();
                        return msg;
                    }
                } else {
                    // No more messages.
                    //队列中没有消息了,进入无限期休眠
                    nextPollTimeoutMillis = -1;
                }
            ...
        }
    }

nativePollOnce(ptr, nextPollTimeoutMillis),这是一个native方法,实际作用就是通过Native层的MessageQueue休眠nextPollTimeoutMillis毫秒的时间。
1.如果nextPollTimeoutMillis=-1,一直休眠不会超时。
2.如果nextPollTimeoutMillis=0,不会休眠,立即返回。
3.如果nextPollTimeoutMillis>0,最长休眠nextPollTimeoutMillis毫秒(超时),如果期间有程序唤醒会立即返回。

3.3、最后说 handler

handler通过handler.send (message)发送消息,实际上是往构成他的 looper的 messagequeue中 插入了一条消息,在将这条消息插入 messagequeue中之前,他需 要将此消息的 target变量指向当前发它的 handler,然后looper在适当的时机取出这个消息,(looper发现构成它的 messagequeue中有消息时, looper的 loop方法就会从 messagequeue中取出这条消息),然后调 用这个消息对应的handler的dispatchmessage方法来处理这个消息(即msg.target.dispatchmessage),注意,dispatchmessage 方法是在构成 handler的 looper中的loop方法中调用的,所以处理消息的逻辑就切换到了构成handler的looper所在的线程之中了。

messagequeue加入一条消息唤醒取消息线程的三种情况
 boolean enqueueMessage(Message msg, long when) {
            ...
            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 {
                //p.target == null && msg.isAsynchronous()代表这个消息是系统消息
                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;
            }
            //需要的情况下唤醒取消息线程
            if (needWake) {
                nativeWake(mPtr);
            }
        }
        return true;
    }

1、messagequeue为空
2、当前消息不是延时消息
3、当前消息执行时间小于队头消息执行时间

(hanlder的构成是需要一个 looper,主线程 之中,在activitythread的main方法中(程序入口)通过 looper.preparemainlooper在主线 程中存储一个 looper,而在子线程之中,我们则需要手动的通过 looper的 prepare在子线程中存储一个 looper,然后通过 looper.loop 开启一个消息循环)。

4、主线程中的handler

android系统中的一个例子就是主线程中的所有操作都是通过主线程中的handler去处理的。例如activity的生命周期方法调用就是通过主线程中的handler去处理的。
在app的主线程中有一个类是activitythread,这个类中有一个main方法是app程序的入口,在main方法中使用Looper.prepareMainLooper(),在主线程中设置了一个looper,然后创建了一个applicationthread的线程用于和server进程中applicationthreadproxy进行进程通信,最后调用了Looper.loop()开启消息循环。
在activity的生命中期中,比如说系统服务ActivityManagerService调用applicationthreadproxy通过Binder给当前app进程中的applicationthread发送了一个暂停activity的操作。app进程中的applicationthread便会通过在主线程中的handler将这个暂停activity的消息插入到主线程的messagequeue中去处理。

5、主线程的死循环一直运行是不是特别消耗CPU资源呢?

这里就涉及到Linux pipe/epoll机制,在主线程的MessageQueue没有消息时,主线程便阻塞在loop的queue.next()中的nativePollOnce()方法里,相当于java层的线程waite机制,此时主线程会释放CPU资源进入休眠状态,直到下个消息到达时调用nativewake,通过往pipe管道写端写入数据来唤醒主线程工作。相当于java层的notify机制,去唤醒主线程,然后处理消息,所以主线程大多数时候都是处于休眠状态,并不会消耗大量CPU资源。
从looper取消息的过程,可以看出取消息的线程大部分时候处于阻塞状态,不会消耗cpu资源。

6、 Android中为什么主线程不会因为Looper.loop()里的死循环导致(anr)卡死?

理解1:looper死循环是不断的往构成它的消息队列中取消息,如果当前队列中没有消息,或者队列中的消息不需要现在立即处理,looper所在的线程就进入wait状态,释放cpu资源,其他的线程仍可处理事件。比如说applicationthread仍可接收服务进程中的消息来处理,如果这个消息需要在主线程中处理,它就会调用主线程中的handler,将这个消息加到主线程的消息队列中去处理。

理解2:looper取消息的过程是先wait一段时间(这段时间是messagequeue队首消息的执行时间减去当前时间),然后醒来从messagequeue中取出队首消息进行执行,wait过程中主线程是释放cpu资源的,其他的线程(applicationthread)仍可处理事件。

理解3:(首先主线程中的死循环不会导致app anr,它会使得主线程阻塞在messagequeue的next中的nativePollOnce()方法里,当有消息来时就会唤醒主线程进行消息处理,即使主线程在休眠的时候也有其他的线程(applicationthread)在处理事件。)

首先Anr和死循环不是一个概念。
1、主线程的工作就是处理主线程中的message,所有需要到主线程执行的操作都是通过主线程的向主线程的messagequeue加入一条消息,looper在适当的时机取出这条消息,来执行的,如果不是一个死循环,那么loop取出一条消息,执行完一条消息后,主线程就退出了,正是有这个死循环,它才保证了主线程不会退出,并且能处理队列中所有的消息。所以这个死循环是一个消息处理机制。

2、而anr原因是,主线程中messagequeue中一个message的处理时间过长,导致接下来的某类消息无法处理,比如说一个消息的处理时间超过了5秒,导致用户的输入无法响应,才会出现anr。

3、另外,从looper取消息的过程来看,只有当此刻有需要执行的消息时,主线程才将此消息取出来执行,否则就进入休眠状态,释放cpu。(就算不进入休眠一直循环,如果手机是多核,也是不会卡死的,只是主线程在不停的运行代码,消耗了更多资源)

为什么主线程中会采用死循环呢?

线程是一段可执行的代码,当可执行代码执行完成后,线程生命周期便该终止了。而对于主线程,我们是绝不希望会被运行一段时间就退出,所以采用死循环保证它不会被退出。

7、handler.postDelayed(Runnable r, long delayMillis)

handler.postDelayed在message加入到messagequeue中之前,会计算出这个消息的执行时间SystemClock.uptimeMillis() + delayMillis,(SystemClock.uptimeMillis()是开机到现在的时间(毫秒)),然后通过enqueueMessage 将message和其执行的时间一起添加进messagequeue,在enqueueMessage方法中会根据这个消息的执行时间去将这个消息插入到适当的位置,简单的说,messagequeue是按消息的执行时间message.when排序的。如果插在队列中间,说明该消息不需要马上处理,不需要由这个消息来唤醒队列。 如果插在队列头部(或者when=0),则表明可能要马上处理这个消息。如果当前队列正在堵塞,则需要唤醒它进行处理。 通过nativeWake方法唤醒队列。

8、如何保证延时消息精确执行?

1、从looper取消息过程来看,
2、从加入一条新的消息过程来看。
这两个过程都不存在任何延迟

8、ThreadLocal

ThreadLocal 可以在多个线程内存储数据,使用ThreadLocal存储的数据在多个线程之间是隔离的,因为它是将数据存储在每个线程内的ThreadLocalMap中。

9、同步屏障,同步消息,异步消息

同步消息就是我们平时发送的消息,异步消息一般是系统发送的消息

同步屏障就是给消息队列发送了一个屏障信息(target == null),消息队列在处理到这个屏障信息时就开启了”同步屏障”模式。在该模式下,只返回异步消息给 Looper 处理,屏蔽同步消息。

在处理完异步消息队列后,即使消息队列中还有同步消息也会通过nativePollOnce()进入线程阻塞状态。直到有新的异步消息进来。除非解除同步屏障模式,同步消息才能得到处理。

简单的说就是,发现了同步屏障消息,就只处理异步消息,不处理同步消息,直到同步屏障被移除。

view的刷新用到了同步屏障,因为界面刷新事件应处在第一优先级。

参考文章

8.1、handler.postDelayed(Runnable r, long delayMillis):https://stevendxc.github.io/Blog/2015/01/18/postDelayed/
8.2、handler流程:https://www.jianshu.com/p/8862bd2b6a29
8.3、handler系列问题:https://www.zhihu.com/question/34652589
8.4、https://segmentfault.com/a/1190000022551209
8.5https://peterxiaosa.github.io/2020/07/15/Handler%E6%9C%BA%E5%88%B6%E4%B9%8B%E6%B6%88%E6%81%AF%E7%9A%84%E5%90%8C%E6%AD%A5%E5%B1%8F%E9%9A%9C/

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

推荐阅读更多精彩内容