Android中的消息机制 - 密切协作的 Handler,Looper,MessageQueue

2024-05-13 21:18

本文主要是介绍Android中的消息机制 - 密切协作的 Handler,Looper,MessageQueue,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Android中的消息机制 - 密切协作的 Handler,Looper,MessageQueue


1.消息机制概述

知其然,知其所以然 ,既然说到消息机制,那么我们就要弄明白了,为什么需要用到handle机制?
我们知道,Android中的消息机制主要用来更新ui操作 ,可是为什么更新ui操作一定要放到消息机制来实现呢?
void checkThread() {if (mThread != Thread.currentThread()) {throw new CalledFromWrongThreadException("Only the original thread that created a view hierarchy can touch its views.");}}
我们知道在更新ui的时候,程序会去检查当前线程是否是当前线程,也就是 ui 线程,否则就会抛出异常。
至于为什么google的Android工程师不允许我们再子线程中更新ui呢,那是因为Android中的ui操作不是线程安全的,如果在多线程下去操作ui而不做任何保护措施,那么就会导致 ui 操作导致不可预期的效果 。
如何解决这种并发的操作ui的问题,1,可以通过加锁,加锁的方式虽然也能够实现,但是使用枷锁却又两个问题存在 
a.加锁会降低ui的访问效率
  b.会让ui操作的逻辑变得复杂
大概是基于这种考虑吧(个人猜测) ,Android 系统工程师 在 ui的更新上,采取了 handler 的机制

2.Android中的消息机制实现

提到Android中的消息机制,不可避免的就要提到handler ,handler作为系统提供给我们使用的上层接口,是我们操作ui的主要交互对象。

2.1.handler的用法

		Handler handler = new Handler(){
			public void handleMessage(Message msg) {
				switch (msg.what) {
				case 1:
					//执行更新ui操作
					break;
				}
			}
		};
		
		new Thread(){
			public void run() {
				
				//执行复杂的计算逻辑
				Message obtain = Message.obtain();
				obtain.what = 1;
				obtain.obj = "更新ui";
				handler.sendMessage(obtain);
			};
		}.start();
如上,当我们在子线程中计算一个复杂的操作,然后需要更新ui的时候,那么我们可以通过handler的handleMessage方法来更新ui操作,两者密切配合,完成更新操作。

2.2.在子线程中使用handler

我们看下面这个代码
		new Thread(){public void run() {Handler handler = new Handler();};}.start();
当子线程的run方法执行的时候,我们满怀期待的去new 一个handler 突然就会发现,what a fuck ,竟然报错了

通过异常信息发现我们没有调用 looper.prepare() ,这是什么鬼 ,通过观察源码发现,

我们接着看 myLooper()的实现




sThreadLocal 是什么 ? ThreadLocal ,我们暂且不管,现在从 sThreadLocal 中取不到looper实例,那么既然 异常信息提示我们调用 Looper.prepare() 我们暂且去看看,


噢,原来是在这里。那我们现在尝试 去调用吧 。
		new Thread(){public void run() {Looper.prepare();Handler handler = new Handler();};}.start();
好了,到此为止,我们终于可以在子线程中 创建一个handler实例了,注意,这里我说的是创建实例,并不代表这样就可以正常使用了。

2.3.子线程中handler的正确使用姿势


以上就是在子线程中创建handler的正确姿势,我们发现 多了一行 Looper.loop() 方法,首先我们看下他的实现

通过looper的代码实现我们可以发现,looper.loop()方法 通过不断的循环,不停的从messageQueue中获取message 进行分发,最终 通过 handler的 dispatchMessage 分发出去我们的消息

我们通过重写handler的 handMessage方法实现自己的业务逻辑

3.Handler,Looper,MessageQueue 之间协作关系和工作流程


图片来源:http://gityuan.com/2015/12/26/handler-message-framework/

以上就是 handler通信机制的流程图,感谢 gitYuan 的图片。

一次handler通信的过程可以分为如下几个步骤 

1.handler 通过sendMessage 方法 发出一个message对象,然后将message对象加入内部的MessageQueue中(链表实现)

2.Looper.looper() 通过不停的循环,处理消息 ,然后将message分发出去交给对应的handler处理

3.使用者通过重写handleMessage 方法处理业务逻辑

4.关于threadLocal 

threadLocal一个泛型类,通过threadLocal我们可以在指定的线程中保存数据。他可以实现线程隔离,分别为不同的线程保存数据副本,做到互不干扰。

4.1  threadLocal在handler中的使用

Looper 类 中维护着一个变量数据
static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();
sThreadLocal 为每一个线程保存了一份looper对象实例
private Looper(boolean quitAllowed) {mQueue = new MessageQueue(quitAllowed);mThread = Thread.currentThread();
}
同时呢,looper又是一个私有的构造方法,也就意外着我们不能够在外部显示的构造looper实例。在上面的例子中,我们通过looper.prepare()在线程中使用handler,
下面是prepare的方法实现
private static void prepare(boolean quitAllowed) {if (sThreadLocal.get() != null) {throw new RuntimeException("Only one Looper may be created per thread");}sThreadLocal.set(new Looper(quitAllowed));}
通过sThreadLocal去获取一个looper对象,如果looper不为空抛出异常(也就说明,每一个线程中只能存在一个looper对象),否则呢 就新增一个looper。
我们先看下这个没有任何参数的get方法
public T get() {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);if (map != null) {ThreadLocalMap.Entry e = map.getEntry(this);if (e != null)return (T)e.value;}return setInitialValue();}
首先会去获取当前线程的ThreadLocalMap 对象,这个对象中维护了一个Entry数组,entry中有维护了value 对象, 也就是 我们的 looper对象。

5.关于handler的认识和理解

1.每个线程中只能有一个looper对象

2.子线程中使用handler必须首先创建looper

3.一个线程中可以有多个handler对象,message对象维护了分发的handler对象实例,所以多个handler的分发不会有问题

4.threadLocal机制保证了每个线程内部只会维护了一个looper对象


问题: 既然looper维护了一个无限循环的队列,为什么主线程不会因此而假死或者卡死呢 ? 同样求解

6.参考

1. gityuan: Android消息机制1
2.《Android开发艺术探索》
3. handler,looper,message,threadLocal源码



这篇关于Android中的消息机制 - 密切协作的 Handler,Looper,MessageQueue的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/986852

相关文章

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

Android ClassLoader加载机制详解

《AndroidClassLoader加载机制详解》Android的ClassLoader负责加载.dex文件,基于双亲委派模型,支持热修复和插件化,需注意类冲突、内存泄漏和兼容性问题,本文给大家介... 目录一、ClassLoader概述1.1 类加载的基本概念1.2 android与Java Class

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED(默认)2.2 SUPPORTS2

MySQL中的锁机制详解之全局锁,表级锁,行级锁

《MySQL中的锁机制详解之全局锁,表级锁,行级锁》MySQL锁机制通过全局、表级、行级锁控制并发,保障数据一致性与隔离性,全局锁适用于全库备份,表级锁适合读多写少场景,行级锁(InnoDB)实现高并... 目录一、锁机制基础:从并发问题到锁分类1.1 并发访问的三大问题1.2 锁的核心作用1.3 锁粒度分

java向微信服务号发送消息的完整步骤实例

《java向微信服务号发送消息的完整步骤实例》:本文主要介绍java向微信服务号发送消息的相关资料,包括申请测试号获取appID/appsecret、关注公众号获取openID、配置消息模板及代码... 目录步骤1. 申请测试系统2. 公众号账号信息3. 关注测试号二维码4. 消息模板接口5. Java测试

Redis的持久化之RDB和AOF机制详解

《Redis的持久化之RDB和AOF机制详解》:本文主要介绍Redis的持久化之RDB和AOF机制,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录概述RDB(Redis Database)核心原理触发方式手动触发自动触发AOF(Append-Only File)核

Android DataBinding 与 MVVM使用详解

《AndroidDataBinding与MVVM使用详解》本文介绍AndroidDataBinding库,其通过绑定UI组件与数据源实现自动更新,支持双向绑定和逻辑运算,减少模板代码,结合MV... 目录一、DataBinding 核心概念二、配置与基础使用1. 启用 DataBinding 2. 基础布局

Android ViewBinding使用流程

《AndroidViewBinding使用流程》AndroidViewBinding是Jetpack组件,替代findViewById,提供类型安全、空安全和编译时检查,代码简洁且性能优化,相比Da... 目录一、核心概念二、ViewBinding优点三、使用流程1. 启用 ViewBinding (模块级

PostgreSQL中MVCC 机制的实现

《PostgreSQL中MVCC机制的实现》本文主要介绍了PostgreSQL中MVCC机制的实现,通过多版本数据存储、快照隔离和事务ID管理实现高并发读写,具有一定的参考价值,感兴趣的可以了解一下... 目录一 MVCC 基本原理python1.1 MVCC 核心概念1.2 与传统锁机制对比二 Postg

Maven 配置中的 <mirror>绕过 HTTP 阻断机制的方法

《Maven配置中的<mirror>绕过HTTP阻断机制的方法》:本文主要介绍Maven配置中的<mirror>绕过HTTP阻断机制的方法,本文给大家分享问题原因及解决方案,感兴趣的朋友一... 目录一、问题场景:升级 Maven 后构建失败二、解决方案:通过 <mirror> 配置覆盖默认行为1. 配置示