From 1f4c4403c58fb8dc79338e1dce2ce8e2e673ee8f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 06 七月 2023 16:56:03 +0800
Subject: [PATCH] 配置参数修改
---
main.py | 14 ++++----------
1 files changed, 4 insertions(+), 10 deletions(-)
diff --git a/main.py b/main.py
index 7808226..369b7fc 100644
--- a/main.py
+++ b/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()
# 灏唗radeServer浣滀负涓昏繘绋�
--
Gitblit v1.8.0