diff options
author | Pierre Glaser <pierreglaser@msn.com> | 2019-05-10 22:59:08 +0200 |
---|---|---|
committer | Antoine Pitrou <antoine@python.org> | 2019-05-10 22:59:08 +0200 |
commit | f22cc69b012f52882d434a5c44a004bc3aa5c33c (patch) | |
tree | 03dc6cf6c5449ab30ac1243140b6b8f3b2359089 /Lib/multiprocessing/synchronize.py | |
parent | d0d64ad1f5f1dc1630004091d7f8209546c1220a (diff) | |
download | cpython-git-f22cc69b012f52882d434a5c44a004bc3aa5c33c.tar.gz |
bpo-36867: Make semaphore_tracker track other system resources (GH-13222)
The multiprocessing.resource_tracker replaces the multiprocessing.semaphore_tracker module. Other than semaphores, resource_tracker also tracks shared_memory segments. Patch by Pierre Glaser.
Diffstat (limited to 'Lib/multiprocessing/synchronize.py')
-rw-r--r-- | Lib/multiprocessing/synchronize.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/Lib/multiprocessing/synchronize.py b/Lib/multiprocessing/synchronize.py index 5137c49c1b..4fcbefc8bb 100644 --- a/Lib/multiprocessing/synchronize.py +++ b/Lib/multiprocessing/synchronize.py @@ -76,16 +76,16 @@ class SemLock(object): # We only get here if we are on Unix with forking # disabled. When the object is garbage collected or the # process shuts down we unlink the semaphore name - from .semaphore_tracker import register - register(self._semlock.name) + from .resource_tracker import register + register(self._semlock.name, "semaphore") util.Finalize(self, SemLock._cleanup, (self._semlock.name,), exitpriority=0) @staticmethod def _cleanup(name): - from .semaphore_tracker import unregister + from .resource_tracker import unregister sem_unlink(name) - unregister(name) + unregister(name, "semaphore") def _make_methods(self): self.acquire = self._semlock.acquire |