Lines Matching full:acquire
94 thread has acquired a reentrant lock, the same thread may acquire it again
107 thread has acquired a reentrant lock, the same thread may acquire it
138 def acquire(self, blocking=True, timeout=-1): member in _RLock
139 """Acquire a lock, blocking or non-blocking.
168 rc = self._block.acquire(blocking, timeout)
174 __enter__ = acquire
205 self._block.acquire()
240 # Export the lock's acquire() and release() methods
241 self.acquire = lock.acquire
245 # release() and acquire() on the lock). Ditto for _is_owned().
277 self._lock.acquire() # Ignore saved state
282 if self._lock.acquire(False):
314 waiter.acquire()
320 waiter.acquire()
324 gotit = waiter.acquire(True, timeout)
326 gotit = waiter.acquire(False)
407 the number of acquire() calls, plus an initial value. The acquire() method
421 def acquire(self, blocking=True, timeout=None): member in Semaphore
422 """Acquire a semaphore, decrementing the internal counter by one.
428 if multiple acquire() calls are blocked, release() will wake exactly one
441 most timeout seconds. If acquire does not complete successfully in
446 raise ValueError("can't specify timeout for non-blocking acquire")
466 __enter__ = acquire
497 the number of release() calls minus the number of acquire() calls, plus an
498 initial value. The acquire() method blocks if necessary until it can return
888 self._tstate_lock.acquire()
985 self._tstate_lock.acquire()
1054 # could try to acquire the lock again in the same thread, (in
1099 # This method passes its arguments to _tstate_lock.acquire().
1109 if lock.acquire(block, timeout):
1114 # bpo-45274: lock.acquire() acquired the lock, but the function
1560 lock.acquire()