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