当前位置: 首页 > news >正文

ET ProcessInnerSender类(实体) 分析

ProcessInnerSender

  • 作用是进程内部发送Actor消息

字段

  • TIMEOUT_TIME 超时时间
  • RpcId 用来累加
  • requestCallback 存储RPC的回调事件
  • list 用来获取MessageQueue中的Actor消息

方法

  • Awake 初始化在MessageQueue中注册待处理的消息队列
  • Destroy 移除在MessageQueue中的消息队列
  • Update 获取MessageQueue中的待处理消息,处理消息
  • HandleMessage 处理Actor消息, 如果消息类型是Rpc的响应则执行HandleIActorResponse。否则找到Actor的MailBox,如果没有MailBox Reply(回复)ERR_NotFoundActor的错误,如果找到MailBox, 则根据MailBox 类型,分发消息处理。
  • HandleIActorResponse 回复一个Rpc消息结果
  • Reply 回复一条消息,跟发送没区别
  • Send 发送一条Actor消息。
  • SendInner 发送一条消息,实际就是添加到MessageQueue消息队列中,等待Update读取消息后进行处理
  • GetRpcId 获取一个rpcid
  • Call 发送一条Rpc 消息,如果超时会返回超时结果
http://www.xdnf.cn/news/447535.html

相关文章:

  • ultralytics中tasks.py---parse_model函数解析
  • 求助求助,重金酬谢
  • Java知识框架
  • AIGC与数字媒体实验室解决方案分享
  • Jmeter对服务端进行压测快速上手
  • 【电路笔记 通信】8B/10B编码 高速数据传输的串行数据编码技术 论文第三部分 The 8B/10B coding map
  • HarmonyOS NEXT 适配高德地图FlutterSDK实现地图展示,添加覆盖物和移动Camera
  • OpenCV CUDA 模块中用于在 GPU 上计算两个数组对应元素差值的绝对值函数absdiff(
  • Flutter 开发入门:从一个简单的计数器应用开始
  • 操作系统-物理结构
  • 【拥抱AI】Deer-Flow字节跳动开源的多智能体深度研究框架
  • MCP:开启AI的“万物互联”时代
  • 网站安全防御
  • 北斗导航 | 接收机自主完好性监测算法综述,1980至2025年(原理,公式,代码)
  • Java版OA管理系统源码 手机版OA系统源码
  • 深入理解卷积神经网络:从基础原理到实战应用
  • 硕士论文用YOLO可以毕业吗?
  • 记录算法笔记(20025.5.14)对称二叉树
  • 码题集——魔数、A的B次方、网球比赛、三角形、点与线段的关系
  • libmemcached库api接口讲解五
  • Java Queue 接口实现
  • 【经验分享】Dify+GraphRAG实现知识图谱智能问答
  • QMK键盘编码器(Encoder)(理论部分)
  • Unity Image组件无法阻挡手势的解决办法
  • 如何在运行不同操作系统的计算机上轻松擦除U盘
  • 【行为型之观察者模式】游戏开发实战——Unity事件驱动架构的核心实现策略
  • 医学影像系统的集成与工作流优化
  • 计算机图形学编程(使用OpenGL和C++)(第2版)学习笔记 10.增强表面细节(一)过程式凹凸贴图
  • Unity引擎源码-物理系统详解-其二
  • 大疆无人机自主飞行解决方案局限性及增强解决方案-AIBOX:特色行业无人机巡检解决方案