disruptor-pattern

    1熱度

    1回答

    從下面的代碼或ValueMutationEventHandler,爲什麼我不能future2.get(),等待future2完成,然後得到結果? 如果我做future2.get(),它會一直等下去。 import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier;

    18熱度

    5回答

    我希望我能得到最簡單的示例代碼,它將顯示如何使用LMAX干擾程序(http://code.google.com/p/disruptor/)。 不幸的是,每段代碼都過時了。有人知道,我在哪裏可以找到最新的howto(最好沒有DSL)?

    4熱度

    2回答

    Disruptor只能用於POD數據類型嗎? 我的意思是應該Disruptor<T>只能用於T取值byte[], int[], etc? 我的疑問是,如果我們使用T其中有Object引用作爲其成員變量,我們需要new這些成員變量,這將成爲堆。 這將再次導致緩存未命中,因爲成員變量可能位於堆的完全獨立的部分。 那麼我的想法是否正確Disruptor<T>應該只用於T屬於一組普通的舊數據類型(PODs

    27熱度

    2回答

    由於RingBuffer預先分配給定類型的對象,因此如何使用單個環形緩衝區來處理各種不同類型的消息? 您不能創建新的對象實例來插入ringBuffer,並且這會破壞預先分配的目的。 所以,你可以在異步消息傳遞模式3個消息: NewOrderRequest NewOrderCreated NewOrderRejected 所以我的問題是如何在你的意思是使用干擾器模式真實世界的消息系統? 由於 鏈接:

    4熱度

    1回答

    我知道有些人正在使用C++端口。 C#端口可能嗎?特別是我正在考慮在C#中只有32位的volatile字段的限制。如果這是唯一的問題,是否有任何事情認爲寫入該環形緩衝區只有32位允許的插槽數量是值得的。在系統的整個生命週期內,事件發生的次數要少得多。我有這個權利嗎?我們可以在某個點回到0嗎? 預先感謝您。

    3熱度

    1回答

    我也在考慮在應用程序中集成干擾模式。在我開始使用干擾程序之前,我有點不確定幾件事 我有3個生產者,主要是一個FIX線程,對請求進行反序列化。另一個隨着市場走勢而不斷修改訂單價格的線索。此外,我們還有一個線程負責對從GUI應用程序發送的請求進行反序列化。所有三個線程當前寫入阻塞隊列(因此​​我們看到了很多爭論的隊列) 有關單個作家原則破壞者會談,並從我已閱讀,擴展方法最好。有什麼辦法可以讓上述三個線

    1熱度

    1回答

    要開發商/ LMAX干擾器的http://code.google.com/p/disruptor/用戶: 我的問題: 任何人都可以提出一個方法超時功能如何適用於干擾物如使用EventHandler? 這是在我的工作中想出了一個場景: 發件箱 - 從服務器 ACK處理程序收到ACK消息 - 在網絡上 收件箱發送到服務器的消息 - 馬克發件箱郵件作爲被ACK 超時處理程序 - 標記發件箱消息作爲NAC

    195熱度

    5回答

    我想了解disruptor pattern。我觀看了InfoQ的視頻並試圖閱讀他們的論文。我知道有一個環形緩衝區,它被初始化爲一個非常大的數組,以利用緩存局部性,消除新內存的分配。 這聽起來像有其跟蹤位置的一個或多個原子整數。每個'事件'似乎都得到一個唯一的ID,它的位置是通過找到其相對於環的大小等的模數而找到的。等等。 不幸的是,我沒有一個直觀的意義它是如何工作的。我做了很多交易應用程序,並研究