| | |
|---|
| | | queue_l1_w_strategy_r_: multiprocessing.Queue, |
|---|
| | | queue_strategy_w_trade_r_: multiprocessing.Queue, |
|---|
| | | queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, order_queues_, transaction_queues_, |
|---|
| | | market_queue_, queue_l1_trade_r_strategy_w, queue_l1_trade_w_strategy_r): |
|---|
| | | market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_): |
|---|
| | | logger_system.info("策略进程ID：{}", os.getpid()) |
|---|
| | | log.close_print() |
|---|
| | | # 初始化参数 |
|---|
| | |
|---|
| | | # |
|---|
| | | # 交易接口服务 |
|---|
| | | t1 = threading.Thread(target=huaxin_trade_api_server.run, name="trade_api_server", |
|---|
| | | args=(pipe_server, queue_other_w_l2_r, queue_l1_trade_r_strategy_w), |
|---|
| | | args=(pipe_server, queue_other_w_l2_r, queue_l1_trade_r_strategy_w_), |
|---|
| | | daemon=True) |
|---|
| | | t1.start() |
|---|
| | | # |
|---|
| | |
|---|
| | | huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_, |
|---|
| | | queue_strategy_w_trade_r_for_read_, order_queues_, |
|---|
| | | transaction_queues_, market_queue_, |
|---|
| | | queue_l1_trade_w_strategy_r) |
|---|
| | | queue_l1_trade_w_strategy_r_) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 主服务 |
|---|
