| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def createTradeServer(pipe_server, pipe_trade, pipe_l1, pipe_l2): |
|---|
| | | logger_system.info("策略进程ID：", os.getpid()) |
|---|
| | | logger_system.info("策略进程ID：{}", os.getpid()) |
|---|
| | | log.close_print() |
|---|
| | | # 初始化参数 |
|---|
| | | global_data_loader.init() |
|---|
| | |
|---|
| | | # 托管环境下不创建 |
|---|
| | | # serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,)) |
|---|
| | | # serverProcess.start() |
|---|
| | | logger_system.info("主进程ID：", os.getpid()) |
|---|
| | | logger_system.info("主进程ID：{}", os.getpid()) |
|---|
| | | |
|---|
| | | tradeServerProcess = multiprocessing.Process(target=createTradeServer, |
|---|
| | | args=(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy)) |
|---|
