线程日志

Administrator

2023-09-12 802f51948ad7b05b7fdf1cd9e885892a5c2523b2

线程日志

 main.py

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

    # 数据服务
    t1 = threading.Thread(target=createDataServer, daemon=True)
    t1 = threading.Thread(target=createDataServer, name="createDataServer", daemon=True)
    t1.start()

    # 交易接口服务
    t1 = threading.Thread(target=trade_api_server.run, args=(pipe_server, pipe_l2), daemon=True)
    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, daemon=True)
    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, args=(ptl2_l2, psl2_l2, trade_server.my_l2_data_callback),
    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,
    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()

 test/test.py

@@ -9,7 +9,10 @@

__queue = queue.Queue()


def start_thread():
    print(threading.current_thread().getName(), threading.current_thread().ident)


if __name__ == "__main__":
    while True:
        data = __queue.get()
        print("数据：", data)
    threading.Thread(target=start_thread).start()