| | |
|---|
| | | def createTradeServer(pipe_server, queue_strategy_r_trade_w_: multiprocessing.Queue, |
|---|
| | | 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_): |
|---|
| | | queue_strategy_w_trade_r_for_read_: multiprocessing.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_strategy_w_trade_r_for_read_, |
|---|
| | | queue_l1_trade_w_strategy_r_) |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | args=(None, queue_other_w_l2_r, queue_strategy_r_trade_w, queue_strategy_w_trade_r, |
|---|
| | | queue_strategy_w_trade_r_for_read)) |
|---|
| | | tradeProcess.start() |
|---|
| | | |
|---|
| | | # 创建L2通信队列 |
|---|
| | | order_queues = [] |
|---|
| | | transaction_queues = [] |
|---|
| | | 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()) |
|---|
| | | |
|---|
| | | # 此处将L2的进程与策略进程合并 |
|---|
| | | # L2 |
|---|
| | | # l2Process = multiprocessing.Process( |
|---|
| | |
|---|
| | | # l2Process.start() |
|---|
| | | # 将L2的进程改为进程执行 |
|---|
| | | threading.Thread(target=huaxin_client.l2_client.run, args=( |
|---|
| | | queue_other_w_l2_r, order_queues, transaction_queues, market_queue, |
|---|
| | | huaxin_trade_server.my_l2_data_callbacks), daemon=True).start() |
|---|
| | | queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).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_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w, |
|---|
| | | queue_l1_trade_w_strategy_r) |
|---|
| | | |
|---|
| | | # 将tradeServer作为主进程 |
|---|
