++++++++++++++++ bug修复-

Administrator

2023-08-15 8b409a424fcf260bcfce2a74f265b05fe6406f71

++++++++++++++++
bug修复-

 main.py

@@ -76,8 +76,8 @@
    tradeServerProcess.start()

    # 交易进程与L2进程
    tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run, args=(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=huaxin_api.l2_client.run, args=(ptl2_l2, psl2_l2,))
    tradeProcess = multiprocessing.Process(target=lambda: huaxin_api.trade_client.run(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=lambda: huaxin_api.l2_client.run(ptl2_l2, psl2_l2))
    tradeProcess.start()
    l2Process.start()
    # L1订阅数据

 trade/huaxin/trade_api_server.py

@@ -420,7 +420,7 @@
        super().finish()


def __set_target_codes():
def __set_target_codes(pipe_l2):
    while True:
        try:
            _datas = huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.pop()
@@ -491,15 +491,13 @@
            time.sleep(1)


def run(pipe_server, pipe_l2_):
    global pipe_l2
    pipe_l2 = pipe_l2_
def run(pipe_server, pipe_l2):

    print("create TradeApiServer")
    # 拉取交易信息
    huaxin_trade_data_update.run()

    t1 = threading.Thread(target=lambda: __set_target_codes(), daemon=True)
    t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True)
    t1.start()

    t1 = threading.Thread(target=lambda: __read_sync_task(pipe_server), daemon=True)

 trade/huaxin/trade_server.py

@@ -343,7 +343,6 @@
    def set_target_codes(cls, data_json):
        data = data_json["data"]
        datas = data["data"]
        print("set_target_codes", data_json)
        HuaXinL1TargetCodesManager.set_level_1_codes_datas(datas)
        # lp = LineProfiler()
        # lp.enable()