現在我正在使用disruptor,我得到了consumer-productor.It的一個簡單示例運行完美,但我不知道緩衝區大小的含義,我應該設置它的大小? private static final int BUFFER_SIZE = 4; private final RingBuffer<StockEvent> ringBuffer =
new RingBuffer<StockEven
在這個例子中https://stackoverflow.com/a/9980346/93647和這裏Why is my disruptor example so slow?干擾物的例子(在問題的末端)有1個出版商其中發佈項目和1名消費者。 但在我的情況下,消費者的工作更加複雜,需要一定的時間。所以我想要4個並行處理數據的消費者。 因此,舉例來說,如果生產商生產的數字:1,2,3,4,5,6,7,8
我沒有提供完整的列表,因爲以下代碼對於那些熟悉干擾程序的人來說已經足夠了。 問題是如果調用Next和Publish方法是線程安全的。在下面的例子之間什麼是正確的?請注意,Attach可以同時從不同的線程中調用。我有多個消費者。 示例1。鎖定一切: private object attachLock = new object();
// can be called from parall