工业设计的网站,2021年uc秒懂网址推荐,开封网站建设报价,上海公司牌照价格2023年下面看一下多生产多消费者的模式#xff0c;下面的代码是模拟100个生产者#xff0c;每个生产者生产100个事件#xff0c;然后有3个消费者#xff0c;同时进行消费#xff0c;共消费1W个事件#xff0c;下面看一下代码#xff1a;这边new出了3个消费者#xff0c;并把消…下面看一下多生产多消费者的模式下面的代码是模拟100个生产者每个生产者生产100个事件然后有3个消费者同时进行消费共消费1W个事件下面看一下代码这边new出了3个消费者并把消费者数组放入workPool这个消息队列中然后在RingBuffer中获取事件进行消费看一下event类Order下面看一下生产者把数据生产完成后放入ringBuffer然后进行事件发布在看一下消费者通过一个原子类进行消费的记录查看哪个消费者消费了多少个事件查看一下打印的结果看一下最后的打印结果3个消费者总共消费1000个事件中间的协调通过SequenceBarrier进行消费协调这种实现模式就是多消费者多生产者。需要注意的是RingBuffer和disruptor使用的范围RingBuffer适合使用在不复杂消费模型上面disruptor适合使用在复杂消费模型上例如菱形顺序六边形等。
