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之间的通信。可以根据具体需求选择合适的通信方式，比如使用消息队列、共享内存、网络通信等。