Add function to cleanup existing SHM

Author: arthurlm

example/simple_task.py

@@ -93,6 +93,10 @@ def _main_shm_autostart():
 
 
 if __name__ == "__main__":
+    # Clear any previous SHM if found
+    pyarraypool.cleanup_shm()
+
+    # Run main
     _main_classic()
     _main_shm_manualmanagement()
     _main_shm_autostart()

python/pyarraypool/__init__.py

@@ -157,3 +157,17 @@ def object_pool_context() -> Iterator[None]:
         yield
     finally:
         stop_pool()
+
+
+def cleanup_shm():
+    """Remove previous SHM if any."""
+    link_path = Path(_CFG_LINK_PATH)
+    if not link_path.exists():
+        return
+
+    segment_name = link_path.read_text().strip("/")
+    segment_path = Path("/dev/shm") / segment_name
+
+    LOGGER.info("Removing SHM segment: %s", segment_path)
+    link_path.unlink(missing_ok=True)
+    segment_path.unlink(missing_ok=True)