文章目录
一、EventBus 事件发送
- 一、EventBus 事件发送
- 二、事件发送 postSingleEvent 方法
在客户端的某个线程中 , 调用 EventBus.getDefault().post("Hello EventBus !");
方法 , 向消息中心发送消息 ;
在 EventBus
中 , 获取 ThreadLocal
数据 PostingThreadState
, 其中记录了 线程状态信息 , 其中维护了一个事件队列 List eventQueue
, 将本次传入的事件 , 加入到该事件队列中 ;
然后判断发布线程是否是主线程 , 并保存发送状态 ;
// 判断是否处于主线程
postingState.isMainThread = isMainThread();
// 保存临时状态 , 放置重复调用
postingState.isPosting = true;
EventBus.post 方法源码 :
/**
* EventBus是Java和Android的中央发布/订阅事件系统。
* 事件被发布({@link#post(Object)})到总线,总线将其传递给具有匹配处理程序的订阅者
* 事件类型的方法。
* 要接收事件,订阅者必须使用{@link#register(Object)}将自己注册到总线。
* 一旦注册,订阅服务器将接收事件,直到调用{@link#unregister(Object)}。
* 事件处理方法必须由{@link Subscribe}注释,必须是公共的,不返回任何内容(void),
* 并且只有一个参数(事件)。
*/
public class EventBus {
private final ThreadLocal currentPostingThreadState = new ThreadLocal() {
@Override
protected PostingThreadState initialValue() {
return new PostingThreadState();
}
};
/** 将给定的事件传递给事件总线 */
public void post(Object event) {
// ThreadLocal 数据
// ThreadLocal currentPostingThreadState
// PostingThreadState 可以理解成一个辅助类
PostingThreadState postingState = currentPostingThreadState.get();
// 该队列用于维护事件 , 是一个事件队列 , 队列的固有属性就是 先进先出
List eventQueue = postingState.eventQueue;
// 将传入事件加入到队列中
eventQueue.add(event);
if (!postingState.isPosting) {
// 判断是否处于主线程
postingState.isMainThread = isMainThread();
// 保存临时状态 , 放置重复调用
postingState.isPosting = true;
if (postingState.canceled) {
throw new EventBusException("Internal error. Abort state was not reset");
}
try {
while (!eventQueue.isEmpty()) {
// 发送单个事件 , 该方法是核心调用方法
postSingleEvent(eventQueue.remove(0), postingState);
}
} finally {
postingState.isPosting = false;
postingState.isMainThread = false;
}
}
}
}
二、事件发送 postSingleEvent 方法
首先 , 获取发送的事件类型 ;
// 获取发送的消息事件类型
Class eventClass = event.getClass();
然后通过 eventInheritance
变量 , 判断是否支持事件类型的父类查找 , 该值默认为 true ;
// 判断事件类型的父类 , 向事件的上一级类型查找
// 传入的是否是某个事件的父类对象
// 该值默认为 true
if (eventInheritance) {
如果支持事件类型父类查找 , 则获取当前所有的事件类型集合 , 进行单个事件的发送 ;
// 获取当前所有的 事件类型 集合
List eventTypes = lookupAllEventTypes(eventClass);
int countTypes = eventTypes.size();
for (int h = 0; h
关注
打赏
热门博文
- 【Android Gradle 插件】Gradle 自定义 Plugin 插件 ③ ( 自定义插件作用 | Android Gradle 插件的扩展 | 自定义 Extension 扩展 )
- 【Android Gradle 插件】Gradle 构建生命周期 ③ ( BuildListener 构建监听器 | TaskExecutionGraphListener 任务执行图监听器 )
- 【Android Gradle 插件】Gradle 构建生命周期 ② ( Gradle 类的添加构建生命周期监听器函数 | Gradle#addListener 函数 )
- 【Android Gradle 插件】Gradle 构建生命周期 ① ( 分析构建脚本 | 执行初始化配置 | 执行 Gradle 任务 | Project#beforeEvaluate 函数 )
- 【Android Gradle 插件】自定义 Gradle 任务 ⑨ ( 控制 Gradle 执行任务顺序 | Task#finalizedBy 函数 | 控制 Gradle 执行任务顺序示例分析 )
- 【Android Gradle 插件】自定义 Gradle 任务 ⑧ ( 控制 Gradle 执行任务顺序 | Task#shouldRunAfter 函数 | 三个函数使用场景对比 )
- 【Android Gradle 插件】自定义 Gradle 任务 ⑦ ( 控制 Gradle 执行任务顺序 | Task#dependsOn 函数 | Task#mustRunAfter 函数 )
- 【数学分析】集合 ① ( 集合概念 | 集合表示 | 常用的数集合 | 集合的表示 )
- 【数学分析】学科简介 ( 初等数学缺陷 | 微分与积分 | 学习数学分析的目的 | 数学分析与高等数学对比 )
- 【Android Gradle 插件】自定义 Gradle 任务 ③ ( Gradle 自定义任务创建方法 Project#task 函数 | Task#doFirst 函数用法 )