在像LMAX破坏者这样的模式中，你如何处理一个缓慢的消费者

我有一个问题，在像环形缓冲区这样的lmax破坏者中，有多个生产者和一个运行在x86 Linux上的单个消费者的情况下，该怎么办?使用类似lmax的环形缓冲区模式，您将不断覆盖数据，但如果消费者速度较慢怎么办?因此，你如何处理这样的情况，比如在10个大小的环形缓冲区0-9个环形槽中，你的消费者在槽5上，现在你的写入器准备开始写入槽15，这也是缓冲区中的槽5(即:槽5 = 15% 10)?处理这种情况的典型方法是什么?这样写程序仍然按照数据进入的顺序生成数据，而客户端也将按照相同的顺序接收数据。这就是我的问题。以下是我设计的一些细节，它工作得很好，只是我目前没有一个很好的方法来处理这个问题。有多个线程做写，一个线程做读，我不能在不改变现有设计的情况下引入多个读取线程，这超出了当前的项目范围，但是如果它们涉及到这个作为解决方案，我仍然对你的想法感兴趣。

设计细节

我有一个环缓冲区，设计目前有多个生产者线程和一个消费者线程。这部分设计是现有的，目前不能更改。我试图删除现有的排队系统使用锁自由环缓冲区。我的资料如下。

代码在x86 Linux上运行，有多个线程用于写程序，只有一个线程用于读取程序。读取器和写入器分开一个插槽，并且是std::atomic<uint64_t>，因此读取器从插槽0开始，写入器从插槽1开始，然后每个写入器首先通过调用下面的incrementSequence在写入器序列上执行原子fetch_add(1, std::memory_order::memory_order_acq_rel)来声明一个插槽，然后使用compare_and_swap循环更新读取器序列，让客户端知道这个插槽可用(参见updateSequence )。

 inline data_type incrementSequence() {                                                                                       
        return m_sequence.fetch_add(1,std::memory_order::memory_order_seq_cst);                                                  
    }   

void updateSequence(data_type aOld, data_type aNew) {                                                                        
        while ( !m_sequence.compare_exchange_weak(aOld, aNew, std::memory_order::memory_order_release, std::memory_order_relaxed)
            if  (sequence() < aNew)  {                                                                                           
                continue;                                                                                                        
            }                                                                                                                    
            break;                                                                                                               
        }                                                                                                                        
    }                   
 inline data_type sequence() const {                                                                                          
        return m_sequence.load(std::memory_order::memory_order_acquire);                                                         
    }