code: def acquire (self, blocking=1):
          
          threadname = threading.currentThread().getName()
          log.debug(LOG_THREAD, "Acquire %s for %s", self.name, threadname)
          self.lock.acquire(blocking)
          log.debug(LOG_THREAD, "...acquired %s for %s", self.name, threadname)
docs: Acquire lock.