C++中如何实现actor之间的通信

在C++中实现actor之间的通信通常使用消息传递的方式。可以使用消息队列、异步消息传递、共享内存等方式来实现。以下是一个简单的示例代码：

#include <iostream>#include <thread>#include <queue>#include <mutex>#include <condition_variable>class Actor {public:    Actor() : running(true) {        thread = std::thread([this]() {            while (running) {                std::unique_lock<std::mutex> lock(mutex);                if (messages.empty()) {                    cv.wait(lock);                } else {                    auto message = messages.front();                    messages.pop();                    lock.unlock();                    processMessage(message);                }            }        });    }    void sendMessage(const std::string& message) {        std::lock_guard<std::mutex> lock(mutex);        messages.push(message);        cv.notify_one();    }    void stop() {        running = false;        cv.notify_one();        thread.join();    }protected:    virtual void processMessage(const std::string& message) {        std::cout << "Actor received message: " << message << std::endl;    }private:    std::queue<std::string> messages;    std::mutex mutex;    std::condition_variable cv;    std::thread thread;    bool running;};int main() {    Actor actor1;    Actor actor2;    actor1.sendMessage("Hello from actor1");    actor2.sendMessage("Hello from actor2");    std::this_thread::sleep_for(std::chrono::seconds(1));    actor1.stop();    actor2.stop();    return 0;}

在上面的示例中，定义了一个简单的Actor类，其中包含一个消息队列用于存储消息，以及一个线程用于处理消息。可以通过sendMessage方法向Actor发送消息，然后Actor会在自己的线程中处理消息。在main函数中创建了两个Actor实例，并发送了两条消息。通过调用stop方法可以停止Actor的线程。

这只是一个简单的示例，实际应用中可能需要更复杂的消息传递机制来实现actor之间的通信。可以根据具体需求选择合适的通信方式，比如使用消息队列、共享内存、网络通信等。