summaryrefslogtreecommitdiff
path: root/collect
diff options
context:
space:
mode:
Diffstat (limited to 'collect')
-rw-r--r--collect/shared_dict.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/collect/shared_dict.py b/collect/shared_dict.py
index ac390bc..ec76138 100644
--- a/collect/shared_dict.py
+++ b/collect/shared_dict.py
@@ -108,7 +108,8 @@ class SharedDict(object):
def cleanup(self) -> None:
if not hasattr(self, 'shared_memory'):
return
- self.shared_memory.unlink()
+ with SharedDict.MPLOCK:
+ self.shared_memory.unlink()
def clear(self) -> None:
self._save_memory({})