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

2024-05-29 blue-VH-driver-对外接口的并行调用-设计与思考

摘要:

VH的driver的对外接口, 要做到可以并行,也就是两个不同的线程,分别调用,不能互相阻塞。

本文记录对其的思考和设计。

上下文:

2024-05-28 blue-VH-driver-需求分析及问题分析-CSDN博客

2024-05-27 blue-vh-问题点-CSDN博客

2024-05-23 blue-vh-分析-CSDN博客

driver对外接口的并行调用:

  1. 注意这里有个隐含条件,所谓的上层调用的并行,是指在多个线程并行的去调用driver的接口,而不是用户态自己封装的协程。
  2. 所以要注意,所谓的并行,不能阻塞,究竟是不能阻塞什么。当认为是多线程并行调用的时候,那么自然就是多个上层调用线程在调用接口的时候,不能互相阻塞。也就是如果两个线程去分别调用同样的接口,两者需要互相独立
  3. 思路就是使用线程池和task,将上层调用的处理,封装成task,然后交给线程池去执行,这样在执行的时候,阻塞的是线程池中的线程,而不是上层调用方的线程。然后让上层调用方的线程休眠等待task处理完成,并且处理超时。
  4. 对外暴漏的接口调用,如果是需要和组态交互的,比如说 SearchPoints, 把这个包装成task, 也就是 CVxTaskSearchPointsInfoV2, 继承自 CVxTask, 实现  Execute()接口, 在 Execute () 里, 调用IPointCfgInterfaceV2的异步接口,并且在这个线程等待 IPointCfgInterfaceV2 回调的数据处理。  将 CVxTaskSearchPointsInfoV 放到 异步任务调度器 CVxTaskInvoker 里去执行, 这样就不会阻塞上层标准数据服务的调用driver接口的线程了。假设 CVxTaskInvoker 里启动了缺省的4个线程,那么 CVxTaskSearchPointsInfoV2 这个task就由  CVxTaskSearchPointsInfoV 里的4个工作线程其中的一个去调用,CVxTaskSearchPointsInfoV2::Execute()这个接口里一直等到拿到组态回调的数据再返回.
  5. 那么这次查询返回的数据,放在了 CVxTaskSearchPointsInfoV2 里, 使用 std::unordered_map 来装载,这个哈希的key,使用递增的序列号,每次涉及到与组态交互数据的查询,都是递增序列号。 这个序列号返回给标准数据服务的接口调用,这样小宝那边如果要翻页的时候,就把这个查询的序列号传给driver。  
  6. 还有就是错误处理,和VH数据库失去连接, 以及VH的组态的状态切换到 时候,,对缓存的数据的生命周期的影响,以及和上层标准数据服务的交互,以及VH返回的数据超时,和标准数据服务的配合,感觉还有更多的问题没有想到。

问题分析:

设计:

类图-线程池和task:

类图-driver:

时序图-driver-查询位点:

http://www.lryc.cn/news/358309.html

相关文章:

  • ubuntu安装
  • Rosetta PyRosetta 源码包 安装包 下载
  • C++ 进阶(3)虚函数表解析
  • 2024年新算法-秘书鸟优化算法(SBOA)优化BP神经网络回归预测
  • kafka-主题创建(主题操作的命令)
  • [日常开发] 数据库主从延迟问题
  • Python高层解雇和客户活跃度量化不确定性模型
  • 【IOT】OrangePi+HomeAssistant+Yolov5智能家居融合
  • Python 点云裁剪
  • Presto 从提交SQL到获取结果 源码详解(2)
  • Python的类全面系统学习
  • 信号处理中简单实用的方法
  • Jeecg | 如何解决 ERR Client sent AUTH, but no password is set 问题
  • 数据容器:set(集合) 更新啦!
  • 算法入门----小话算法(1)
  • Vue | 自定义组件双向绑定基础用法
  • python使用modbustcp协议与PLC进行简单通信
  • mongodb在游戏开发领域的优势
  • 大数据Scala教程从入门到精通第十篇:Scala在IDEA中编写Hello World代码的简单说明
  • 【SPSS】基于因子分析法对水果茶调查问卷进行分析
  • ElasticSearch学习篇12_《检索技术核心20讲》基础篇
  • Reids高频面试题汇总总结
  • 19 - grace数据处理 - 补充 - 地下水储量计算过程分解 - 冰后回弹(GIA)改正
  • 车载客流统计设备:双目3D还原智能统计算法的应用与优势
  • U盘无法打开?数据恢复与预防措施全解析
  • apollo版本更新简要概述
  • 基于心电疾病分类的深度学习模型部署应用于OrangePi Kunpeng Pro开发板
  • vue中axios的使用
  • Spark SQL【Java API】
  • 文心智能体平台丨创建你的四六级学习小助手