全面理解Handler第一步:理解消息队列,手写消息队列

前言

Handler机制这个话题,算是烂大街的内容。但是为什么偏偏重拿出来“炒一波冷饭”呢?因为自己发现这“冷饭”好像吃的不是很明白。最近在思考几个问题,发现以之前对Handler机制的了解是在过于浅显。什么问题?

  • Handler机制存在的意义是什么?能否用其他方式替换?
  • Looper.loop();是一个死循环,为什么没有阻塞主线程?用什么样的方式解决死循环的问题?

如果透彻的了解Handler,以及线程的知识。是肯定不会有这些疑问的,因为以上问题本身就存在问题。

就这俩个小问题,就发现自己在学习道路上的不扎实,所以这段时间重新理解了一下Handler。先预告一小下下,关于Handler的内容将是一个系列文章,今天这一篇内容重点在于Handler的理解,以及对消息队列的思考。

正文

1、Handler机制为了什么?

我们都知道,在Android开发中,无法在子线程中更新UI。

我们先思考一个问题?为什么不能在子线程更新UI。如果看过View绘制的源码,我们都知道不能在子线程更新UI的原因是:ViewRootImpl中有这么一个方法:

void checkThread() {
    if (mThread != Thread.currentThread()) {
        throw new CalledFromWrongThreadException(
            "Only the original thread that created a view hierarchy can touch its views.");
    }
}

很明显这是人为限制的一个操作。那我们在思考,为什么谷歌开发Android系统时要这么限制?

其实不难推测出来。对于线程来说,我们都知道线程与线程之间是内存共享的。所以如果某一时刻多个子线程同时去更新UI,那么对于绘制UI来说便成为了一个不安全的操作。为了保证UI绘制的正确性,此时势必要增加锁,以同步的方式去控制这个问题。

然而加锁的方式显然是一种牺牲性能的方式。

那么还有没有其他方案呢?很显然,最终谷歌选择了只能在主线程更新UI,应运而生的Handler机制被创造出来了。但是它也不是什么新概念,说白了就是消息队列。实现原理也很简单:只允许一个线程(主线程)去更新UI,子线程将消息放到消息队列中,由主线程去轮询消息队列,拿出消息并执行。

这也就是我们的Handler机制。

2、消息队列

这种单线程 + 消息队列的模型其实应用很广。比如在Web前端之中,对于JavaScript来说,被设计时就决定了单线程模型。假设如果 Javascript 被设计为多线程的程序,那么操作 DOM 必然会涉及到资源的竞争。此时只能加锁,那么在 Client 端中跑这么一门语言的程序,资源消耗和性能都将是不乐观的。但是如果设计成单线程,并辅以完善的异步队列来实现,那么运行成本就会比多线程的设计要小很多了。

所以我们可以看到,Handler机制的思路可以说是一个颇为常见的设计。

既然本质是消息队列,是不是我们自己也可以写一套消息队列来感受一下Handler的设计思路呢?没错,接下来让我们一起实现一套简单的消息队列:

3、手写消息队列

我们先来捋一捋思路:

Looper中创建了MessageQueue,Handler之中又通过ThreadLocal拿到主线程new出来的Looper,因此Handler就持有了MessageQueue,又因此线程间是内存共享的,所以子线程可以通过Handler去往MessageQueue之中发送Message。

Looper.loop()死循环轮询MessageQueue,拿到Message就回调其对应的方法。

这样整个Handler机制就运转起来了。接下来我们就依靠这个思路,实现自己的消息队列,为了代码更简洁,以及和Handler机制产生区别,我这里省略一些操作比如ThreadLocal之类的。

3.1、代码实现

代码结束后有解释


public class MainMQ {
private MyMessageQueue mMQ;
public static void main(String[] args) {
    new MainMQ().fun();
}

public void fun() {
    mMQ = new MyMessageQueue();
    System.out.println("当前线程id:" + Thread.currentThread().getId());
    new Thread(new Runnable() {
        @Override
        public void run() {
            // 省略try-catch
            Thread.sleep(3000);
            mMQ.post(new MyMessage(new Runnable() {
                @Override
                public void run() {
                    System.out.println("执行此条消息的线程id:" + Thread.currentThread().getId());
                }
            }));
        }
    }).start();

    loop();
    System.out.println("死循环了,我永远也不被执行~");
}

public void loop() {
    while (true) {
        // 省略try-catch
        MyMessage next = mMQ.next();
        if (next == null) {
            continue;
        }
        Runnable runnable = next.getRunnable();
        if (runnable != null) {
            runnable.run();

    }
}

}

这里没有使用Looper这种思想,因为Looper本质就是使用ThreadLocal创建一个和主线程唯一关联的Looper实例,并以此保证MessageQueue的唯一性。

知道这个原理之后,这个demo。直接在主线程中new MessageQueue(),是同样的道理,然后调用loop()方法死循环轮询MessageQueue中的Message,不为null则执行。

main()方法中start了一个子线程,然后sleep3秒后,往MessageQueue中post Message。效果很简单,我猜很多小伙伴已经猜到了:

![](http://i2.51cto.com/images/blog/201809/30/d9f45c6c1e12522dd0ad17e54bcb86d7.png?x-oss-process=image/watermark,size_16,text_QDUxQ1RP5Y2a5a6i,color_FFFFFF,t_100,g_se,x_10,y_10,shadow_90,type_ZmFuZ3poZW5naGVpdGk=)

> 贴一下MessageQueue和Message
```java
public class MyMessageQueue {
    private final Queue<MyMessage> mQueue = new ArrayDeque<>();

    public void post(MyMessage message) {
        synchronized (this) {
            notify();
            mQueue.add(message);
        }
    }

    public MyMessage next() {
        while (true) {
            synchronized (this) {
                // 省略try-catch
                if (!mQueue.isEmpty()) {
                    return mQueue.poll();
                }
                wait();
            }
        }
    }
}
public class MyMessage {
    private Runnable mRunnable;

    public MyMessage(Runnable runnable) {
        mRunnable = runnable;
    }

    public Runnable getRunnable() {
        return mRunnable;
    }
}

3.2、思考存在的问题

细心的小伙伴,可能有留意到loop()方法执行后有这么一行代码,然后效果图中并没有被打印:

System.out.println("死循环了,我永远也不被执行~");

当然这是必然的,毕竟我们的loop()是一个死循环,后边的代码是不可能被执行的。其实我们ActivityThread中调用了Looper.loop()之后,也没有任何代码了。

这里可能有小伙伴有疑问了。loop()死循环了,那么我们在主线程中的生命周期回调怎么办?岂不也不被执行了?其实不然,通过上述的消息队列,我们就能看出:我们在手写的这个demo中,loop启动前start了一个子线程,由子线程发送Message交由loop去执行。保证了消息的流畅性。

那是不是我们Android中的loop也是这种思路?没错,main中的loop启动前,的确会起一个子线程......

不要着急,关于这个问题,让我们下篇文章再展开~

结尾

今天这篇文章是全面理解Handler机制的第一篇,内容大多并没有直切到Handler机制本身,而是从外部去思考Handler的设计。而接下来的内容则是对Handler内部源码进行剖析了。

希望可以对小伙伴们有所帮助,如果感觉有收获,欢迎点赞,收藏,关注呦~

原文地址:http://blog.51cto.com/13931046/2287799

时间: 2024-10-13 02:40:22

全面理解Handler第一步:理解消息队列,手写消息队列的相关文章

手写阻塞队列(Condition实现)

自己实现阻塞队列的话可以采用Object下的wait和notify方法,也可以使用Lock锁提供的Condition来实现,本文就是自己手撸的一个简单的阻塞队列,部分借鉴了JDK的源码.Ps:最近看面经的时候发现字节跳动的面试官特别喜欢让面试者手写阻塞队列,希望本文能对大家有帮助.个人手撸如有错误还请批评指正. public class AxinBlockQueue { //队列容器 private List<Integer> container = new ArrayList<>

手写消息总线LiveDataBus,让你永无后顾之忧

做了很久的面试专题,不知道对各位需要面试和有跳槽想法的小伙伴有没有帮助,今天收集一篇关于LiveDataBus方面的文章,面试方面的收集,后续我还会持续更新如果觉得有用可以点个关注 原文链接:https://www.jianshu.com/p/e13ef9068ee0 Android四大组件和线程间通信方式有很多,比如Handler管道.广播.接口回调.rxBus.EventBus等,但是这些方式都存在一些瑕疵,(比如EvebtBus可能现在用的人比较少了,个人见解可以能算半个过时性的~个人见解

深入理解 Handler 消息机制

记得很多年前的一次面试中,面试官问了这么一个问题,你在项目中一般如何实现线程切换? 他的本意应该是考察 RxJava 的使用,只是我的答案是 Handler,他也就没有再追问下去了.在早期 Android 开发的荒芜时代,Handler 的确承担了项目中大部分的线程切换工作,通常包括子线程更新 UI 和消息传递.不光在我们自己的应用中,在整个 Android 体系中,Handler 消息机制也是极其重要的,不亚于 Binder 的地位. ActivityThread.java 中的内部类 H 就

GCD 深入理解:第一部分

虽然 GCD 已经出现过一段时间了,但不是每个人都明了其主要内容.这是可以理解的:并发一直很棘手,而 GCD 是基于 C 的 API ,它们就像一组尖锐的棱角戳进 Objective-C 的平滑世界.我们将分两个部分的教程来深入学习 GCD . 在这两部分的系列中,第一个部分的将解释 GCD 是做什么的,并从许多基本的 GCD 函数中找出几个来展示.在第二部分,你将学到几个 GCD 提供的高级函数. 什么是 GCD GCD 是 libdispatch 的市场名称,而 libdispatch 作为

一步一步理解Paxos算法

一步一步理解Paxos算法 背景 Paxos 算法是Lamport于1990年提出的一种基于消息传递的一致性算法.由于算法难以理解起初并没有引起人们的重视,使Lamport在八年后重新发表到 TOCS上.即便如此paxos算法还是没有得到重视,2001年Lamport用可读性比较强的叙述性语言给出算法描述.可见Lamport对 paxos算法情有独钟.近几年paxos算法的普遍使用也证明它在分布式一致性算法中的重要地位.06年google的三篇论文初现“云”的端倪,其中的chubby锁服务使用p

彻底理解handler的实现原理

说到handler大家都很熟悉,自己也用了很久,再此总结一下 从handler的源码角度看看handler是如何执行的. 涉及到的内容: Loop Message MessageQueue ThreadLocal Hadnler 这些东西还是挺多的.那么我们先看一个栗子吧 public class MainActivity extends Activity { private static final String TAG = "MainActivity"; @Override pro

理解 Handler

今天对Handler 做了一个整体的理解 转一篇园子里的博文 已经写的很详细 本文的思维导图: 众所周知,Handler是Android中用来处理异步的类,为什么有时候可以直接使用子线程,而有时候要使用Handler呢?网上有很多教程讲解Handler,个人认为,很多教程都将Handler复杂化,学会Handler的使用是一件非常简单的事. 1.为什么需要Handler? 我们有这样一个需求,在界面中有一个TextView,当系统启动时,每隔一秒就更改里面的文字为:“当前值: ” + i,其中i

安卓开发_深入理解Handler消息传递机制

一.概述 因为子线程的run()方法无法修改UI线程(主线程)的UI界面,所以Android引入了Handler消息传递机制,实现在新创建的线程中操作UI界面 二.消息类(Message) 消息类是存放在MessageQueue中的,而一个MessageQueue中可以包含多个Message对象 每一个Message对象可以通过Message.obtain()或者Handler.obtainMessage()方法获得 一个Message具有的属性: 属性 类型 介绍 arg1 int 存放整型数

【第二课】深入理解Handler

简要讲解Handler是做什么的 我们知道,在Android中,app启动会启动一个进程一个线程——UI线程,UI线程是主线程,并且不允许这个线程阻塞超过5秒,一旦超过5秒就会ANR. 所以较为耗时的工作(网络请求.文件读写)一般都是开一个线程来处理的,但其他的工作线程不可以直接操作Android的UI,UI只能在UI线程操作.所以就需要一个进程间通信机制来让工作线程的消息传递到UI线程,从而在UI线程改变UI. 这个通信机制就是Handler,普遍的做法就是通过重载Handler的handle