一、EventBus 中主线程支持类

如果订阅方法的线程模式被设置为 ASYNC , 则不管在哪个线程中发布消息 , 都会将事件放入队列 , 通过线程池执行该事件 ;

public class EventBus {private void postToSubscription(Subscription subscription, Object event, boolean isMainThread) {// 获取该 订阅方法 的线程模式 switch (subscription.subscriberMethod.threadMode) {case ASYNC:asyncPoster.enqueue(subscription, event);break;default:throw new IllegalStateException("Unknown thread mode: " + subscription.subscriberMethod.threadMode);}}
}

二、EventBus 中 AsyncPoster 分析

AsyncPoster 分析 : 在 EventBus 中 , 定义了 AsyncPoster asyncPoster 成员变量 , 在构造函数中进行了初始化操作 ;

public class EventBus {private final AsyncPoster asyncPoster;EventBus(EventBusBuilder builder) {asyncPoster = new AsyncPoster(this);}
}

三、AsyncPoster 线程池 Runnable 任务类

AsyncPoster 实现了 Runnable 接口 , 在 run 方法中 , 调用 eventBus.invokeSubscriber(pendingPost) 执行订阅方法 ;

将该 Runnable 实现类 , 直接传递给线程池 , 即可执行 ;

/*** Posts events in background.* * @author Markus*/
class AsyncPoster implements Runnable, Poster {private final PendingPostQueue queue;private final EventBus eventBus;AsyncPoster(EventBus eventBus) {this.eventBus = eventBus;queue = new PendingPostQueue();}public void enqueue(Subscription subscription, Object event) {// 获取 PendingPost 链表PendingPost pendingPost = PendingPost.obtainPendingPost(subscription, event);// 将 订阅者 和 事件 加入到 PendingPost 链表中 queue.enqueue(pendingPost);// 启动线程池执行 AsyncPoster 任务eventBus.getExecutorService().execute(this);}@Overridepublic void run() {// 从链表中取出 订阅者PendingPost pendingPost = queue.poll();if(pendingPost == null) {throw new IllegalStateException("No pending post available");}// 执行订阅方法eventBus.invokeSubscriber(pendingPost);}}

【EventBus】EventBus 源码解析 ( 事件发送 | 线程池中执行订阅方法 )相关推荐

Java Executor源码解析(3)—ThreadPoolExecutor线程池execute核心方法源码【一万字】
基于JDK1.8详细介绍了ThreadPoolExecutor线程池的execute方法源码! 上一篇文章中,我们介绍了:Java Executor源码解析(2)-ThreadPoolExecutor ...
Java Executor源码解析(7)—Executors线程池工厂以及四大内置线程池
详细介绍了Executors线程池工具类的使用,以及四大内置线程池. 系列文章: Java Executor源码解析(1)-Executor执行框架的概述 Java Executor源码解析(2)-T ...
【EventBus】EventBus 源码解析 ( 事件发送 | postToSubscription 方法 | EventBus 线程模式处理细节 )
文章目录一.事件发送 postSingleEventForEventType 方法二.事件发送 postToSubscription 方法三.事件发送 invokeSubscriber 方法一 ...
ScheduledThreadPool 源码解析——定时类线程池是如何工作的
文章目录引言一.ScheduledThreadPool 使用示例 1. 延时类的定时任务 `schedule` 2. 延时类,固定周期执行任务 `scheduleAtFixedRate` 3. 延 ...
Unity中的UGUI源码解析之事件系统(8)-输入模块(中)
Unity中的UGUI源码解析之事件系统(8)-输入模块(中) 接上一篇文章, 继续介绍输入模块. Unity中主要处理的是指针事件, 也就是在2d平面上跟踪指针设备输入坐标的的事件, 这一类事件有鼠 ...
Executors源码解读——创建ExecutorService线程池
Executors源码解读--创建ExecutorService线程池〇.[源码版本] jdk 1.8 一.线程池概述二.线程池创建三.Executors源码解读 newFixedThreadP ...
Android之EventBus框架源码解析下（源码解析）
转载请标明出处:[顾林海的博客] 个人开发的微信小程序,目前功能是书籍推荐,后续会完善一些新功能,希望大家多多支持! 前言 EventBus是典型的发布订阅模式,多个订阅者可以订阅某个事件,发布者通过 ...
Android 源码分析之 EventBus 的源码解析
1.EventBus 的使用 1.1 EventBus 简介 EventBus 是一款用于 Android 的事件发布-订阅总线,由 GreenRobot 开发,Gihub 地址是:EventBus. ...
Android之EventBus框架源码解析上(单例模式)
转载请标明出处:[顾林海的博客] 个人开发的微信小程序,目前功能是书籍推荐,后续会完善一些新功能,希望大家多多支持! 前言 EventBus能够简化各组件间的通信,让我们的代码书写变得简单,能有效的分 ...

【EventBus】EventBus 源码解析 ( 事件发送 | 线程池中执行订阅方法 )

文章目录

一、EventBus 中主线程支持类

二、EventBus 中 AsyncPoster 分析

三、AsyncPoster 线程池 Runnable 任务类

【EventBus】EventBus 源码解析 ( 事件发送 | 线程池中执行订阅方法 )相关推荐

最新文章

热门文章