mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-12-04 00:30:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

add debug calls to self._note for the Semaphore class. This closes bug

Browse source 
443614.  I will submit a new feature request and patch to threading.py and
libthreading.tex to address the bounded semaphore issue.
This commit is contained in:
Skip Montanaro 2001-08-19 04:25:24 +00:00
parent dbec7d2c16
commit b446fc7f27
1 changed files with 9 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
Lib/threading.py
View file

@ -261,9 +261,15 @@ class _Semaphore(_Verbose):
while self.__value == 0: while self.__value == 0:
if not blocking: if not blocking:
break break
if __debug__:
self._note("%s.acquire(%s): blocked waiting, value=%s",
self, blocking, self.__value)
self.__cond.wait() self.__cond.wait()
else: else:
self.__value = self.__value - 1 self.__value = self.__value - 1
if __debug__:
self._note("%s.acquire: success, value=%s(%s)",
self, self.__value, self.__initial_value)
rc = 1 rc = 1
self.__cond.release() self.__cond.release()
return rc return rc
@ -271,6 +277,9 @@ class _Semaphore(_Verbose):
def release(self): def release(self):
self.__cond.acquire() self.__cond.acquire()
self.__value = self.__value + 1 self.__value = self.__value + 1
if __debug__:
self._note("%s.release: success, value=%s(%s)",
self, self.__value, self.__initial_value)
self.__cond.notify() self.__cond.notify()
self.__cond.release() self.__cond.release()