配置参数修改

Administrator

2023-07-06 1f4c4403c58fb8dc79338e1dce2ce8e2e673ee8f

 main.py

@@ -4,13 +4,11 @@

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):
@@ -40,9 +38,7 @@
    # 初始化参数
    global_data_loader.init()

    t1 = threading.Thread(target=createDataServer)
    # 后台运行
    t1.setDaemon(True)
    t1 = threading.Thread(target=createDataServer, daemon=True)
    t1.start()

    trade_server.run()
@@ -52,9 +48,7 @@
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
@@ -70,11 +64,11 @@


if __name__ == '__main__':
    #tradeServerProcess = multiprocessing.Process(target=createTradeServer)
    # tradeServerProcess = multiprocessing.Process(target=createTradeServer)
    serverProcess = multiprocessing.Process(target=createServer, args=(None, None,))
    jueJinTradeProcess = multiprocessing.Process(target=trade_juejin.run)

    #tradeServerProcess.start()
    # tradeServerProcess.start()
    serverProcess.start()
    jueJinTradeProcess.start()
    # 将tradeServer作为主进程