线程日志

Administrator

2023-09-12 7a9296449e96b3755bffb5d4c201875a1e245699

 main.py

@@ -29,28 +29,28 @@
    # 初始化参数
    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()

    # 启动L2订阅服务
    # t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, name="redis", daemon=True)
    # t1.start()
    #
    # # 启动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)
@@ -69,7 +69,6 @@


def createDataServer():
    logger_system.debug(f"线程ID，dataServer：{threading.current_thread().ident}")
    logger_system.info("create DataServer")
    tcpserver = data_server.run("", 9004)
    tcpserver.serve_forever()