| | |
|---|
| | | # l1与策略间的通信 |
|---|
| | | pl1t_l1, pl1t_strategy = multiprocessing.Pipe() |
|---|
| | | |
|---|
| | | serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,)) |
|---|
| | | serverProcess.start() |
|---|
| | | # 托管环境下不创建 |
|---|
| | | # serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,)) |
|---|
| | | # serverProcess.start() |
|---|
| | | |
|---|
| | | tradeServerProcess = multiprocessing.Process(target=createTradeServer, |
|---|
| | | args=(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy)) |
|---|
| | |
|---|
| | | |
|---|
| | | t1 = threading.Thread(target=lambda: __read_sync_task(pipe_server), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | laddr = "0.0.0.0", 10009 |
|---|
| | | tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle) # 注意：参数是MyBaseRequestHandle |
|---|
| | | tcpserver.serve_forever() |
|---|
| | | # 托管环境下不开启接口 |
|---|
| | | # laddr = "0.0.0.0", 10009 |
|---|
| | | # tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle) # 注意：参数是MyBaseRequestHandle |
|---|
| | | # tcpserver.serve_forever() |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
