[3.7] bpo-36688: Adding an implementation of RLock in _dummy_thread (GH-12943) by miss-islington · Pull Request #14144 · python/cpython
Expand Up
@@ -14,7 +14,7 @@
# Exports only things specified by thread documentation;
# skipping obsolete synonyms allocate(), start_new(), exit_thread().
__all__ = ['error', 'start_new_thread', 'exit', 'get_ident', 'allocate_lock',
'interrupt_main', 'LockType']
'interrupt_main', 'LockType', 'RLock']
# A dummy value TIMEOUT_MAX = 2**31 Expand Down Expand Up @@ -148,6 +148,36 @@ def __repr__(self): hex(id(self)) )
class RLock(LockType): """Dummy implementation of threading._RLock.
Re-entrant lock can be aquired multiple times and needs to be released just as many times. This dummy implemention does not check wheter the current thread actually owns the lock, but does accounting on the call counts. """ def __init__(self): super().__init__() self._levels = 0
def acquire(self, waitflag=None, timeout=-1): """Aquire the lock, can be called multiple times in succession. """ locked = super().acquire(waitflag, timeout) if locked: self._levels += 1 return locked
def release(self): """Release needs to be called once for every call to acquire(). """ if self._levels == 0: raise error if self._levels == 1: super().release() self._levels -= 1
# Used to signal that interrupt_main was called in a "thread" _interrupt = False # True when not executing in a "thread" Expand Down
# A dummy value TIMEOUT_MAX = 2**31 Expand Down Expand Up @@ -148,6 +148,36 @@ def __repr__(self): hex(id(self)) )
class RLock(LockType): """Dummy implementation of threading._RLock.
Re-entrant lock can be aquired multiple times and needs to be released just as many times. This dummy implemention does not check wheter the current thread actually owns the lock, but does accounting on the call counts. """ def __init__(self): super().__init__() self._levels = 0
def acquire(self, waitflag=None, timeout=-1): """Aquire the lock, can be called multiple times in succession. """ locked = super().acquire(waitflag, timeout) if locked: self._levels += 1 return locked
def release(self): """Release needs to be called once for every call to acquire(). """ if self._levels == 0: raise error if self._levels == 1: super().release() self._levels -= 1
# Used to signal that interrupt_main was called in a "thread" _interrupt = False # True when not executing in a "thread" Expand Down