From 2cfa8edcbdb30d13b0f0e6d57d2f922b46ed8710 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 12 九月 2023 15:45:24 +0800
Subject: [PATCH] 线程日志
---
huaxin_client/l2_client.py | 1 +
huaxin_client/trade_client.py | 1 +
db/redis_manager_delegate.py | 2 ++
trade/huaxin/trade_server.py | 1 +
main.py | 1 +
trade/huaxin/trade_api_server.py | 1 +
test/test.py | 27 ++-------------------------
7 files changed, 9 insertions(+), 25 deletions(-)
diff --git a/db/redis_manager_delegate.py b/db/redis_manager_delegate.py
index 638f785..ece402e 100644
--- a/db/redis_manager_delegate.py
+++ b/db/redis_manager_delegate.py
@@ -3,6 +3,7 @@
"""
import logging
import queue
+import threading
import time
import redis
@@ -195,6 +196,7 @@
@classmethod
def run_loop(cls):
logger_system.info("鍚姩Redis鏁版嵁鍚屾鏈嶅姟")
+ logger_system.debug(f"绾跨▼ID锛宺edis锛歿threading.get_ident()}")
dataList = []
last_upload_time = time.time()
while True:
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index 16a6a88..6840e2c 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -574,6 +574,7 @@
def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None:
+ logger_system.debug(f"绾跨▼ID锛宭2_client锛歿threading.get_ident()}")
logger_system.info("L2杩涚▼ID锛歿}", os.getpid())
try:
log.close_print()
diff --git a/huaxin_client/trade_client.py b/huaxin_client/trade_client.py
index f9241d9..ce17d1b 100644
--- a/huaxin_client/trade_client.py
+++ b/huaxin_client/trade_client.py
@@ -1113,6 +1113,7 @@
def run(trade_response_: TradeResponse, pipe_l2=None, pipe_strategy=None):
try:
+ logger_system.debug(f"绾跨▼ID锛宼rade_client锛歿threading.get_ident()}")
logger_system.info("浜ゆ槗杩涚▼ID锛歿}", os.getpid())
__init_trade_data_server()
global l2pipe
diff --git a/main.py b/main.py
index 68fe264..7cd1b03 100644
--- a/main.py
+++ b/main.py
@@ -69,6 +69,7 @@
def createDataServer():
+ logger_system.debug(f"绾跨▼ID锛宒ataServer锛歿threading.get_ident()}")
logger_system.info("create DataServer")
tcpserver = data_server.run("", 9004)
tcpserver.serve_forever()
diff --git a/test/test.py b/test/test.py
index 705747f..08493d2 100644
--- a/test/test.py
+++ b/test/test.py
@@ -9,30 +9,7 @@
__queue = queue.Queue()
-
-def read(pipe):
- while True:
- if not __queue.empty():
- val = __queue.get(block=False)
- if val:
- print("read:", val)
-
-
-def write(pipe):
- while True:
- __queue.put_nowait("123")
- time.sleep(1)
- break
-
-
if __name__ == "__main__":
- p1, p2 = multiprocessing.Pipe()
- t1 = threading.Thread(target=lambda: write(p1), daemon=True)
- t1.start()
- print("鏄惁alive锛�", t1.is_alive())
-
- threading.Thread(target=lambda: read(p2), daemon=True).start()
while True:
- print("鏄惁alive锛�", t1.is_alive())
- time.sleep(1)
- input()
+ data = __queue.get()
+ print("鏁版嵁锛�", data)
diff --git a/trade/huaxin/trade_api_server.py b/trade/huaxin/trade_api_server.py
index 621f689..37c6890 100644
--- a/trade/huaxin/trade_api_server.py
+++ b/trade/huaxin/trade_api_server.py
@@ -500,6 +500,7 @@
def run(pipe_server, pipe_l2):
+ logger_system.debug(f"绾跨▼ID锛宼rade_api_server锛歿threading.get_ident()}")
logger_system.info("create TradeApiServer")
# 鎷夊彇浜ゆ槗淇℃伅
huaxin_trade_data_update.run()
diff --git a/trade/huaxin/trade_server.py b/trade/huaxin/trade_server.py
index 0fa0f11..21bd68a 100644
--- a/trade/huaxin/trade_server.py
+++ b/trade/huaxin/trade_server.py
@@ -821,6 +821,7 @@
def run(pipe_trade, pipe_l1, pipe_l2, trade_cmd_callback):
try:
+ logger_system.debug(f"绾跨▼ID锛宼rade_server锛歿threading.get_ident()}")
# 鎵ц涓�浜涘垵濮嬪寲鏁版嵁
block_info.init()
--
Gitblit v1.8.0