天天看點

EventBus源碼解析(一)——擷取EventBus對象

個人部落格:haichenyi.com。感謝關注

簡介

我們先來看一下他的類注釋

/**
 * EventBus is a central publish/subscribe event system for Android. Events are posted ({@link #post(Object)}) to the
 * bus, which delivers it to subscribers that have a matching handler method for the event type. To receive events,
 * subscribers must register themselves to the bus using {@link #register(Object)}. Once registered, subscribers
 * receive events until {@link #unregister(Object)} is called. Event handling methods must be annotated by
 * {@link Subscribe}, must be public, return nothing (void), and have exactly one parameter
 * (the event).
 *
 * @author Markus Junginger, greenrobot
 */
           

  英語不是很好,大緻講一下這段話是什麼意思:EventBus是重要的釋出/訂閱的Android事件系統。事件被釋出給總線,這個總線将這個事件傳遞給跟他比對類型的訂閱者。接收事件必須在總線使用的時候注冊他們。一旦注冊,訂閱者就會一直接收事件,直到他們被取消注冊。這個接收方法必須增加注解Subscribe辨別,必須是public,傳回類型是void,并且隻有一個參數。 簡單的來說,就是用之前必須先注冊,然後接收方法必須有Subscribe注解,必須是public,傳回類型是void并且隻有一個參數

簡單用法

第一步:依賴

第二步:注冊與反注冊

//注冊,在onCrate裡面
EventBus.getDefault().register(this)
//反注冊,在onDestory裡面
EventBus.getDefault().unregister(this)
           

第三步:接收方法

@Subscribe
public void handle(MyClothes myClothes){
    //你的具體邏輯
}
           

第四步:發送

EventBus.getDefault().post(new MyClothes())
           

  經過上面三步,你就可以正常使用EventBus了,前面兩步要在一個類裡面,因為接收之前,必須要注冊,可以在任意的地方post

源碼解析—getDefault()

public static EventBus getDefault() {
        if (defaultInstance == null) {
            synchronized (EventBus.class) {
                if (defaultInstance == null) {
                    defaultInstance = new EventBus();
                }
            }
        }
        return defaultInstance;
    }
           

  可以看到這裡使用的是雙重校驗鎖的單例模式,保證不同的線程調用該方法得到的都是同一個EventBus執行個體。

EventBus()

看到上面的單例模式之後,我們再來瞅瞅單例模式裡面調用的構造方法

public EventBus() {
        this(DEFAULT_BUILDER);
    }
           

這裡他的空參數的構造方法裡面調用的是一個參數的構造方法,我們來看看這個參數是什麼?

private static final EventBusBuilder DEFAULT_BUILDER = new EventBusBuilder();
           

EventBusBuilder()

EventBusBuilder() {
    }
           

這個builder的構造方法裡面什麼都沒有,也就是說沒有初始化任何變量,那我們看一看他的變量,這裡我就說一個:

private final static ExecutorService DEFAULT_EXECUTOR_SERVICE = Executors.newCachedThreadPool();

ExecutorService executorService = DEFAULT_EXECUTOR_SERVICE;
           

Executors.newCachedThreadPool() 建立的是一個可緩存的線程池,如果線程池長度超過處理需要,可靈活回收空線程池,若無回收,可建立線程。

接下來,我們再來看看隻有EventBusBuilder參數的構造方法

EventBus(EventBusBuilder builder)

EventBus(EventBusBuilder builder) {
        subscriptionsByEventType = new HashMap<>();
        typesBySubscriber = new HashMap<>();
        stickyEvents = new ConcurrentHashMap<>();
        mainThreadPoster = mainThreadSupport != null ? mainThreadSupport.createPoster(this) : null;
        backgroundPoster = new BackgroundPoster(this);
        asyncPoster = new AsyncPoster(this);
        ...
    }
           

  講到這裡,很明顯,他這裡用的是建造者模式,跟我們之前講的Luban的模式是一樣的,這個建造者模式,我就不講了。講Luban的時候講過的

  這裡我列出來的6個變量,其他變量并沒有列出來,因為,其他變量都是builder裡面的指派,沒有啥好講的。我們來看看這6個成員變量的類型

private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
private final Map<Object, List<Class<?>>> typesBySubscriber;
private final Map<Class<?>, Object> stickyEvents;
private final Poster mainThreadPoster;
private final BackgroundPoster backgroundPoster;
private final AsyncPoster asyncPoster;
           

意義:

  1. subscriptionsByEventType:可以看到這是一個是以event的class為key,以subscribe的list為value的map,有的人可能不知道CopyOnWriteArrayList,這是ArrayList的一個線程安全變種。(這裡,有人會點到Subscription裡面去看一下,可以看到就是一個類,封裝了訂閱者和訂閱方法,重寫了hashcode和equal方法)
  2. typesBySubscriber:這是以訂閱者類為key,以event的list為value的map,在注冊和反注冊的時候用的到
  3. stickyEvents:粘性事件,以event的class為key,訂閱者為value的map
  4. 後面這三個Poster都是用來處理粘性事件的

  我們說了這麼多成員變量。我們知道這裡的EventBusBuilder就是給EventBus初始化成員變量的,辣麼,我們可不可以不用getDefault,擷取eventBus對象呢?

EventBus build1 = EventBus.getDefault();

EventBus build2 = EventBus.builder().build();
           

這兩個build的差別是什麼呢?我們可以點到build()方法裡面去看一下:

public EventBus build() {
        return new EventBus(this);
    }
           

他這裡是直接new出來的,并沒有單例,是以每次使用的都是new一個新的對象,而通過getDefault,獲得是同一個對象

繼續閱讀