Lines Matching full:lock
99 lock = self.locktype()
100 del lock
103 lock = self.locktype()
104 self.assertRegex(repr(lock), "<unlocked .* object (.*)?at .*>")
105 del lock
108 lock = self.locktype()
109 lock.acquire()
110 self.assertRegex(repr(lock), "<locked .* object (.*)?at .*>")
111 del lock
114 lock = self.locktype()
115 lock.acquire()
116 del lock
119 lock = self.locktype()
120 lock.acquire()
121 lock.release()
122 del lock
125 lock = self.locktype()
126 self.assertTrue(lock.acquire(False))
127 lock.release()
130 lock = self.locktype()
131 lock.acquire()
134 result.append(lock.acquire(False))
137 lock.release()
140 lock = self.locktype()
141 lock.acquire()
144 lock.acquire()
145 lock.release()
151 lock.release()
156 lock = self.locktype()
158 lock.acquire()
159 lock.release()
161 with lock:
165 # Check the lock is unacquired
168 # Check the lock is unacquired
172 # The lock shouldn't leak a Thread instance when used from a foreign
174 lock = self.locktype()
176 lock.acquire()
177 lock.release()
191 lock = self.locktype()
193 self.assertRaises(ValueError, lock.acquire, False, 1)
195 self.assertRaises(ValueError, lock.acquire, timeout=-100)
196 self.assertRaises(OverflowError, lock.acquire, timeout=1e100)
197 self.assertRaises(OverflowError, lock.acquire, timeout=TIMEOUT_MAX + 1)
199 lock.acquire(timeout=TIMEOUT_MAX)
200 lock.release()
202 self.assertTrue(lock.acquire(timeout=5))
209 results.append(lock.acquire(timeout=0.5))
217 lock = self.locktype()
218 ref = weakref.ref(lock)
222 lock = self.locktype()
223 ref = weakref.ref(lock)
224 del lock
235 # Lock needs to be released before re-acquiring.
236 lock = self.locktype()
240 lock.acquire()
242 lock.acquire()
251 lock.release()
257 # Lock can be released from a different thread.
258 lock = self.locktype()
259 lock.acquire()
261 lock.release()
264 lock.acquire()
265 lock.release()
268 # Issue #11618: check that lock is in a proper state after a
270 lock = self.locktype()
271 lock.acquire()
272 self.assertFalse(lock.acquire(timeout=0.01))
273 lock.release()
274 self.assertFalse(lock.locked())
275 self.assertTrue(lock.acquire(blocking=False))
279 def use_lock(lock): argument
280 # make sure that the lock still works normally
282 lock.acquire()
283 lock.release()
286 lock = self.locktype()
287 lock._at_fork_reinit()
288 use_lock(lock)
290 # locked: _at_fork_reinit() resets the lock to the unlocked state
302 lock = self.locktype()
303 lock.acquire()
304 lock.acquire()
305 lock.release()
306 lock.acquire()
307 lock.release()
308 lock.release()
311 # Cannot release an unacquired lock
312 lock = self.locktype()
313 self.assertRaises(RuntimeError, lock.release)
314 lock.acquire()
315 lock.acquire()
316 lock.release()
317 lock.acquire()
318 lock.release()
319 lock.release()
320 self.assertRaises(RuntimeError, lock.release)
323 # Cannot _release_save an unacquired lock
324 lock = self.locktype()
325 self.assertRaises(RuntimeError, lock._release_save)
326 lock.acquire()
327 lock.acquire()
328 lock.release()
329 lock.acquire()
330 lock.release()
331 lock.release()
332 self.assertRaises(RuntimeError, lock._release_save)
336 lock = self.locktype()
338 lock.acquire()
341 self.assertRaises(RuntimeError, lock.release)
347 lock = self.locktype()
348 self.assertFalse(lock._is_owned())
349 lock.acquire()
350 self.assertTrue(lock._is_owned())
351 lock.acquire()
352 self.assertTrue(lock._is_owned())
355 result.append(lock._is_owned())
358 lock.release()
359 self.assertTrue(lock._is_owned())
360 lock.release()
361 self.assertFalse(lock._is_owned())
450 # ensure that condition is still using a Lock after reset
478 lock = threading.Lock()
479 cond = self.condtype(lock)
481 self.assertFalse(lock.acquire(False))
483 self.assertTrue(lock.acquire(False))
485 lock.release()
487 self.assertFalse(lock.acquire(False))