| | |
|---|
| | | import middle_api_server |
|---|
| | | import middle_cb_api_server |
|---|
| | | import middle_server |
|---|
| | | # from huaxin_client import huaxin_trade_client |
|---|
| | | # from trade import huaxin_trade_api |
|---|
| | | # from huaxin_client import huaxin_trade_client |
|---|
| | | from log_module import async_log_util |
|---|
| | | # from trade import huaxin_trade_api |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | t1 = threading.Thread(target=lambda: middle_api_server.run(), daemon=True) |
|---|
| | |
|---|
| | | t1.start() |
|---|
| | | # t1 = threading.Thread(target=lambda: middle_l1_data_server.run(12881), daemon=True) |
|---|
| | | # t1.start() |
|---|
| | | |
|---|
| | | # 运行仿真交易 |
|---|
| | | # queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query = multiprocessing.Queue(), multiprocessing.Queue(), multiprocessing.Queue() |
|---|
| | | # huaxin_trade_api.run_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query) |
|---|
| | | |
|---|
| | | # ===========运行交易端========== |
|---|
| | | # tradeProcess = multiprocessing.Process( |
|---|
| | | # target=huaxin_trade_client.run, |
|---|
| | | # args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,)) |
|---|
| | | # tradeProcess.start() |
|---|
| | | |
|---|
| | | middle_server.run() |
|---|
