bug修复

Administrator

2025-06-03 c4ed4da4ac8b8bc24e0a3ed0e782e9248b4a511c

 test_communication.py

@@ -26,7 +26,7 @@
                use_time = (time.time() - msg['time']) * 1000
                decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory)
                print(f"获取到逐笔委托数据: 数据长度：{len(decoded_data)} 通信耗时：{use_time}ms 解码耗时:{decoded_use_time}s")
                if use_time > 0.1:
                if use_time > 1:
                    logger_debug.info(f"委托通信耗时：{use_time}")
            except Exception as e:
                logging.exception(e)
@@ -42,7 +42,7 @@
                use_time = (time.time() - msg['time']) * 1000
                decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory)
                print(f"获取到逐笔成交数据:  数据长度：{len(decoded_data)} 通信耗时：{use_time}ms 解码耗时:{decoded_use_time}s")
                if use_time > 0.1:
                if use_time > 1:
                    logger_debug.info(f"成交通信耗时：{use_time}")
            except Exception as e:
                logging.exception(e)
@@ -87,6 +87,9 @@
            try:
                datas = ('888888', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 150
                use_time = L2SharedMemoryDataUtil.set_data(datas, shared_memory)
                if use_time > 0.0005:
                    logger_debug.info(f"数据装载耗时：{use_time}")

                socket.send_json({'data': [], "time": time.time()})
                response = socket.recv_string()
            except Exception as e:
@@ -106,7 +109,7 @@
            time.sleep(100)


if __name__ == "__main__1":
if __name__ == "__main__":
    channel_count = 100
    params = []
    for i in range(0, channel_count):
@@ -130,6 +133,6 @@
    while True:
        time.sleep(100)

if __name__ == "__main__":
if __name__ == "__main__1":
    datas = ('000990', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100
    print(datas)