分类导航

LMAX Disruptor—多生产者多消费者中，消息复制分发的高性能实现

发布时间：2016年12月09日作者：文章转自网络，版权归原作者所有，反馈可立刻删除 (该文来自笔记，点击查看原文)

当我们有多个消息的生产者线程，一个消费者线程时，他们之间如何进行高并发、线程安全的协调？

很简单，用一个队列。

当我们有多个消息的生产者线程，多个消费者线程，并且每一条消息需要被所有的消费者都消费一次（这就不是一般队列，只消费一次的语义了），该怎么做？

这时仍然需要一个队列。但是：

1. 每个消费者需要自己维护一个指针，知道自己消费了队列中多少数据。这样同一条消息，可以被多个人独立消费。

2. 队列需要一个全局指针，指向最后一条被所有生产者加入的消息。消费者在消费数据时，不能消费到这个全局指针之后的位置——因为这个全局指针，已经是代表队列中最后一条可以被消费的消息了。