共享内存/zeromq通信测试

Administrator

2024-04-18 f3de3b93f37ff6f537423b0067bf8afa05e08924

共享内存/zeromq通信测试

 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__":