From f3de3b93f37ff6f537423b0067bf8afa05e08924 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 18 四月 2024 16:47:01 +0800
Subject: [PATCH] 共享内存/zeromq通信测试
---
test_communication.py | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/test_communication.py b/test_communication.py
index 3b109d8..7b4bf55 100644
--- a/test_communication.py
+++ b/test_communication.py
@@ -49,6 +49,8 @@
args=(param.delegate_ipc_addr, param.delegate_data_shared_memory,), daemon=True).start()
threading.Thread(target=self.rec_deal_data, args=(param.deal_ipc_addr, param.deal_data_shared_memory,),
daemon=True).start()
+ while True:
+ time.sleep(100)
class L2DataCollector:
@@ -67,7 +69,6 @@
L2SharedMemoryDataUtil.set_data(datas, shared_memory)
socket.send_json({'data': [], "time": time.time()})
response = socket.recv_string()
- print("鏀跺埌濮旀墭鍙嶉")
except Exception as e:
logging.exception(e)
finally:
@@ -94,6 +95,8 @@
daemon=True).start()
threading.Thread(target=self.send_deal_data, args=(param.deal_ipc_addr, param.deal_data_shared_memory,),
daemon=True).start()
+ while True:
+ time.sleep(100)
if __name__ == "__main__":
--
Gitblit v1.8.0