| | |
|---|
| | | 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_, order_ipc_hosts_): |
|---|
| | | 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_) |
|---|
| | | queue_l1_trade_w_strategy_r_, order_ipc_hosts_) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 主服务 |
|---|
| | |
|---|
| | | # 创建L2通信队列 |
|---|
| | | order_queues = [] |
|---|
| | | transaction_queues = [] |
|---|
| | | order_ipc_hosts = [] |
|---|
| | | market_queue = multiprocessing.Queue() |
|---|
| | | for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT): |
|---|
| | | order_queues.append(multiprocessing.Queue()) |
|---|
| | | for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT): |
|---|
| | | transaction_queues.append(multiprocessing.Queue()) |
|---|
| | | for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT): |
|---|
| | | order_ipc_hosts.append(f"ipc://l2order{i}.ipc") |
|---|
| | | |
|---|
| | | # L2 |
|---|
| | | l2Process = multiprocessing.Process( |
|---|
| | | target=huaxin_client.l2_client.run, |
|---|
| | | args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue)) |
|---|
| | | args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue, order_ipc_hosts)) |
|---|
| | | 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) |
|---|
| | | queue_l1_trade_w_strategy_r, order_ipc_hosts) |
|---|
| | | |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | l1Process.join() |
|---|
