def acquire(self, blocking=1): if self._is_owned(): raise NRLockException("Recursive NRLock acquire") return threading._RLock.acquire(self, blocking)