2. 实时数据流架构：生产者-消费者模型、环形缓冲区设计、零拷贝技术

多摄像头同步，说白了就是解决一个核心矛盾：多个数据源同时往系统里灌数据，而处理单元只有一个出口。你想想看，四路 1080p@30fps 的摄像头，每秒就是 4×1920×1080×3×30 ≈ 745MB 的原始数据。如果架构设计得不好，数据在内存里拷贝来拷贝去，CPU 光干搬运工了，哪还有精力做算法处理？

这一章，我就带你拆解实时流架构的三个核心组件。这些都是我在多个量产项目中反复验证过的套路，希望能帮你少走弯路。

2.1 生产者-消费者模型：解耦的基石

先看最基础的模型。生产者（摄像头驱动/DMA）只管往缓冲区里扔数据，消费者（编码器/算法模块）只管从缓冲区里取数据。两者通过一个共享队列通信，互不阻塞。

我在项目中遇到过一种典型问题：某个摄像头因为光线变暗，帧率从 30fps 掉到了 25fps。如果模型设计成同步阻塞式，其他三路摄像头都得等它，整个系统的输出帧率就被拖到了 25fps。换成异步生产者-消费者模型后，每个摄像头都有自己的独立队列，慢的摄像头丢几帧，快的摄像头照常处理，系统整体吞吐量反而提升了 20%。

具体实现时，我建议用无锁队列（lock-free queue）来替代传统的 mutex 保护队列。为什么？因为锁会导致上下文切换，而上下文切换在实时流处理中是灾难性的。以 ARM Cortex-A72 为例，一次 pthread_mutex_lock/unlock 平均耗时约 50-100ns，看起来不多，但乘以 4 路摄像头 × 30fps，每秒就是 12000 次锁操作，累积的抖动足以破坏帧间同步。

实现方式	平均延迟	抖动（标准差）	适用场景
Mutex + Condition Variable	~120ns	±45ns	低频控制消息
Spinlock	~30ns	±12ns	短临界区，多核
无锁队列（CAS）	~15ns	±3ns	高频数据流，实时性要求高

2.2 环形缓冲区：内存管理的艺术

有了生产者-消费者模型，接下来要解决的是缓冲区怎么设计。线性队列有个问题：频繁的 malloc/free 会导致内存碎片，而且 cache 命中率低。环形缓冲区（Ring Buffer）就是为此而生的。

说白了，环形缓冲区就是一块固定大小的内存，用两个指针（读指针和写指针）循环使用。写指针追着读指针跑，读指针追着写指针跑。当写指针追上读指针时，表示缓冲区满了——这时候要么覆盖旧数据，要么阻塞等待。

在多摄像头场景下，我通常为每个摄像头分配独立的环形缓冲区，而不是所有摄像头共享一个。为什么？因为不同摄像头的帧率、分辨率可能不同，共享缓冲区会导致高帧率摄像头挤占低帧率摄像头的空间。

实现上，我推荐使用双指针 + 内存屏障的方式，避免使用锁。核心代码大概长这样：

// 环形缓冲区写入示例（简化版）
bool ring_buffer_write(RingBuffer* rb, const uint8_t* data, size_t size) {
    uint32_t write_pos = atomic_load(&rb->write_pos);
    uint32_t read_pos  = atomic_load(&rb->read_pos);
    uint32_t next_pos  = (write_pos + 1) % rb->capacity;

    // 检查是否满
    if (next_pos == read_pos) {
        return false;  // 缓冲区满，丢帧
    }

    // 拷贝数据
    memcpy(rb->buffer + write_pos * rb->frame_size, data, size);
    atomic_store(&rb->write_pos, next_pos);  // 释放语义
    return true;
}

2.3 零拷贝技术：让数据飞一会儿

好了，现在数据已经进了环形缓冲区。但问题来了：从摄像头 DMA 到环形缓冲区，从环形缓冲区到算法模块，从算法模块到编码器……每经过一个环节，数据就要被拷贝一次。四路摄像头，每帧 6MB，每秒 120 帧，如果每帧拷贝 3 次，那就是 6MB × 120 × 3 = 2.16GB/s 的内存带宽消耗。DDR4-3200 的理论带宽也就 25.6GB/s，但实际可用带宽只有 60% 左右，这么一搞就占了 14% 的带宽。

零拷贝技术，就是让数据在各个环节之间共享同一块物理内存，而不是复制来复制去。具体怎么做？

• DMA 直接写入用户空间缓冲区：传统做法是 DMA 先写到内核空间，再拷贝到用户空间。零拷贝的做法是，在用户空间分配物理连续的内存（通过 dma_alloc_coherent 或 ion_alloc），然后把物理地址告诉 DMA 控制器，让它直接写进去。
• 共享内存 + 引用计数：多个处理模块共享同一块内存，通过引用计数来管理生命周期。当所有模块都处理完一帧后，才释放内存。
• 指针传递而非数据传递：模块之间传递的是指向缓冲区的指针和元数据（时间戳、帧序号），而不是整个帧数据。

不过，零拷贝也不是银弹。它要求所有模块对内存布局达成一致——比如 YUV420 还是 NV12，对齐方式是多少。一旦某个模块需要修改数据格式，就不得不拷贝了。我的做法是：在架构设计阶段就统一数据格式，所有模块都基于同一种格式工作。如果实在需要格式转换，就在一个专门的转换模块里做，并且用 SIMD 优化。

2.4 整体架构：三者如何协同

把上面三个组件串起来，就构成了一个完整的实时流处理管道。我画了一张图，帮你直观理解：

从图中你能看到，整个架构的核心思想就是分而治之 + 共享复用。每个摄像头独立生产数据，通过环形缓冲区解耦，再通过零拷贝技术让多个消费者共享同一份数据。这样一来，即使某个摄像头出现异常，也不会影响其他通道的正常工作。