diff options
Diffstat (limited to 'collect/shared_dict.py')
| -rw-r--r-- | collect/shared_dict.py | 3 |
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({}) |
