| | |
| | | |
| | | import multiprocessing |
| | | |
| | | |
| | | from trade.huaxin import trade_server |
| | | from third_data import data_server |
| | | |
| | | from server import * |
| | | import l2.l2_data_util |
| | | |
| | | |
| | | |
| | | def __read_server_pipe(pipe): |
| | |
| | | # 初始化参数 |
| | | global_data_loader.init() |
| | | |
| | | t1 = threading.Thread(target=createDataServer) |
| | | # 后台运行 |
| | | t1.setDaemon(True) |
| | | t1 = threading.Thread(target=createDataServer, daemon=True) |
| | | t1.start() |
| | | |
| | | trade_server.run() |
| | |
| | | def createServer(pipe_juejin, pipe_gui): |
| | | print("create Server") |
| | | |
| | | t1 = threading.Thread(target=lambda: __read_server_pipe(pipe_gui)) |
| | | # 后台运行 |
| | | t1.setDaemon(True) |
| | | t1 = threading.Thread(target=lambda: __read_server_pipe(pipe_gui), daemon=True) |
| | | t1.start() |
| | | |
| | | laddr = "", 9001 |