C++怎么实现一个简单的Actor并发模型_C++并发设计模式与消息传递

#include <iostream>
#include <queue>
#include <thread>
#include <functional>
#include <mutex>
#include <condition_variable>
<p>class SimpleActor {
public:
// 启动Actor的运行线程
SimpleActor() : running(true) {
thread = std::thread(&SimpleActor::run, this);
}</p><pre class='brush:php;toolbar:false;'>// 停止Actor并等待线程结束
~SimpleActor() {
    {
        std::unique_lock<std::mutex> lock(mutex);
        running = false;
    }
    condition.notify_all();
    if (thread.joinable()) {
        thread.join();
    }
}

// 发送一个可调用对象作为消息
void send(std::function<void()> message) {
    {
        std::lock_guard<std::mutex> lock(mutex);
        mailbox.push(message);
    }
    condition.notify_one(); // 唤醒处理线程
}

<pre class="brush:php;toolbar:false;">std::queue<std::function<void()>> mailbox; // 消息队列（信箱）
std::mutex mutex;
std::condition_variable condition;
std::thread thread;
bool running;

// 向Actor发送几条“消息”
actor.send([]() { std::cout << "Hello from Actor! Thread ID: " 
                  << std::this_thread::get_id() << std::endl; });
actor.send([]() { std::cout << "Another message processed." << std::endl; });

// 主线程休眠一下，确保消息被处理
std::this_thread::sleep_for(std::chrono::seconds(1));
return 0;

#include <caf/all.hpp>
using namespace caf;
<p>// 定义Actor的行为
behavior hello_actor(event_based_actor* self) {
return {
on(atom("greet")) >> [] {
std::cout << "Hello from CAF Actor!" << std::endl;
}
};
}</p><p>int main() {
actor_system_config config;
actor_system system{config};</p><pre class='brush:php;toolbar:false;'>// 创建Actor
auto actor = system.spawn(hello_actor);
// 发送消息
anon_send(actor, atom("greet"));

// 等待所有Actor完成
await_all_actors_done();
shutdown();
return 0;