| | |
|---|
| | | # L1订阅数据 |
|---|
| | | huaxin_api.l1_client.run_async(pl1t_l1) |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | while True: |
|---|
| | | psl2_strategy.send(f"{time.time()}") |
|---|
| | | time.sleep(2) |
|---|
| | | input() |
|---|
| | |
|---|
| | | # 拉取交易信息 |
|---|
| | | huaxin_trade_data_update.run() |
|---|
| | | # |
|---|
| | | # t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True) |
|---|
| | | # t1.start() |
|---|
| | | t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | t1 = threading.Thread(target=lambda: __read_sync_task(pipe_server), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | __set_target_codes(pipe_l2) |
|---|
| | | while True: |
|---|
| | | time.sleep(5) |
|---|
| | | |
|---|
| | | # 托管环境下不开启接口 |
|---|
| | | # laddr = "0.0.0.0", 10009 |
|---|
