disruptor-pattern

    1熱度

    1回答

    現在我正在使用disruptor,我得到了consumer-productor.It的一個簡單示例運行完美,但我不知道緩衝區大小的含義,我應該設置它的大小? private static final int BUFFER_SIZE = 4; private final RingBuffer<StockEvent> ringBuffer = new RingBuffer<StockEven

    10熱度

    1回答

    下面是否正確? 的disruptor pattern具有更好的並行性能和可擴展性,如果每個條目有多種方式來處理(IO操作或註釋),因爲可以使用多個消費者不爭進行並行化。 相反,work stealing(即本地存儲條目和竊取從其他線程的條目)具有更好的並行性能和可擴展性,如果每個條目具有唯一的一個單一的方式進行處理,因爲在破碎器中的條目disjointly分佈到多個線程模式導致爭用。 (而且是破壞

    3熱度

    1回答

    的成長考慮從LMAX建築description from Martin Fowler以下情形: 我將使用一個簡單的非LMAX的例子來說明。想象一下,你是 通過信用卡訂購果凍豆。 < ...> 在LMAX架構,你會這樣操作一分爲二。 第一次操作將捕獲訂單信息,並通過 完成向信用卡公司輸出一個事件(請求信用卡驗證)給信用卡公司 。然後,業務邏輯處理器將爲其他客戶進行 處理事件,直到其輸入事件流中收到

    2熱度

    2回答

    我學習干擾物在Java中。我不明白門控序列的意義。我知道它的核心部分是環形緩衝區,每個緩衝區都與一個序列號相關聯。

    5熱度

    3回答

    誰能告訴我什麼是Disruptor設計模式與簡單的例子?我會想知道這種設計模式的基礎知識。

    6熱度

    2回答

    在這個例子中https://stackoverflow.com/a/9980346/93647和這裏Why is my disruptor example so slow?干擾物的例子(在問題的末端)有1個出版商其中發佈項目和1名消費者。 但在我的情況下,消費者的工作更加複雜,需要一定的時間。所以我想要4個並行處理數據的消費者。 因此,舉例來說,如果生產商生產的數字:1,2,3,4,5,6,7,8

    2熱度

    2回答

    我沒有提供完整的列表,因爲以下代碼對於那些熟悉干擾程序的人來說已經足夠了。 問題是如果調用Next和Publish方法是線程安全的。在下面的例子之間什麼是正確的?請注意,Attach可以同時從不同的線程中調用。我有多個消費者。 示例1。鎖定一切: private object attachLock = new object(); // can be called from parall

    14熱度

    2回答

    我的系統有兩種不同類型的消息 - 類型A和B.每個消息具有不同的結構 - 類型A包含一個int成員,類型B包含一個雙重成員。我的系統需要將這兩種類型的消息傳遞給衆多業務邏輯線程。減少延遲非常重要,因此我正在研究使用Disruptor以機械上同情的方式將消息從主線程傳遞到業務邏輯線程。 我的問題是,干擾者只接受環形緩衝區中的一種類型的對象。這是有道理的,因爲干擾程序預先分配環形緩衝區中的對象。但是,

    8熱度

    1回答

    是否有一些示例代碼用於從標準LinkedBlockingQueue到LMAX' Disruptor架構遷移?我有一個事件處理應用程序(單個生產者,多個消費者),可能會受益於此更改。 當我的目標是最大化吞吐量而不是最小化延遲時,它是否有意義?

    1熱度

    1回答

    我一直在做一些關於高性能可靠消息系統的干擾模式的研究,作爲NServiceBus的一個狂熱的用戶,我想知道這是否可以實現它?或者也許已經有一個這樣的實現......我只是想知道其他人對此的看法?