From 02c91a4afceca47e22ffaef219ecaff1004f179c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 13 三月 2024 11:05:54 +0800
Subject: [PATCH] 更改序列化传输方式
---
l2/l2_data_listen_manager.py | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/l2/l2_data_listen_manager.py b/l2/l2_data_listen_manager.py
index 1f0a19f..e3be39a 100644
--- a/l2/l2_data_listen_manager.py
+++ b/l2/l2_data_listen_manager.py
@@ -1,6 +1,7 @@
"""
L2鏁版嵁鐩戝惉
"""
+import marshal
import multiprocessing
import threading
import time
@@ -33,11 +34,12 @@
while True:
# datas_dict = {}
try:
- if not q.empty():
- item = q.get()
- self.my_l2_data_callback.OnL2Order(item[0], item[1], item[2])
- else:
- time.sleep(0.001)
+ # if not q.empty():
+ item = q.get()
+ item = marshal.loads(item)
+ self.my_l2_data_callback.OnL2Order(item[0], item[1], item[2])
+ # else:
+ # time.sleep(0.001)
# while not q.empty():
# item = q.get()
@@ -78,6 +80,7 @@
# time.sleep(0.01)
if not q.empty():
item = q.get()
+ item = marshal.loads(item)
self.my_l2_data_callback.OnL2Transaction(item[0], item[1])
else:
time.sleep(0.005)
--
Gitblit v1.8.0