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

Administrator

2023-08-17 b4480ad745510c8e81c88c20fb67cb65eef79cc5

 main.py

@@ -11,7 +11,7 @@
import huaxin_api.l2_client
import huaxin_api.l1_client
from log_module import log
from log_module.log import logger_l2_trade
from log_module.log import logger_l2_trade, logger_system

from server import *

@@ -24,6 +24,7 @@


def createTradeServer(pipe_server, pipe_trade, pipe_l1, pipe_l2):
    logger_system.info("策略进程ID：", os.getpid())
    log.close_print()
    # 初始化参数
    global_data_loader.init()
@@ -60,7 +61,7 @@


if __name__ == '__main__':
    logger_l2_trade.info("test123123")
    logger_l2_trade.info("启动程序")
    log.close_print()
    # 策略与server间的通信
    pss_server, pss_strategy = multiprocessing.Pipe()
@@ -77,6 +78,7 @@
    # 托管环境下不创建
    # serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,))
    # serverProcess.start()
    logger_system.info("主进程ID：", os.getpid())

    tradeServerProcess = multiprocessing.Process(target=createTradeServer,
                                                 args=(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy))