深入理解异步加载--Handler和Looper源码解析(2)
2016-05-26 15:09
751 查看
上一章介绍了一些Handler类和Looper类,其实这些内容网上有一大把,我只不过是做了个笔记,便于以后回忆
在这章,会放出一点干货,讲讲别人没讲过的东西。
看看这个图和我们的Handler,Looper和MessageQueue模型像不像
其实我们的异步加载模型就是从多生产者,单消费者模型里借鉴出来的。
我们再看下生产者/消费者 模型的定义:
在实际的软件开发过程中,经常会碰到如下场景:某个模块负责产生数据,这些数据由另一个模块来负责处理(此处的模块是广义的,可以是类、函数、线程、进程等)。产生数据的模块,就形象地称为生产者;而处理数据的模块,就称为消费者。
单单抽象出生产者和消费者,还够不上是生产者/消费者模式。该模式还需要有一个缓冲区处于生产者和消费者之间,作为一个中介。生产者把数据放入缓冲区,而消费者从缓冲区取出数据
我们在子线程发送Message不就是生产出数据,放入MessageQueue的缓冲区,然后用Looper在主线程中取出来,用于消费。
只不过我们是使用自旋锁的形式用Looper死循环,不断的去取数据。
我们再来看下上张讲的Looper.loop()方法
我们可以看到
final Looper me = myLooper();这句代码就是用来取出Looper对象
而myLooper()的实质就是通过ThreadLocal取出当前线程中的Looper。
这里稍微介绍一下ThreadLocal
这个对象作用于是线程,根据不同线程号,在每个线程中会维护一个values数据,用于存放数据。这样的好处是不用维护一个Hash表去区分不同线程数据。每个线程有独立的副本对象。
用于我们一般使用场景都是子线程把数据交给主线程去处理的,使用的都是MainLooper,所以我们传进去的ThreadId都是UI线程的ID,取到的都是MainLooper。由于MainLooper是在U线程挂起的(自旋),所以取出来后的Message调用getTarget得到Handler对象后去处理消息内容也是在UI线程当中了。
这里有一个很重要的概念,我曾经问了很多人都似是而非,不是很理解。对象和线程是没有关系的,我们使用Handler进行异步加载其实是没有切换线程,准确的说代码也无法切换线程。我们只不过是子线程准备好了数据,放进了一个内存中共享的缓冲区(堆),然后在UI线程把数据取出来,进行了处理。也正因为这样,MessageQueue是线程不安全的,可以看到在源代码里在进插入单链表和取数据的时候都加了synchronized锁,防止数据脏读。
基于上述理论,我们完全可以实现自己的异步加载
调用
A Thread:
Looper.prepare();
Handler handler = new Handler(Looper.myLooper());
Looper.loop();
然后我们在别的线程就可以把数据交给A Thread去处理了。
顺便再提一下,串联整个异步加载过程的是MessageQueue对象。
MessageQueue是Looper的一个成员变量,Looper成员变量里取消息,然后再new Handler对象的时候,又会把Looper对象传给Handler对象,Handler就把Message都存在了Looper对应的MessageQueue里了。这样存和取就对上了。
如果对上述内容有什么疑问,可以在关键代码处打印下线程ID,就可以一目了然了
转载请注明出处,尊重别人的劳动成果
在这章,会放出一点干货,讲讲别人没讲过的东西。
看看这个图和我们的Handler,Looper和MessageQueue模型像不像
其实我们的异步加载模型就是从多生产者,单消费者模型里借鉴出来的。
我们再看下生产者/消费者 模型的定义:
在实际的软件开发过程中,经常会碰到如下场景:某个模块负责产生数据,这些数据由另一个模块来负责处理(此处的模块是广义的,可以是类、函数、线程、进程等)。产生数据的模块,就形象地称为生产者;而处理数据的模块,就称为消费者。
单单抽象出生产者和消费者,还够不上是生产者/消费者模式。该模式还需要有一个缓冲区处于生产者和消费者之间,作为一个中介。生产者把数据放入缓冲区,而消费者从缓冲区取出数据
我们在子线程发送Message不就是生产出数据,放入MessageQueue的缓冲区,然后用Looper在主线程中取出来,用于消费。
只不过我们是使用自旋锁的形式用Looper死循环,不断的去取数据。
我们再来看下上张讲的Looper.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 . . .省略下面取消息的部分 .
我们可以看到
final Looper me = myLooper();这句代码就是用来取出Looper对象
/** * Return the Looper object associated with the current thread. Returns * null if the calling thread is not associated with a Looper. */ public static Looper myLooper() { return sThreadLocal.get(); }
而myLooper()的实质就是通过ThreadLocal取出当前线程中的Looper。
这里稍微介绍一下ThreadLocal
这个对象作用于是线程,根据不同线程号,在每个线程中会维护一个values数据,用于存放数据。这样的好处是不用维护一个Hash表去区分不同线程数据。每个线程有独立的副本对象。
用于我们一般使用场景都是子线程把数据交给主线程去处理的,使用的都是MainLooper,所以我们传进去的ThreadId都是UI线程的ID,取到的都是MainLooper。由于MainLooper是在U线程挂起的(自旋),所以取出来后的Message调用getTarget得到Handler对象后去处理消息内容也是在UI线程当中了。
这里有一个很重要的概念,我曾经问了很多人都似是而非,不是很理解。对象和线程是没有关系的,我们使用Handler进行异步加载其实是没有切换线程,准确的说代码也无法切换线程。我们只不过是子线程准备好了数据,放进了一个内存中共享的缓冲区(堆),然后在UI线程把数据取出来,进行了处理。也正因为这样,MessageQueue是线程不安全的,可以看到在源代码里在进插入单链表和取数据的时候都加了synchronized锁,防止数据脏读。
基于上述理论,我们完全可以实现自己的异步加载
调用
A Thread:
Looper.prepare();
Handler handler = new Handler(Looper.myLooper());
Looper.loop();
然后我们在别的线程就可以把数据交给A Thread去处理了。
顺便再提一下,串联整个异步加载过程的是MessageQueue对象。
MessageQueue是Looper的一个成员变量,Looper成员变量里取消息,然后再new Handler对象的时候,又会把Looper对象传给Handler对象,Handler就把Message都存在了Looper对应的MessageQueue里了。这样存和取就对上了。
如果对上述内容有什么疑问,可以在关键代码处打印下线程ID,就可以一目了然了
转载请注明出处,尊重别人的劳动成果
相关文章推荐
- Linux编程学习之静态库和动态库
- Linux查看内核或系统版本总结
- centos下安装mysql5.7.5的rpm包
- CentOS系统时间同步(NTP)
- 有关tomcat内存溢出的完美解决方法
- nginx location 匹配顺序
- centos6.6 版本操作系统优化
- linux定时任务
- Linux 内核Coding Style整理
- Cannot find class [org.apache.commons.dbcp.BasicDataSource]问题
- RunLoop 的实际应用举例-AFNetworking
- hadoop2.6解决 WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform... 问题
- Ubuntu 配置Tomcat环境
- Dockerfile 属性介绍
- Mac命令行高亮
- OpenGLES---熟悉全局变量uniform,局部变量attribute,共享变量varying
- shell之while循环和文件描述符
- 详解linux下的串口通讯开发
- Apache Curator Leader选举 简单示例
- TOMCAT内存溢出及大小调整的实现方法