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

#include <functional>
#include <iostream>
#include <vector>
#include <thread>
#include <chrono>
class AsyncEventManager {
public:
using Callback = std::function<void(int)>;
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&amp; cb : callbacks) {
            cb(data);  // 调用所有注册的回调
        }
    }).detach();
}
private:
std::vector<Callback> callbacks;
};

int main() {
    AsyncEventManager manager;
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";
    }
int id = 1;
};
// 注册成员函数作为回调
DataProcessor proc;
manager.registerCallback(std::bind(&DataProcessor::onData, &proc, std::placeholders::_1));

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