From e5048ebdfa6b484c181693e77102845e05139735 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 04 八月 2023 18:11:12 +0800
Subject: [PATCH] redis连接池归还
---
main.py | 13 +++++++------
1 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/main.py b/main.py
index 341f0c2..a2c99f5 100644
--- a/main.py
+++ b/main.py
@@ -13,7 +13,7 @@
from trade.huaxin import trade_server, trade_api_server
-def createTradeServer():
+def createTradeServer(pipe):
# 鍒濆鍖栧弬鏁�
global_data_loader.init()
@@ -22,7 +22,7 @@
t1.start()
# 浜ゆ槗鎺ュ彛鏈嶅姟
- t1 = threading.Thread(target=trade_api_server.run, daemon=True)
+ t1 = threading.Thread(target=trade_api_server.run, args=(pipe,), daemon=True)
t1.start()
# 浜ゆ槗鏈嶅姟
@@ -30,10 +30,10 @@
# 涓绘湇鍔�
-def createServer():
+def createServer(pipe):
print("create Server")
laddr = "", 9001
- tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_juejin=None) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
+ tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_trade=pipe) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
# tcpserver.handle_request() # 鍙帴鍙椾竴涓鎴风杩炴帴
tcpserver.serve_forever() # 姘镐箙寰幆鎵ц,鍙互鎺ュ彈澶氫釜瀹㈡埛绔繛鎺�
@@ -45,8 +45,9 @@
if __name__ == '__main__':
+ pipe_server, pipe_trade = multiprocessing.Pipe()
logger_l2_process_time.info("娴嬭瘯123")
- serverProcess = multiprocessing.Process(target=createServer)
+ serverProcess = multiprocessing.Process(target=createServer, args=(pipe_server,))
serverProcess.start()
# 灏唗radeServer浣滀负涓昏繘绋�
- createTradeServer()
+ createTradeServer(pipe_trade)
--
Gitblit v1.8.0