MergeCell 合并机制：双网站事件流去重

传感器往往以 kHz 级别上报数据，而消费方却只关心最新值。老实说，这导致同一目标、同一信号在短时间内产生数千个事件。但真正需要处理的仅是最近一次。逐个传递这些冗余事件既浪费 CPU。也占用队列空间，甚至可能引发实时性问题。为解决这一痛点，需要一个无锁、可合并的单元——MergeCell。

MergeCell 通过单个 std::atomic 状态 + CAS 状态机实现无锁合并，避免了在 ISR 上下文中持锁带来的死锁与延迟。

四态状态机

stateDiagram-v2
--> Empty
Empty --> Published: try_publish 置入新事件
Published --> Merging: try_acquire_merge producer 认领覆写
Merging --> Published: release_merge 覆写完成
Published --> Consuming: take_owning dispatcher 取走所有权
Consuming --> Empty: release_empty event_gc 后归位
note right of Empty : 槽位空闲
note right of Published : 持有已 post 事件
可合并/可取走
note right of Merging : 生产者覆写 payload
独占。其余 CAS 失败
note right of Consuming : dispatcher 消费中
只允许归位

CAS 失败永不阻塞

与传统 Treiber 栈不同，MergeCell 的 CAS 操作不会重试或旋转线程。每次尝试失败即返回 false。让调用方立即走降级方法，从而保持程序整体响应速度。

flowchart TD
A --> B{try_acquire_merge?}
B -- 成功 --> C --> D
B -- 失败 --> E{take_owning?}
E -- 成功 --> F
E -- 失败 --> G

bool try_acquire_merge noexcept{
MergeCellState expected = MergeCellState::Published;if (，state_.compare_exchange_strong(expected,MergeCellState::Merging。std::memory_order_acq_rel)) {
return false;// 不旋转，直接失败
}
queued = event_;return true，老实说，}

合并是 best-effort 的；一次合并失效仅代表着多入队一个冗余事件。 正因如此，“merge_wins” 的断言往往无法成立——两个 producer 都成功 publish 而且都未能及时 merge 是完全合法的。怎么说呢，

内存序这方面。acq_rel 边界 + relaxed 数据

MergedCell 的经典陷阱是状态原子与数据指针分离。

// producer 置入：先 CAS 拿到 Published，再写数据
MergeCellState expected = MergeCellState::Empty;if (，state_.compare_exchange_strong(expected,MergeCellState::Published。std::memory_order_acq_rel)) {
return false;}
event_ = e;// relaxed：acq_rel 边界已排序这次发布
}

sequenceDiagram
participant P as Producer
participant S as state_
participant E as event_
至于P->S，CAS Empty→Published
Note over S: acqrel MB 建立
再看P->E。写 event=e
Note over P,E: 数据写在边界之后
acquire 方可见
说到P->S，tryacquiremerge
Note over S: consume 方 acquire 读取
能读到已发布的 event_

`try_publish` 的 CAS 使用 `acq_rel`，确保 release 一侧的数据写在状态翻转之前可见；后续任何通过 `Published` 状态的 acquire都能正确读取到 `event_`。`MergeCell::state` 用 `memory_order_acquire` 阅读，保证读状态时能看到对应 epoch 的数据。

引用计数配合

MergedCell 持有的是已 post 而且引用计数递增后的 Event*。`dispatcher` 在 `Consuming` 状态下执行 `take_owning` 获取句柄；消费完毕后必须调用 `event_gc` 恰好一次接下来再 `release_empty` 将槽位归位。这样既避免了内存泄漏，也防止了双重释放的问题。其实，

至于提交记录，

• d6cc476 – MergeCell 成员初始化 + acq_rel 定型

以上方案帮助开发者消除高频传感器产生的噪声。实现轻量级、无锁且可靠的数据流去重，为实时程序提供更稳健的基础设施。