| | |
|---|
| | | data = json.loads(value) |
|---|
| | | _type = data["type"] |
|---|
| | | if _type == "l2_cmd": |
|---|
| | | huaxin_l2_log.info(logger_local_huaxin_l2_subscript, f"订阅代码：{data}") |
|---|
| | | __start_time = time.time() |
|---|
| | | # 线程池 |
|---|
| | | __l2_cmd_thread_pool.submit( |
|---|
| | |
|---|
| | | data_callback_distribute_manager = CodeDataCallbackDistributeManager(data_callbacks) |
|---|
| | | l2_data_upload_manager = L2DataUploadManager(data_callback_distribute_manager) |
|---|
| | | __init_l2(l2_data_upload_manager) |
|---|
| | | |
|---|
| | | threading.Thread(target=huaxin_l2_log.run_sync, daemon=True).start() |
|---|
| | | # TODO 测试 |
|---|
| | | # threading.Thread(target=lambda: test_add_codes(queue_r), daemon=True).start() |
|---|
| | | global l2CommandManager |
|---|
