| | |
|---|
| | | |
|---|
| | | trade_call_back_queue = multiprocessing.Queue() |
|---|
| | | |
|---|
| | | # ===========运行交易外部API========== |
|---|
| | | # 策略与交易通信队列 |
|---|
| | | # 交易结果读取, 交易命令队列与交易查询队列设置为同一个 |
|---|
| | | 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) |
|---|
| | | # 华鑫交易数据更新 |
|---|
| | | huaxin_trade_data_update.run() |
|---|
| | | |
|---|
| | | # ===========运行交易端========== |
|---|
| | | tradeProcess = multiprocessing.Process( |
|---|
| | | target=trade_client_for_cb.run, |
|---|
| | | args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,)) |
|---|
| | | tradeProcess.start() |
|---|
| | | # 仿真交易不运行交易客户端 |
|---|
| | | # # ===========运行交易外部API========== |
|---|
| | | # |
|---|
| | | # |
|---|
| | | # |
|---|
| | | # # 策略与交易通信队列 |
|---|
| | | # # 交易结果读取, 交易命令队列与交易查询队列设置为同一个 |
|---|
| | | # 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=trade_client_for_cb.run, |
|---|
| | | # args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,)) |
|---|
| | | # tradeProcess.start() |
|---|
| | | |
|---|
| | | # ===========运行本地API接口========== |
|---|
| | | # middle_api_protocol.SERVER_HOST = "192.168.3.122" |
|---|
| | |
|---|
| | | command_callback, [("trade_cb", 50)]) |
|---|
| | | manager.run(blocking=False) |
|---|
| | | |
|---|
| | | threading.Thread(target=test, daemon=True).start() |
|---|
| | | # threading.Thread(target=test, daemon=True).start() |
|---|
| | | # ===========读取根据L2制定的买入策略========== |
|---|
| | | threading.Thread(target=read_l2_results, args=(trade_call_back_queue,), daemon=True).start() |
|---|
| | | # ===========异步日志持久化========== |
|---|
