【EventBus】EventBus 源码解析 ( 事件发送 | postToSubscription 方法 | EventBus 线程模式处理细节 )

韩曙亮

发布于 2023-03-29 17:46:14

2210

发布于 2023-03-29 17:46:14

文章目

一、事件发送 postSingleEventForEventType 方法

首先 , 在同步代码块中 , 根据事件类型获取 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 成员变量中 , 指定事件类型键 Key 对应的值 Value , 即 CopyOnWriteArrayList<Subscription> 集合 ;

每个集合元素都是 Subscription 对象 , 其中封装了一个订阅者类和一个订阅方法 ;

        synchronized (this) {
        	// 根据事件类型获取 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 
        	//	成员的值 , 即 CopyOnWriteArrayList<Subscription> 集合 
        	//	每个集合元素都是 Subscription 对象 
        	//	其中封装了 一个订阅者类 和 一个订阅方法 
            subscriptions = subscriptionsByEventType.get(eventClass);
        }

遍历上述集合 , 调用 postToSubscription 方法 , 进行事件传递后续操作 , 主要是执行订阅者中的订阅方法 ;

                	// 调用 postToSubscription 方法 , 进行事件传递后续操作
                	//	主要是执行 订阅者 中的 订阅方法 
                    postToSubscription(subscription, event, postingState.isMainThread);

EventBus.postSingleEventForEventType 方法源码 :

public class EventBus {
    private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
    private boolean postSingleEventForEventType(Object event, PostingThreadState postingState, Class<?> eventClass) {
        CopyOnWriteArrayList<Subscription> subscriptions;
        synchronized (this) {
        	// 根据事件类型获取 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 
        	//	成员的值 , 即 CopyOnWriteArrayList<Subscription> 集合 
        	//	每个集合元素都是 Subscription 对象 
        	//	其中封装了 一个订阅者类 和 一个订阅方法 
            subscriptions = subscriptionsByEventType.get(eventClass);
        }
        // 确保 CopyOnWriteArrayList<Subscription> 集合不为空 
        if (subscriptions != null && !subscriptions.isEmpty()) {
        	// 遍历上述 CopyOnWriteArrayList<Subscription> 集合 
            for (Subscription subscription : subscriptions) {
            	// 将当前的事件保存在 ThreadLocal 辅助类中 
                postingState.event = event;
                // 将当前的 订阅者 和 订阅方法 封装类 保存在 ThreadLocal 辅助类中 
                postingState.subscription = subscription;
                boolean aborted;
                try {
                	// 调用 postToSubscription 方法 , 进行事件传递后续操作
                	//	主要是执行 订阅者 中的 订阅方法 
                    postToSubscription(subscription, event, postingState.isMainThread);
                    aborted = postingState.canceled;
                } finally {
                    postingState.event = null;
                    postingState.subscription = null;
                    postingState.canceled = false;
                }
                if (aborted) {
                    break;
                }
            }
            return true;
        }
        return false;
    }
}

二、事件发送 postToSubscription 方法

订阅方法的执行 , 实际上是通过反射 , 调用订阅方法 , 并传入指定类型的事件作为参数 , 完成的 ;

invokeSubscriber(subscription, event);

EventBus.postToSubscription 方法源码 :

public class EventBus {
    private void postToSubscription(Subscription subscription, Object event, boolean isMainThread) {
    	// 获取该 订阅方法 的线程模式 
        switch (subscription.subscriberMethod.threadMode) {
            case POSTING:
            	// 不做线程切换 , 直接在发布线程中调用 
                invokeSubscriber(subscription, event);
                break;
            case MAIN:
                if (isMainThread) {
                	// 假如在主线程中 , 直接调用 
                    invokeSubscriber(subscription, event);
                } else {
                	// 假如发布线程是子线程 , 则将事件加入队列 , 通过 Handler 切换线程执行 
                    mainThreadPoster.enqueue(subscription, event);
                }
                break;
            case MAIN_ORDERED:
                if (mainThreadPoster != null) {
                    mainThreadPoster.enqueue(subscription, event);
                } else {
                    // temporary: technically not correct as poster not decoupled from subscriber
                    invokeSubscriber(subscription, event);
                }
                break;
            case BACKGROUND:
                if (isMainThread) {
                    backgroundPoster.enqueue(subscription, event);
                } else {
                    invokeSubscriber(subscription, event);
                }
                break;
            case ASYNC:
                asyncPoster.enqueue(subscription, event);
                break;
            default:
                throw new IllegalStateException("Unknown thread mode: " + subscription.subscriberMethod.threadMode);
        }
    }
}

三、事件发送 invokeSubscriber 方法

通过反射调用订阅方法 ;

EventBus.invokeSubscriber 方法源码 :

public class EventBus {
    void invokeSubscriber(Subscription subscription, Object event) {
        try {
        	// 通过反射调用 订阅方法 
            subscription.subscriberMethod.method.invoke(subscription.subscriber, event);
        } catch (InvocationTargetException e) {
            handleSubscriberException(subscription, event, e.getCause());
        } catch (IllegalAccessException e) {
            throw new IllegalStateException("Unexpected exception", e);
        }
    }
}

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2021-09-24，如有侵权请联系 cloudcommunity@tencent.com 删除

集合