更改序列化传输方式

Administrator

2024-03-13 02c91a4afceca47e22ffaef219ecaff1004f179c

 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)