电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛

标题: EventBus源码分析（4） [打印本页]

作者: look_w 时间: 2019-4-12 17:01 标题: EventBus源码分析（4）

post：就是把event，其实就是传入的 Javabean数据，保存在当前线程的 PostingThreadState 的 eventQueue队列中
1>：首先：判断当前是否是主线程；
2>：然后：遍历 eventQueue队列中所有的 event，其实就是遍历所有 post(param) 中传递的参数，然后调用 postSingleEvent

private void postSingleEvent(Object event, PostingThreadState postingState) throws Error {
         // 获取当前 Javabean数据所在的 Class对象
         Class<? extends Object> eventClass = event.getClass();
         // 根据eventClass获取 List<Class<?>>，其实就是 Javabean数据的当前Class、
         // 及父类和接口的Class类型，用于匹配
         // eventTypes：是所有 Class
         List<Class<?>> eventTypes = findEventTypes(eventClass);
         boolean subscriptionFound = false;

         // 遍历所有Class，在 subscriptionsByEventType中查找 subscriptions ，
         // register注册：就是把所有方法都存储到 subscriptionsByEventType集合中
         int countTypes = eventTypes.size();
         for (int h = 0; h < countTypes; h++) {
            Class<?> clazz = eventTypes.get(h);
            CopyOnWriteArrayList<Subscription> subscriptions;
            synchronized (this) {
                  subscriptions = subscriptionsByEventType.get(clazz);
            }
            if (subscriptions != null && !subscriptions.isEmpty()) {
                  // 遍历每个 subscription ，依次调用 postToSubscription
                  for (Subscription subscription : subscriptions) {
                     postingState.event = event;
                     postingState.subscription = subscription;
                     boolean aborted = false;
                     try {
                        postToSubscription(subscription, event, postingState.isMainThread);
                        aborted = postingState.canceled;
                     } finally {
                        postingState.event = null;
                        postingState.subscription = null;
                        postingState.canceled = false;
                     }
                     if (aborted) {
                        break;
                     }
                  }
                  subscriptionFound = true;
            }
         }
         if (!subscriptionFound) {
            if (eventClass != NoSubscriberEvent.class && eventClass != SubscriberExceptionEvent.class) {
                  post(new NoSubscriberEvent(this, event));
            }
         }
      }

欢迎光临电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)