| | |
|---|
| | | 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_, order_ipc_hosts_): |
|---|
| | | market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_): |
|---|
| | | logger_system.info("策略进程ID：{}", os.getpid()) |
|---|
| | | log.close_print() |
|---|
| | | # 初始化参数 |
|---|
| | |
|---|
| | | 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_, order_ipc_hosts_) |
|---|
| | | queue_l1_trade_w_strategy_r_) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 主服务 |
|---|
| | |
|---|
| | | # L2 |
|---|
| | | l2Process = multiprocessing.Process( |
|---|
| | | target=huaxin_client.l2_client.run, |
|---|
| | | args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue, order_ipc_hosts)) |
|---|
| | | args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue)) |
|---|
| | | l2Process.start() |
|---|
| | | |
|---|
| | | # 主进程 |
|---|
| | | createTradeServer(pss_strategy, 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_r_strategy_w, |
|---|
| | | queue_l1_trade_w_strategy_r, order_ipc_hosts) |
|---|
| | | queue_l1_trade_w_strategy_r) |
|---|
| | | |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | l1Process.join() |
|---|
