python中的生成器实现周期性报文发送功能
更新时间：2023年03月08日 09:18:27 作者：Logintern09
本文主要介绍了python中的生成器实现周期性报文发送功能，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
使用python中的生成器实现周期性发送列表中数值的报文发送功能。
功能开发背景：提取cantest工具采集到的现场报文数据，希望使用原始的现场数据模拟验证程序现有逻辑，需要开发一个工具能够自动按照报文发送周期依次发送采集到的报文数据中的一个数值。
功能开发需求：多个报文发送对象共用同一个报文发送线程，多个对象间的报文发送周期不同，多个对象间的总报文发送数据长度不同，能够允许报文发送过程中断及恢复某个对象的报文发送。
功能开发实现逻辑：在固定发送对象某个数值的基础程序版本上增加新的功能，考虑使用python中生成器实现周期性提取对象数值发送报文的功能。
目前只需要发送两个对象的报文数据，先定义两个使用yield生成器：
def yield_item_value_1(self): item_value_list = self.item_value_dict[item_list[0]] for i in range(len(item_value_list)): yield item_value_list[i] def yield_item_value_2(self): item_value_list = self.item_value_dict[item_list[1]] for i in range(len(item_value_list)): yield item_value_list[i]
报文发送线程中的run()函数：
def run(self):
# 实时更新item的被选状态
self.get_checkbox_res_func()
# 获取每个对象的实际物理值
self.get_item_value_dict()
self.item1_value_func = self.yield_item_value_1()
self.item2_value_func = self.yield_item_value_2()
while self.Flag:
if any(msg_send_flag_dict.values()):
# 每隔second秒执行func函数
timer = Timer(0.01, self.tick_10ms_func)
timer.start()
self.send_working_msg(self.working_can_device, self.working_can_channel)
timer.join()
else:
mes_info = "Goodbye *** 自动发送所有报文数据结束！！！"
toastone = wx.MessageDialog(None, mes_info, "信息提示",
wx.YES_DEFAULT | wx.ICON_QUESTION)
if toastone.ShowModal() == wx.ID_YES: # 如果点击了提示框的确定按钮
toastone.Destroy() # 则关闭提示框
break
报文周期性发送函数：
def send_working_msg(self, can_device, device_id):
for idx in range(len(item_list)):
if msg_send_flag_dict[item_list[idx]] == 1:
msg_id_idx = msg_operation_list.index("报文ID") - 1
msg_id = eval(str(self.operation_dict[item_list[idx]][msg_id_idx]).strip())
# 获取报文发送帧类型
msg_type_idx = msg_operation_list.index("帧类型") - 1
msg_type = str(self.operation_dict[item_list[idx]][msg_type_idx])
msg_type = 1 if msg_type == "扩展帧" else 0
# 获取报文发送周期
msg_cycle_idx = msg_operation_list.index("周期(ms)") - 1
msg_cycle = int(self.operation_dict[item_list[idx]][msg_cycle_idx])
send_cycle = msg_cycle / 10
if msg_tick_10ms_dict["_".join(["tick", "10ms", str(idx)])] >= send_cycle:
# 开始喂值
if idx == 0:
try:
item_phyValue = next(self.item1_value_func)
except StopIteration:
msg_send_flag_dict[item_list[idx]] = 0
continue
else:
try:
item_phyValue = next(self.item2_value_func)
except StopIteration:
msg_send_flag_dict[item_list[idx]] = 0
continue
msg_data = self.get_item_msg(item_list[idx], item_phyValue)
if send_msg(msg_id, msg_type, msg_data, can_device, device_id, 0):
print("发送报文成功")
# print("msg_data", msg_data)
msg_tick_10ms_dict["_".join(["tick", "10ms", str(idx)])] = 0
else:
pass
# print("发送报文失败")
# mes_info = "发送报文失败"
# toastone = wx.MessageDialog(None, mes_info, "信息提示",
# wx.YES_DEFAULT | wx.ICON_QUESTION)
# if toastone.ShowModal() == wx.ID_YES: # 如果点击了提示框的确定按钮
# toastone.Destroy() # 则关闭提示框
功能实现逻辑的待优化点：存在多个对象就需要定义多个存储报文数据的生成器。
上述功能实现逻辑优化如下：
def set_yield_func(self): item_yield_func_dict = dict() for i in range(len(item_list)): item_yield_func_dict[item_list[i]] = self.yield_item_value(i) return item_yield_func_dict def yield_item_value(self, item_idx): item_value_list = self.item_value_dict[item_list[item_idx]] for i in range(len(item_value_list)): yield item_value_list[i]
报文发送线程的run()函数中调用这个存储对象报文发送数据生成器的字典item_yield_func_dict：
def run(self):
# 实时更新item的被选状态
self.get_checkbox_res_func()
# 获取每个对象的实际物理值
self.get_item_value_dict()
self.item_yield_func_dict = self.set_yield_func()
…………
从存储每个对象生成器的字典item_yield_func_dict中获取生成器对象：
try:
item_phyValue = next(self.item_yield_func_dict[item_list[idx]])
except StopIteration:
msg_send_flag_dict[item_list[idx]] = 0
continue
到此这篇关于python中的生成器实现周期性报文发送功能的文章就介绍到这了,更多相关python 周期性报文发送 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
您可能感兴趣的文章:
相关文章
本篇文章主要介绍了python操作mysql数据库的相关知识，具有很好的参考价值。下面跟着小编一起来看下吧2017-03-03
批标准化层 tf.keras.layers.Batchnormalization()解析
这篇文章主要介绍了批标准化层 tf.keras.layers.Batchnormalization()，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-02-02
下面小编就为大家分享一篇基于python内置函数与匿名函数详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-01-01
关于PySnooper 永远不要使用print进行调试的问题
这篇文章主要介绍了关于PySnooper 永远不要使用print进行调试的问题,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-03-03
师兄采集的视网膜图像放在一个文件夹下，由于分类十分混乱，因此出现了一个文件多次出现的情况，因此让我写了个脚本2013-04-04
这篇文章主要介绍了python数据类型强制转换实例详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-06-06
矩阵是matrix类型的对象,该类继承自numpy.ndarray,任何针对ndarray的操作,对矩阵对象同样有效,下面这篇文章主要给大家介绍了关于Python numpy生成矩阵基础的相关资料,需要的朋友可以参考下2022-08-08
这篇文章主要介绍了python数据结构之图深度优先和广度优先,较为详细的分析了深度优先和广度优先算法的概念与原理,并给出了完整实现算法,具有一定参考借鉴价值,需要的朋友可以参考下2015-07-07
在图像处理中，直方图是非常重要，也是非常有用的一个处理要素。这篇文章主要介绍了python数字图像处理实现直方图与均衡化，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-05-05
Python 提供了将一个或多个字符串连接在一起的多种方法,本文主要介绍了Python中连接字符串的7种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2024-06-06
最新评论