From 81a5855a2739797a9a41e03acecf9746baa3e882 Mon Sep 17 00:00:00 2001 From: Serhiy Storchaka Date: Mon, 22 Apr 2013 22:51:43 +0300 Subject: Issue #11714: Use 'with' statements to assure a Semaphore releases a condition variable. Original patch by Thomas Rachel. --- Lib/threading.py | 38 ++++++++++++++++++-------------------- Misc/ACKS | 1 + Misc/NEWS | 3 +++ 3 files changed, 22 insertions(+), 20 deletions(-) diff --git a/Lib/threading.py b/Lib/threading.py index 46df676..ab9302c 100644 --- a/Lib/threading.py +++ b/Lib/threading.py @@ -248,31 +248,29 @@ class Semaphore: raise ValueError("can't specify timeout for non-blocking acquire") rc = False endtime = None - self._cond.acquire() - while self._value == 0: - if not blocking: - break - if timeout is not None: - if endtime is None: - endtime = _time() + timeout - else: - timeout = endtime - _time() - if timeout <= 0: - break - self._cond.wait(timeout) - else: - self._value = self._value - 1 - rc = True - self._cond.release() + with self._cond: + while self._value == 0: + if not blocking: + break + if timeout is not None: + if endtime is None: + endtime = _time() + timeout + else: + timeout = endtime - _time() + if timeout <= 0: + break + self._cond.wait(timeout) + else: + self._value = self._value - 1 + rc = True return rc __enter__ = acquire def release(self): - self._cond.acquire() - self._value = self._value + 1 - self._cond.notify() - self._cond.release() + with self._cond: + self._value = self._value + 1 + self._cond.notify() def __exit__(self, t, v, tb): self.release() diff --git a/Misc/ACKS b/Misc/ACKS index 9961aa5..36adf7d 100644 --- a/Misc/ACKS +++ b/Misc/ACKS @@ -970,6 +970,7 @@ Fernando Pérez Pierre Quentel Brian Quinlan Anders Qvist +Thomas Rachel Jérôme Radix Burton Radons Jeff Ramnani diff --git a/Misc/NEWS b/Misc/NEWS index e71b6ed..60945c6 100644 --- a/Misc/NEWS +++ b/Misc/NEWS @@ -36,6 +36,9 @@ Core and Builtins Library ------- +- Issue #11714: Use 'with' statements to assure a Semaphore releases a + condition variable. Original patch by Thomas Rachel. + - Issue #17795: Reverted backwards-incompatible change in SysLogHandler with Unix domain sockets. -- cgit v0.12