0

0

c++如何实现一个简单的actor模型框架_c++ Theron/CAF库思想【并发】

php中文网

php中文网

发布时间:2026-01-03 09:06:53

|

597人浏览过

|

来源于php中文网

原创

C++轻量级Actor框架核心是消息驱动、状态封装与单线程执行:Actor基类持私有状态和deque邮箱,通过虚函数OnMessage响应类型擦除消息;调度器用线程池+MailboxProcessor轮询邮箱并安全分发;ActorRef句柄管理生命周期,Send线程安全,确保自治性。

c++如何实现一个简单的actor模型框架_c++ theron/caf库思想【并发】

用 C++ 实现一个轻量级 Actor 模型框架,核心是把“消息驱动 + 封装状态 + 单线程执行”这三点落地。不一定要照搬 Theron 或 CAF 的全部设计,但可以借鉴它们的关键思想:Actor 是独立调度单元、通过邮箱(mailbox)收消息、由调度器(scheduler)统一分发、避免裸共享内存。

Actor 基类:封装状态与消息循环

每个 Actor 应该有自己的私有状态,不对外暴露数据成员,只响应消息。用虚函数 OnMessage 统一入口,配合类型擦除(如 std::any 或自定义消息基类)支持多类型消息:

  • 定义抽象基类 Message 或使用 std::variant 表达消息类型
  • Actor 持有一个 std::deque<:unique_ptr>> 作为邮箱(FIFO)
  • 提供 Send() 方法(线程安全地 push 到邮箱),不直接调用 OnMessage
  • OnMessage 在 Actor 自己的上下文中被调度器调用,保证同一 Actor 内部无并发访问

轻量调度器:单线程事件循环 + 线程池协作

Theron 偏向固定线程数 + Actor 绑定到特定工作线程;CAF 更倾向“每个 Actor 可迁移”,但默认仍用共享线程池。你可以折中:用一个全局 ThreadPool + 每个 Actor 关联一个 MailboxProcessor 对象:

  • MailboxProcessor 负责轮询 Actor 邮箱,取出消息并调用其 OnMessage
  • std::atomic_bool running 控制生命周期,配合 condition_variable 实现空邮箱时休眠
  • 调度器启动若干 std::thread,每个线程运行一个 while(running) { scheduler->DispatchOne(); } 循环
  • DispatchOne() 可以轮询所有非空邮箱,或用 work-stealing 方式提升负载均衡(类似 CAF)

消息传递:值语义 + 线程安全发送

Actor 之间只通过消息通信,禁止传裸指针或引用。关键点:

PictoGraphic
PictoGraphic

AI驱动的矢量插图库和插图生成平台

下载

立即学习C++免费学习笔记(深入)”;

  • Send() 接口接收 const Message&Message&&,内部做 move 或 copy(取决于消息是否可拷贝)
  • 邮箱 push 使用 std::mutex + std::lock_guard —— 这是最小代价的线程安全保障(仅写入邮箱时加锁,处理时无锁
  • 若追求零拷贝,可用 std::shared_ptr,但需注意生命周期管理(Theron 早期用过;CAF 默认值语义更简单可靠)
  • 可选:支持 Ask() 模式(带 promise/future 的请求-响应),用 std::promise 存入消息一起发,响应时 set_value

Actor 管理与生命周期:句柄代替裸指针

用户不应直接 new Actor,而是通过工厂获取智能句柄(类似 CAF 的 actor 类型):

  • 定义 ActorRef 类,内部持 std::weak_ptr + 全局 ID(用于日志/调试)
  • Send() 实现在 ActorRef 上,自动检查 weak_ptr 是否还有效,无效则静默丢弃或报错
  • Actor 析构时,从调度器注册表中移除自己,邮箱清空,避免悬挂调用
  • 支持 spawn() 创建子 Actor,并自动建立父子监督关系(可选进阶:失败时重启或终止子 Actor)

基本上就这些。不需要宏、不需要代码生成、不依赖 Boost,C++17 足够支撑。重点不是功能多全,而是让每个 Actor 真正“自治”——它决定何时处理什么、状态不被外部篡改、错误不影响其他 Actor。Theron 教你精简,CAF 教你工程化,你自己实现一遍,就懂为什么 actor_id、mailbox、scheduler 这三个词总是一起出现。

相关专题

更多
while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

82

2023.09.25

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

520

2023.09.20

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

995

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

53

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

243

2025.12.29

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

473

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

54

2025.12.01

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

54

2025.12.01

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

150

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 5.9万人学习

C 教程
C 教程

共75课时 | 3.8万人学习

C++教程
C++教程

共115课时 | 10.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号