| | |
|---|
| | | need_update_codes.append(d["securityID"]) |
|---|
| | | if need_update_codes: |
|---|
| | | gpcode_manager.request_price_pre(need_update_codes) |
|---|
| | | |
|---|
| | | queue_l1_trade_r_strategy_w.put_nowait( |
|---|
| | | {"type": "set_target_codes", "data": list(position_codes)}) |
|---|
| | | queue_strategy_w_l2_r.put_nowait( |
|---|
| | | {"type": "l2_cmd", "data": list(position_codes)}) |
|---|
| | | # 9点25之前需要订阅持仓票 |
|---|
| | | __process_thread_pool.submit(huaxin_trade_record_manager.PositionManager.add, datas) |
|---|
| | | async_log_util.info(hx_logger_trade_debug, f"获取交易数据成功：{type_}") |
|---|
| | |
|---|
| | | |
|---|
| | | def test(): |
|---|
| | | time.sleep(2) |
|---|
| | | position_codes =["000333"] |
|---|
| | | position_codes = ["000333"] |
|---|
| | | queue_l1_trade_r_strategy_w.put_nowait( |
|---|
| | | {"type": "set_target_codes", "data": list(position_codes)}) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 运行 |
|---|
| | | def run(queue_l1_trade_r_strategy_w_): |
|---|
| | | global queue_l1_trade_r_strategy_w |
|---|
| | | def run(queue_l1_trade_r_strategy_w_, queue_strategy_w_l2_r_): |
|---|
| | | global queue_l1_trade_r_strategy_w, queue_strategy_w_l2_r |
|---|
| | | queue_l1_trade_r_strategy_w = queue_l1_trade_r_strategy_w_ |
|---|
| | | queue_strategy_w_l2_r = queue_strategy_w_l2_r_ |
|---|
| | | t1 = threading.Thread(target=lambda: __read_update_task_queue(), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | # threading.Thread(target=lambda: test(), daemon=True).start() |
|---|
