D撤修改

Administrator

2023-09-12 c97dc748bfcc4fa4361ca50924359c916271ce1f

 main.py

@@ -30,27 +30,27 @@
    global_data_loader.init()

    # # 数据服务
    # t1 = threading.Thread(target=createDataServer, name="createDataServer", daemon=True)
    # t1.start()
    t1 = threading.Thread(target=createDataServer, name="createDataServer", daemon=True)
    t1.start()
    #
    # 交易接口服务
    # t1 = threading.Thread(target=trade_api_server.run, name="trade_api_server", args=(pipe_server, pipe_l2), daemon=True)
    # t1.start()
    t1 = threading.Thread(target=trade_api_server.run, name="trade_api_server", args=(pipe_server, pipe_l2), daemon=True)
    t1.start()
    #
    # redis后台服务
    # t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, name="redis", daemon=True)
    # t1.start()
    t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, name="redis", daemon=True)
    t1.start()
    #
    # # 启动L2订阅服务
    # 启动L2订阅服务
    t1 = threading.Thread(target=huaxin_client.l2_client.run, name="l2_client", args=(ptl2_l2, psl2_l2, trade_server.my_l2_data_callback),
                          daemon=True)
    t1.start()
    #
    # # 启动华鑫交易服务
    # t1 = threading.Thread(target=huaxin_client.trade_client.run, name="trade_client",
    #                       args=(trade_server.my_trade_response, ptl2_trade, pst_trade),
    #                       daemon=True)
    # t1.start()
    # 启动华鑫交易服务
    t1 = threading.Thread(target=huaxin_client.trade_client.run, name="trade_client",
                          args=(trade_server.my_trade_response, ptl2_trade, pst_trade),
                          daemon=True)
    t1.start()

    # 交易服务
    trade_server.run(pipe_trade, pipe_l1, pipe_l2, huaxin_client.trade_client.process_cmd)