下面看一下多生產多消費者的模式，下面的代碼是模擬100個生產者，每個生產者生產100個事件，然后有3個消費者，同時進行消費，共消費1W個事件，

下面看一下代碼：

這邊new出了3個消費者，并把消費者數組放入workPool這個消息隊列中，然后在RingBuffer中獲取事件，進行消費：

看一下event類：Order

下面看一下生產者：

把數據生產完成后，放入ringBuffer，然后進行事件發布

在看一下消費者：

通過一個原子類進行消費的記錄查看哪個消費者消費了多少個事件，

查看一下打印的結果：

看一下最后的打印結果：

3個消費者，總共消費1000個事件，中間的協調通過SequenceBarrier進行消費協調；這種實現模式就是多消費者多生產者。需要注意的是RingBuffer和disruptor使用的范圍，RingBuffer適合使用在不復雜消費模型上面，disruptor適合使用在復雜消費模型上，例如，菱形，順序，六邊形等。

總結

以上是生活随笔為你收集整理的java无锁消费者框架_无锁并行框架多生产者多消费者模型的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。