C++中如何實(shí)現(xiàn)actor之間的通信

在C++中實(shí)現(xiàn)actor之間的通信通常使用消息傳遞的方式?？梢允褂孟㈥?duì)列、異步消息傳遞、共享內(nèi)存等方式來(lái)實(shí)現(xiàn)。以下是一個(gè)簡(jiǎn)單的示例代碼：

#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;
}

在上面的示例中，定義了一個(gè)簡(jiǎn)單的Actor類，其中包含一個(gè)消息隊(duì)列用于存儲(chǔ)消息，以及一個(gè)線程用于處理消息。可以通過(guò)sendMessage方法向Actor發(fā)送消息，然后Actor會(huì)在自己的線程中處理消息。在main函數(shù)中創(chuàng)建了兩個(gè)Actor實(shí)例，并發(fā)送了兩條消息。通過(guò)調(diào)用stop方法可以停止Actor的線程。

這只是一個(gè)簡(jiǎn)單的示例，實(shí)際應(yīng)用中可能需要更復(fù)雜的消息傳遞機(jī)制來(lái)實(shí)現(xiàn)actor之間的通信?？梢愿鶕?jù)具體需求選擇合適的通信方式，比如使用消息隊(duì)列、共享內(nèi)存、網(wǎng)絡(luò)通信等。