C++回调模式实现 异步事件处理机制

#include <functional>
#include <iostream>
#include <vector>
#include <thread>
#include <chrono>
<p>class AsyncEventManager {
public:
using Callback = std::function<void(int)>;</p><pre class='brush:php;toolbar:false;'>void registerCallback(Callback cb) {
    callbacks.push_back(cb);
}

void triggerEventAsync(int data) {
    // 模拟异步执行
    std::thread([this, data]() {
        std::this_thread::sleep_for(std::chrono::milliseconds(100)); // 模拟延迟
        for (auto& cb : callbacks) {
            cb(data);  // 调用所有注册的回调
        }
    }).detach();
}

int main() {
    AsyncEventManager manager;
<pre class='brush:php;toolbar:false;'>manager.registerCallback([](int value) {
    std::cout << "Callback 1: Received " << value << "\n";
});

manager.registerCallback([](int value) {
    std::cout << "Callback 2: Value doubled is " << value * 2 << "\n";
});

std::cout << "Triggering async event...\n";
manager.triggerEventAsync(42);

// 主线程不阻塞
std::this_thread::sleep_for(std::chrono::seconds(1));
return 0;

using ResultCallback = std::function<void(bool success, int data, const std::string& error)>;

void simulateAsyncOperation(ResultCallback cb) {
    std::thread([cb]() {
        bool success = rand() % 2; // 模拟随机成功/失败
        int data = 100;
        std::string error = success ? "" : "Network timeout";
        std::this_thread::sleep_for(std::chrono::milliseconds(200));
        cb(success, data, error);
    }).detach();
}

class DataProcessor {
public:
    void onData(int value) {
        std::cout << "Processor " << id << " got: " << value << "\n";
    }
<pre class='brush:php;toolbar:false;'>int id = 1;

manager.registerCallback([&proc](int value) { proc.onData(value); });