Lines Matching full:lock
97 lock = self.locktype()
98 del lock
101 lock = self.locktype()
102 self.assertRegex(repr(lock), "<unlocked .* object (.*)?at .*>")
103 del lock
106 lock = self.locktype()
107 lock.acquire()
108 self.assertRegex(repr(lock), "<locked .* object (.*)?at .*>")
109 del lock
112 lock = self.locktype()
113 lock.acquire()
114 del lock
117 lock = self.locktype()
118 lock.acquire()
119 lock.release()
120 del lock
123 lock = self.locktype()
124 self.assertTrue(lock.acquire(False))
125 lock.release()
128 lock = self.locktype()
129 lock.acquire()
132 result.append(lock.acquire(False))
135 lock.release()
138 lock = self.locktype()
139 lock.acquire()
142 lock.acquire()
143 lock.release()
149 lock.release()
154 lock = self.locktype()
156 lock.acquire()
157 lock.release()
159 with lock:
163 # Check the lock is unacquired
166 # Check the lock is unacquired
170 # The lock shouldn't leak a Thread instance when used from a foreign
172 lock = self.locktype()
174 lock.acquire()
175 lock.release()
189 lock = self.locktype()
191 self.assertRaises(ValueError, lock.acquire, False, 1)
193 self.assertRaises(ValueError, lock.acquire, timeout=-100)
194 self.assertRaises(OverflowError, lock.acquire, timeout=1e100)
195 self.assertRaises(OverflowError, lock.acquire, timeout=TIMEOUT_MAX + 1)
197 lock.acquire(timeout=TIMEOUT_MAX)
198 lock.release()
200 self.assertTrue(lock.acquire(timeout=5))
207 results.append(lock.acquire(timeout=0.5))
215 lock = self.locktype()
216 ref = weakref.ref(lock)
220 lock = self.locktype()
221 ref = weakref.ref(lock)
222 del lock
232 # Lock needs to be released before re-acquiring.
233 lock = self.locktype()
237 lock.acquire()
239 lock.acquire()
248 lock.release()
254 # Lock can be released from a different thread.
255 lock = self.locktype()
256 lock.acquire()
258 lock.release()
261 lock.acquire()
262 lock.release()
265 # Issue #11618: check that lock is in a proper state after a
267 lock = self.locktype()
268 lock.acquire()
269 self.assertFalse(lock.acquire(timeout=0.01))
270 lock.release()
271 self.assertFalse(lock.locked())
272 self.assertTrue(lock.acquire(blocking=False))
276 def use_lock(lock): argument
277 # make sure that the lock still works normally
279 lock.acquire()
280 lock.release()
283 lock = self.locktype()
284 lock._at_fork_reinit()
285 use_lock(lock)
287 # locked: _at_fork_reinit() resets the lock to the unlocked state
299 lock = self.locktype()
300 lock.acquire()
301 lock.acquire()
302 lock.release()
303 lock.acquire()
304 lock.release()
305 lock.release()
308 # Cannot release an unacquired lock
309 lock = self.locktype()
310 self.assertRaises(RuntimeError, lock.release)
311 lock.acquire()
312 lock.acquire()
313 lock.release()
314 lock.acquire()
315 lock.release()
316 lock.release()
317 self.assertRaises(RuntimeError, lock.release)
320 # Cannot _release_save an unacquired lock
321 lock = self.locktype()
322 self.assertRaises(RuntimeError, lock._release_save)
323 lock.acquire()
324 lock.acquire()
325 lock.release()
326 lock.acquire()
327 lock.release()
328 lock.release()
329 self.assertRaises(RuntimeError, lock._release_save)
333 lock = self.locktype()
335 lock.acquire()
338 self.assertRaises(RuntimeError, lock.release)
344 lock = self.locktype()
345 self.assertFalse(lock._is_owned())
346 lock.acquire()
347 self.assertTrue(lock._is_owned())
348 lock.acquire()
349 self.assertTrue(lock._is_owned())
352 result.append(lock._is_owned())
355 lock.release()
356 self.assertTrue(lock._is_owned())
357 lock.release()
358 self.assertFalse(lock._is_owned())
447 # ensure that condition is still using a Lock after reset
469 lock = threading.Lock()
470 cond = self.condtype(lock)
472 self.assertFalse(lock.acquire(False))
474 self.assertTrue(lock.acquire(False))
476 lock.release()
478 self.assertFalse(lock.acquire(False))