• RingBuffer：基於陣列的快取實現，也是建立sequencer與定義WaitStrategy的入口
• Disruptor:持有RingBuffer、消費者執行緒池Executor、消費者集合ConsumerRepository等引用
• Sequence：

1. 通過順序遞增的序號來編號，管理進行交換的資料（事件）
2. 對資料（事件）的處理過程總是沿著序號逐個遞增處理
3. 一個Sequence用於跟蹤標識某個特定的事件處理著（RingBuffer、Producer、Consumer）的處理進度
4. 可以看成是一個AtomicLong用於標識進度
5. 防止不同Sequence之間cpu快取偽共享（Flase Sharing）的問題

• Sequencer:

1. 真正Disruptor核心
2. 有兩個實現：SingleProducerSequencer、MultiProducerSequencer
3. 主要實現生產者和消費者之間快速、正確地傳遞資料的併發演算法

• Sequence Barrier

1. 用於保持對RingBuffer的Main Published Sequence（Producer）和Consumer之間的平衡關係；
2. 還定義了決定Consumer是否還有可處理的事件的邏輯

• WaitStrategy

1. 決定一個消費者將如何等待生產者將Event置入Disruptor
2. 主要策略：BlockingWaitStategy、SleepingWaitStategy、YieldingWaitStategy
3. BlockingWaitStategy：最低效，對cpu消耗最小並且在各種部署中提供更加一致的效能表現
4. SleepingWaitStategy：效能表現跟BlockingWaitStategy差不多，對cpu消耗類似，但對生產者執行緒影響最小，適合用於非同步日誌類似場景
5. YieldingWaitStategy:的效能最好的，適合用於低延遲的系統。在要求極高效能且事件處理線束小於cpu邏輯核心數的場景中，推薦使用此策略，如cpu開啟超執行緒的特性（推薦
   ）

• Event:

1. 從生產者到消費者過程中所處理的資料單元
2. Disruptor中沒有程式碼表示Event，因為它完全是由使用者自定義的

• EventProcessor：

1. 主要事件迴圈，處理Disruptor中的Event，擁有消費者的Sequence
2. 他有一個實現類，BatchEventProcessor，包含event loop有效實現，並且將回調到一個EventHandler介面的實現物件

• EventHandler：由使用者實現並且代表Disruptor中的一個消費者的介面，也是我們消費者邏輯都毒液寫在這裡
• WorkProcessor:確保每個Sequence只被一個processor消費，在同一個WorkPool中處理多個WorkProcessor不會浪費同樣的Sequence。

Disruptor圖解

相關推薦