直接用 std::function + std::vector 实现轻量级 pub/sub 就够用了，因其简洁、高效、无锁且天然支持多种可调用对象，适用于单线程场景如游戏逻辑、ui通知等。
为什么直接用 std::function + std::vector 存回调就够用了
多数轻量级 Pub/Sub 场景根本不需要线程安全、消息队列或序列化——尤其在单线程游戏逻辑、配置热更、UI状态通知等场景中。std::function 能绑定成员函数、lambda 和普通函数，std::vector 提供 O(1) 尾插和可预测的遍历顺序，组合起来就是最简观察者模式的自然表达。
常见错误是过早引入 std::shared_ptr 包裹观察者，导致生命周期混乱；或用 std::map 按 topic 索引却忽略 topic 字符串比较开销远高于指针/整数。
- 只在需要跨线程投递时才加
std::mutex，否则锁反而成为性能瓶颈 - 避免用
std::string作 topic 键——改用const char*或枚举值（如enum class Topic : uint8_t { UI_UPDATE, AUDIO_MUTE };） - 回调注册后不校验是否已存在，重复订阅会导致同一函数被调两次；建议用
std::vector<:function>>::iterator</:function>记录句柄，提供unsubscribe()接口
subscribe() 返回 Subscription 对象而不是 void 的原因
裸指针或 raw function pointer 无法安全解绑：lambda 捕获上下文后地址不可比，成员函数指针在多继承下可能不唯一。返回一个轻量 Subscription 对象（内部持有一个 size_t 索引或 void* token），让调用方后续能精准移除自己，是唯一可控方式。
示例关键片段：
struct Subscription {
explicit Subscription(size_t idx) : index(idx) {}
size_t index;
};
// ...
Subscription subscribe(std::function<void> cb) {
callbacks.push_back(std::move(cb));
return Subscription(callbacks.size() - 1);
}
void unsubscribe(const Subscription& s) {
if (s.index <p>注意：不建议在 <code>unsubscribe()</code> 中立即 <code>erase</code>，否则遍历发布时容易跳过后续回调或触发 <code>iterator invalidation</code>。</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/xiazai/gongju/2823" title="C++14"><img
src="https://img.php.cn/upload/manual/001/431/639/6ac8b33c327c4749.png" alt="C++14" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/xiazai/gongju/2823" title="C++14" class="overflowclass">C++14</a>
<p class="overflowclass">C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。</p>
</div>
<a rel="nofollow" href="/xiazai/gongju/2823" title="C++14" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div>
<h3>如何避免 <code>publish()</code> 时回调里又调 <code>subscribe()</code> 或 <code>unsubscribe()</code> 导致崩溃</h3>
<p>这是裸容器实现 Pub/Sub 最典型的崩溃点：一边遍历 <code>std::vector</code>，一边修改它（哪怕只是 <code>push_back</code>），迭代器立刻失效。C++20 以前没有安全的“遍历中修改”原语。</p>
<ul>
<li>最简方案：把待新增的回调暂存到临时 <code>std::vector</code>，本轮 publish 结束后再合并；待移除的标记为 <code>nullptr</code>，下轮 publish 前批量清理</li>
<li>不要在回调里直接调 <code>unsubscribe(this)</code>——改为发一个延迟清理请求（例如 push 到全局 <code>std::vector<subscription></subscription></code>），由主循环统一处理</li>
<li>若必须支持运行时动态增删且不希望延迟，改用 <code>std::list</code> + <code>std::weak_ptr</code> 组合，但代价是缓存不友好和额外分配</li>
</ul>
<h3>为什么不用 Boost.Signals2 或 Qt 的 <code>QSignalMapper</code>
</h3>
<p>Boost.Signals2 功能完备但二进制体积大、编译慢，且默认带线程安全——你单线程跑它，90% 的 mutex 开销白交；Qt 的信号槽依赖 MOC 和 QObject 体系，侵入性强，不适合嵌入式或无 GUI 模块。</p>
<p>真正需要它们的场景其实很窄：比如你要做跨进程 Pub/Sub、带优先级队列、或要求断连自动重试。而 80% 的 C++ 项目里，一个不到 100 行的头文件就覆盖了全部需求：</p>
<pre class="brush:php;toolbar:false;">
template<typename... args>
class EventBus {
std::vector<:function>> callbacks;
public:
using Subscription = size_t;
Subscription subscribe(std::function<void> cb) {
callbacks.push_back(std::move(cb));
return callbacks.size() - 1;
}
void publish(Args... args) const {
for (const auto& cb : callbacks) {
if (cb) cb(args...); // 支持空回调占位
}
}
void unsubscribe(Subscription s) {
if (s <p>真正难的不是写这个类，而是想清楚：你的“事件”是否真该跨模块广播？还是该收拢成明确的接口调用？Pub/Sub 容易掩盖依赖关系，调试时一堆匿名 lambda 不知道谁在哪儿订的，这点比内存安全更值得警惕。</p></void></:function></typename...>C++免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 C++ 的入门与实战技巧！
