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

Administrator

2023-08-15 a4473df83dc143f5a1f4f6ac73f01a3fcdbf6e05

 main.py

@@ -11,7 +11,7 @@
# 交易服务
from third_data import data_server
from trade.huaxin import trade_server, trade_api_server
import huaxin
from huaxin import trade_client,l2_client,l1_client


def createTradeServer(pipe_server, pipe_trade, pipe_l1):
@@ -62,11 +62,11 @@
    serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,))
    serverProcess.start()
    # 交易进程与L2进程
    tradeProcess = multiprocessing.Process(target=huaxin.trade_client.run, args=(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=huaxin.l2_client.run, args=(ptl2_l2,))
    tradeProcess = multiprocessing.Process(target=trade_client.run, args=(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=l2_client.run, args=(ptl2_l2,))
    tradeProcess.start()
    l2Process.start()
    # L1订阅数据
    huaxin.l1_client.run_async(pl1t_l1)
    l1_client.run_async(pl1t_l1)
    # 将tradeServer作为主进程
    createTradeServer(pss_strategy, pst_strategy, pl1t_trade)