PySide6 提供了 `QSharedMemory` 类，它允许我们在多进程间共享内存区域，从而实现高效的进程间通信 (IPC)。下面是一个基于 PySide6 的 `QSharedMemory` 封装成类的示例，并提供一个简单易用的模板。 --- ### 示例代码 ```python from PySide6.QtCore import QSharedMemory, QByteArray import sys class SharedMemoryManager: def __init__(self, key): """ 初始化共享内存管理器 :param key: 共享内存键值，用于区分不同的共享内存实例 """ self.key = key self.shared_memory = QSharedMemory(key) def create(self, size): """ 创建指定大小的共享内存块 :param size: 共享内存的字节大小 :return: 是否创建成功 """ if not self.shared_memory.create(size): print("无法创建共享内存:", self.shared_memory.errorString()) return False print(f"共享内存已创建，key={self.key}, size={size}") return True def attach(self): """ 连接到现有的共享内存块 """ if not self.shared_memory.attach(): print("连接到现有共享内存失败:", self.shared_memory.errorString()) return False print(f"已附加到共享内存，key={self.key}") return True def detach(self): """从共享内存断开""" if self.shared_memory.isAttached(): self.shared_memory.detach() print(f"已从共享内存 {self.key} 断开") def write_data(self, data): """ 写入数据到共享内存 :param data: 要写入的数据（字符串） """ byte_array = QByteArray(data.encode('utf-8')) if len(byte_array) > self.shared_memory.size(): print("数据长度超出共享内存限制!") return False self.shared_memory.lock() # 加锁防止其他线程访问 try: memory = self.shared_memory.data() memory[:len(byte_array)] = bytes(byte_array.toRawData()) # 数据写入 finally: self.shared_memory.unlock() # 解锁 print(f"数据 '{data}' 已写入共享内存") return True def read_data(self): """ 从共享内存读取数据 :return: 字符串形式的数据内容 """ self.shared_memory.lock() # 加锁防止其他线程访问 try: memory = self.shared_memory.constData() data = bytearray(memory[:self.shared_memory.size()]) string_data = data.decode('utf-8').rstrip('\x00') # 去除多余空字符 except Exception as e: print("读取共享内存错误:", str(e)) string_data = "" finally: self.shared_memory.unlock() # 解锁 print(f"从共享内存读取数据：'{string_data}'") return string_data # 测试部分 if __name__ == "__main__": shared_key = "MyAppSharedKey" manager = SharedMemoryManager(shared_key) if "--write" in sys.argv: success = manager.create(1024) or manager.attach() if success: manager.write_data("Hello from Process A!") elif "--read" in sys.argv: success = manager.attach() if success: data = manager.read_data() print("Read Data:", data) ``` --- ### 使用说明 #### 参数解释： 1. **key**: 每个共享内存都由唯一的标识符 (`key`) 区分。 2. **create(size)**: 需要在主进程中调用此方法来分配固定大小的共享内存空间。 3. **attach()**: 子进程通过该方法挂载到已经存在的共享内存上。 4. **write_data(data)** 和 **read_data()** 分别实现了对共享内存的安全写入和读取操作。 #### 执行步骤： 假设我们有两段独立运行的脚本： 1. 主进程负责初始化并写入数据： ```bash python script.py --write ``` 2. 子进程可以随时读取这些数据： ```bash python script.py --read ``` --- ### 注意事项 1. 确保所有进程使用相同的 `key` 来引用同一条共享内存。 2. 如果需要跨平台兼容性，则建议避免超过操作系统默认的最大共享内存限制。 3. 对于复杂的结构化数据，可以用 JSON 或者序列化的工具将复杂对象编码后再存储至共享内存中。