C++发布订阅者模式：实现简单消息传递系统

 
概述：这个C++示例演示了发布者-订阅者模式的基本实现。通过 `Event` 类，发布者 `Publisher` 发送数据，而订阅者 `Subscriber` 订阅并处置惩罚数据。通过简单的回调机制，实现了组件间松散耦合的消息传递。
好的，我将为你提供一个简单的C++实例，演示如何使用发布者-订阅者模式。在这个例子中，我们将使用C++11的标准库中的  头文件，以及线程支持。
首先，我们定义一个简单的变乱类，该变乱类将用于携带消息：

1. // Event.h
2. #pragma once
4. #include <functional>
6. template <typename... Args>
7. class Event {
8. public:
9.     using Callback = std::function<void(Args...)>;
11.     void subscribe(Callback callback) {
12.         callbacks_.emplace_back(std::move(callback));
13.     }
15.     void notify(Args... args) const {
16.         for (const auto& callback : callbacks_) {
17.             callback(args...);
18.         }
19.     }
21. private:
22.     std::vector<Callback> callbacks_;
23. };

复制代码

接下来，我们定义一个发布者类，它将包含一个变乱对象，并提供一个方法来触发该变乱：

1. // Publisher.h
2. #pragma once
4. #include "Event.h"
6. class Publisher {
7. public:
8.     Event<int> onDataReceived;
10.     void sendData(int data) {
11.         // 假设在这里进行一些数据处理
12.         onDataReceived.notify(data);
13.     }
14. };

复制代码

然后，我们定义一个订阅者类，它将订阅发布者的变乱并定义处置惩罚函数：
[code]// Subscriber.h#pragma once#include "Event.h"#include class Subscriber {public:    void processData(int data) {        std::cout