Spark 2.3 源碼分析之事件總線 ListenerBus

一、事件總線介紹 Spark 定義了一個特質 ListenerBus，可以接受事件並且將事件提交到對應事件的監聽器。 該特徵主要有一個 listenersPlusTimers成員，用於維護所有註冊的監聽器，其數據結構是一個線程安全的CopyOnWriteArrayList[(L, Option[Timer])]。 該特徵還有幾個主要的函數： listener：返回listenersPlusTime

>>阅读原文<<