| | |
|---|
| | | t = threading.Thread(target=lambda: __run_upload_order(code, _l2_data_callback), daemon=True) |
|---|
| | | t.start() |
|---|
| | | __upload_order_threads[code] = t |
|---|
| | | logger_local_huaxin_l2_upload.info(f"重新创建L2订单上传线程：{code}") |
|---|
| | | if code not in __upload_trans_threads or not __upload_trans_threads[code].is_alive(): |
|---|
| | | t = threading.Thread(target=lambda: __run_upload_trans(code, _l2_data_callback), daemon=True) |
|---|
| | | t.start() |
|---|
| | | __upload_trans_threads[code] = t |
|---|
| | | logger_local_huaxin_l2_upload.info(f"重新创建L2成交上传线程：{code}") |
|---|
| | | time.sleep(3) |
|---|
| | | except: |
|---|
| | | pass |
|---|
