Stowage/cpython
2
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-10-31 05:31:20 +00:00
Code Issues Projects Releases Packages Wiki Activity

Revert 60189 and restore performance.

Browse source
This commit is contained in:
Raymond Hettinger 2008-01-24 18:12:23 +00:00
parent 7a6eacd2ca
commit 70ec29d0f4
1 changed files with 24 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

32
Lib/threading.py
View file

@ -347,18 +347,27 @@ def isSet(self):
return self.__flag
def set(self):
with self.__cond:
self.__cond.acquire()
try:
self.__flag = True
self.__cond.notifyAll()
finally:
self.__cond.release()
def clear(self):
with self.__cond:
self.__cond.acquire()
try:
self.__flag = False
finally:
self.__cond.release()
def wait(self, timeout=None):
with self.__cond:
self.__cond.acquire()
try:
if not self.__flag:
self.__cond.wait(timeout)
finally:
self.__cond.release()
# Helper to generate new thread names
_counter = 0
@ -525,9 +534,10 @@ def __bootstrap_inner(self):
pass
def __stop(self):
with self.__block:
self.__stopped = True
self.__block.notifyAll()
self.__block.acquire()
self.__stopped = True
self.__block.notifyAll()
self.__block.release()
def __delete(self):
"Remove current thread from the dict of currently running threads."
@ -553,12 +563,15 @@ def __delete(self):
# since it isn't if dummy_threading is *not* being used then don't
# hide the exception.
with _active_limbo_lock:
_active_limbo_lock.acquire()
try:
try:
del _active[_get_ident()]
except KeyError:
if 'dummy_threading' not in _sys.modules:
raise
finally:
_active_limbo_lock.release()
def join(self, timeout=None):
if not self.__initialized:
@ -571,7 +584,8 @@ def join(self, timeout=None):
if __debug__:
if not self.__stopped:
self._note("%s.join(): waiting until thread stops", self)
with self.__block:
self.__block.acquire()
try:
if timeout is None:
while not self.__stopped:
self.__block.wait()
@ -589,6 +603,8 @@ def join(self, timeout=None):
else:
if __debug__:
self._note("%s.join(): thread stopped", self)
finally:
self.__block.release()
def getName(self):
assert self.__initialized, "Thread.__init__() not called"