如何基于QSemaphore实现生产者消费者环形缓冲区的覆写策略

完全可以基于QSemaphore实现你需要的覆写（overwrite） 策略，无需完全替换实现方案，仅需要调整原有信号量的控制逻辑，补充读写指针的越界处理即可。

核心逻辑 #

当生产者无空闲块可写时，主动移动消费者读指针，丢弃最旧的1块（或多块）待消费数据，将对应空间划为空闲空间后写入新数据，实现「旧数据丢弃、新数据优先保留」的需求。

基础组件定义 #

• 定义环形缓冲区总块数N，按你需要的数个MTU大小计算对应块数即可
• 两个信号量：
  • freeSlots：当前空闲块数量，初始值为N
  • usedSlots：当前待消费的已写入块数量，初始值为0
• 两个受保护的下标变量：
  • 读指针rIndex：消费者下一个要读取的块下标，初始值为0
  • 写指针wIndex：生产者下一个要写入的块下标，初始值为0
• 互斥锁bufMutex：保护读写指针、缓冲区数据的修改操作，避免竞态问题

线程逻辑实现 #

生产者线程逻辑 #

1. 调用freeSlots.tryAcquire(1)非阻塞尝试获取空闲块：
   • 获取成功：直接进入写入流程
   • 获取失败（缓冲区已满）：进入覆写逻辑
     1. 加bufMutex锁
     2. 移动读指针跳过最旧的1块数据：rIndex = (rIndex + 1) % N
     3. 调用usedSlots.acquire(1)，减少1个已使用块计数（对应丢弃的旧数据）
     4. 释放bufMutex锁，此时已经获得1块可用空间，无需再获取freeSlots
2. 将新数据写入wIndex对应的缓冲区块
3. 加bufMutex锁，更新写指针：wIndex = (wIndex + 1) % N，释放锁
4. 调用usedSlots.release(1)，增加1个待消费块计数

消费者线程逻辑 #

和QSemaphore官方示例逻辑基本一致，仅需补充锁保护即可：

1. 调用usedSlots.acquire(1)，等待待消费数据就绪
2. 加bufMutex锁，读取rIndex对应块的数据，更新读指针：rIndex = (rIndex + 1) % N，释放锁
3. 调用freeSlots.release(1)，归还1块空闲空间
4. 处理读取到的业务数据

GUI线程逻辑 #

GUI线程仅做只读展示，不要占用信号量计数，避免影响生产消费逻辑：

1. 读取数据前加bufMutex锁
2. 直接读取当前最新的若干块数据用于展示
3. 读取完成后立即释放锁，不要持有锁处理UI渲染逻辑

注意事项 #

• 互斥锁仅在修改读写指针、读写缓冲区内容时持有，不要把业务数据处理、UI渲染等逻辑放到锁范围内，避免影响并发性能
• 如果需要一次覆盖多块旧数据匹配生产速率，仅需在覆写逻辑中计算需要跳过的块数，一次性调整rIndex和信号量计数即可
• 若对性能要求不高，也可以选择带锁的QQueue配合信号量实现相同逻辑，开发成本更低

内容的提问来源于stack exchange，提问作者Drobot Viktor