Disruptor併發框架學習筆記 01

2021-09-11 07:47:56 字數 872 閱讀 7433

sequence disruptor

sequence

sequence barrier

wait strategy

event

eventprocessor

eventhandler

producer

執行簡圖:

建立乙個生產資料的工廠類,eventfactory,用於生產資料

定義事件處理的具體實現

定義用於事件處理的執行緒池

指定等待策略

waitstrategy blocking_wait = new blockingwaitstrategy();

waitstrategy sleeping_wait = new sleepingwaitstrategy();

waitstrategy yielding_wait = new yieldingwaitstrategy();

例項化disruptor,配置引數,繫結事件

發布事件:

事件只有在提交之後才會通知 eventprocessor 進行處理;

public class messageeventproducer 

public void ondata(final asyncevent asyncevent) finally }}

關閉 disruptor:

併發框架Disruptor

martin fowler在自己 上寫了一篇 lmax架構 的文章,在文章中他介紹了lmax是一種新型零售金融交易平台,它能夠以很低的延遲產生大量交易。這個系統是建立在jvm平台上,其核心是乙個業務邏輯處理器,它能夠在乙個執行緒裡每秒處理6百萬訂單。業務邏輯處理器完全是執行在記憶體中,使用事件源驅動...

併發程式設計 Disruptor併發框架

disruptor是什麼?disruptor是乙個高效能的非同步處理框架,或者可以認為是最快的訊息框架 輕量的jms 也可以認為是乙個觀察者模式的實現,或者事件監聽模式的實現 disruptor入門程式 在disruptor中實現helloworld入門程式的步驟 1.建立乙個event類 資料 2...

併發框架Disruptor譯文

martin fowler在自己 上寫了一篇lmax架構的文章,在文章中他介紹了lmax是一種新型零售金融交易平台,它能夠以很低的延遲產生大量交易。這個系統是建立在jvm平台上,其核心是乙個業務邏輯處理器,它能夠在乙個執行緒裡每秒處理6百萬訂單。業務邏輯處理器完全是執行在記憶體中,使用事件源驅動方式...