使用 Disruptor 時我們必須決定資料要怎樣在 Consumer 間流動,這有些常用的 Pattern 可供參考,只要熟悉這些 Pattern 那 Consumer 間有多複雜的協作應該都不是問題。
這邊要介紹的是 Diamond: 1P – 3C,一個 Producer 負責生產資料,兩個 Consumer 同時消費資料後,再交由第三個 Consumer 處理。其依賴關係圖會像這樣:

可以進一步簡化成下面這樣:

透過 DSL 的方式撰寫,只要同時將兩個 EventHandler 帶入 HandleEventWith,再用 Then 方法串接第三個 EventHandler 即可,像是下面這樣:
1 | ... |
是改用 Non-DSL 撰寫的話,本來的依賴關係圖形就會變成下面這樣:

用程式來寫,就是建立一個 Barrier 讓兩個 EventProcessor 共用,然後再建立一個 Barrier 接著前兩個 EventProcessor 的 Sequence, 將之帶入建立第三個 EventProcessor。
1 | ... |
運行起來可以看到有三個 Handler,分別在不同的執行緒上運作,Producer 產生的每一筆資料都會先同時經過前兩個 Handler,再送到最後一個 Handler 做處理。所以這邊可以看到不管哪個 Sequence,第三個 Handler 一定顯示在最後面,而前兩個 Handler 顯示的順序則不固定。
