From 485d37401b9b8d87b03a103b53f8a6c1c6c5f901 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期二, 29 八月 2023 17:27:40 +0800 Subject: [PATCH] 修改L2数据传输方式 --- huaxin_client/l2_data_manager.py | 5 +++-- 1 files changed, 3 insertions(+), 2 deletions(-) diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py index 0c1ec7f..4d0a72c 100644 --- a/huaxin_client/l2_data_manager.py +++ b/huaxin_client/l2_data_manager.py @@ -286,12 +286,13 @@ t.start() -def __test(pipe_strage): +def __test(pipe_strategy): code = "002073" if code not in tmep_order_detail_queue_dict: tmep_order_detail_queue_dict[code] = queue.Queue() target_codes.add(code) - run_upload_task(code, pipe_strage) + t = threading.Thread(target=lambda: __run_upload_order(code, pipe_strategy), daemon=True) + t.start() while True: try: tmep_order_detail_queue_dict[code].put_nowait( -- Gitblit v1.8.0