test_locks.py - OpenGrok cross reference for /third_party/python/Lib/test/test_asyncio/test

Lines Matching defs:asyncio
7 import asyncio
23     asyncio.set_event_loop_policy(None)
29         lock = asyncio.Lock()
38         lock = asyncio.Lock()
50             asyncio.Lock,
51             asyncio.Condition,
52             asyncio.Event,
53             asyncio.Semaphore,
54             asyncio.BoundedSemaphore,
57         loop = asyncio.get_running_loop()
69             asyncio.Lock(),
70             asyncio.Condition(),
71             asyncio.Semaphore(),
72             asyncio.BoundedSemaphore(),
76             await asyncio.sleep(0.01)
87         lock = asyncio.Lock()
107         t1 = asyncio.create_task(c1(result))
108         t2 = asyncio.create_task(c2(result))
110         await asyncio.sleep(0)
114         await asyncio.sleep(0)
117         await asyncio.sleep(0)
120         t3 = asyncio.create_task(c3(result))
123         await asyncio.sleep(0)
127         await asyncio.sleep(0)
138         lock = asyncio.Lock()
141         task = asyncio.create_task(lock.acquire())
142         asyncio.get_running_loop().call_soon(task.cancel)
143         with self.assertRaises(asyncio.CancelledError):
162         lock = asyncio.Lock()
172         fa = asyncio.get_running_loop().create_future()
173         ta = asyncio.create_task(lockit('A', fa))
174         await asyncio.sleep(0)
176         tb = asyncio.create_task(lockit('B', None))
177         await asyncio.sleep(0)
179         tc = asyncio.create_task(lockit('C', None))
180         await asyncio.sleep(0)
188         await asyncio.sleep(0)
198         loop = asyncio.get_running_loop()
199         lock = asyncio.Lock()
216         t1 = asyncio.create_task(lockit())
217         t2 = asyncio.create_task(lockit())
218         t3 = asyncio.create_task(lockit())
221         await asyncio.sleep(0)
224         with self.assertRaises(asyncio.CancelledError):
236         await asyncio.sleep(0)
240         lock = asyncio.Lock()
245         tb = asyncio.create_task(lock.acquire())
246         await asyncio.sleep(0)
251         tc = asyncio.create_task(lock.acquire())
254         await asyncio.sleep(0)
263         lock = asyncio.Lock()
268         lock = asyncio.Lock()
276         lock = asyncio.Lock()
288         ev = asyncio.Event()
302         ev = asyncio.Event()
319         t1 = asyncio.create_task(c1(result))
320         t2 = asyncio.create_task(c2(result))
322         await asyncio.sleep(0)
325         t3 = asyncio.create_task(c3(result))
328         await asyncio.sleep(0)
339         ev = asyncio.Event()
346         ev = asyncio.Event()
348         wait = asyncio.create_task(ev.wait())
349         asyncio.get_running_loop().call_soon(wait.cancel)
350         with self.assertRaises(asyncio.CancelledError):
355         ev = asyncio.Event()
365         ev = asyncio.Event()
373         t = asyncio.create_task(c1(result))
374         await asyncio.sleep(0)
385         await asyncio.sleep(0)
396         cond = asyncio.Condition()
417         t1 = asyncio.create_task(c1(result))
418         t2 = asyncio.create_task(c2(result))
419         t3 = asyncio.create_task(c3(result))
421         await asyncio.sleep(0)
427         await asyncio.sleep(0)
432         await asyncio.sleep(0)
437         await asyncio.sleep(0)
442         await asyncio.sleep(0)
447         await asyncio.sleep(0)
459         cond = asyncio.Condition()
462         wait = asyncio.create_task(cond.wait())
463         asyncio.get_running_loop().call_soon(wait.cancel)
464         with self.assertRaises(asyncio.CancelledError):
470         cond = asyncio.Condition()
475         wait_task = asyncio.create_task(cond.wait())
476         await asyncio.sleep(0)
483         asyncio.get_running_loop().call_soon(wait_task.cancel)
484         asyncio.get_running_loop().call_soon(cond.release)
488         except asyncio.CancelledError:
498         cond = asyncio.Condition()
506         waiter = asyncio.create_task(wait_on_cond())
507         await asyncio.sleep(0)  # Start waiting
511         await asyncio.sleep(0)  # Get to acquire()
513         await asyncio.sleep(0)  # Activate cancellation
515         await asyncio.sleep(0)  # Cancellation should occur
521         cond = asyncio.Condition()
526         cond = asyncio.Condition()
541         t = asyncio.create_task(c1(result))
543         await asyncio.sleep(0)
549         await asyncio.sleep(0)
556         await asyncio.sleep(0)
563         cond = asyncio.Condition()
573         cond = asyncio.Condition()
597         t1 = asyncio.create_task(c1(result))
598         t2 = asyncio.create_task(c2(result))
599         t3 = asyncio.create_task(c3(result))
601         await asyncio.sleep(0)
607         await asyncio.sleep(0)
614         await asyncio.sleep(0)
625         cond = asyncio.Condition()
643         t1 = asyncio.create_task(c1(result))
644         t2 = asyncio.create_task(c2(result))
646         await asyncio.sleep(0)
652         await asyncio.sleep(0)
661         cond = asyncio.Condition()
665         cond = asyncio.Condition()
669         cond = asyncio.Condition()
685         cond = asyncio.Condition()
694                 lock = asyncio.Lock()
696                 cond = asyncio.Condition(lock)
713         await f(asyncio.Lock())
714         lock = asyncio.Lock()
715         await f(lock, asyncio.Condition(lock))
718         loop = asyncio.new_event_loop()
723                 asyncio.Lock(loop=loop)  # actively disallowed since 3.10
724             lock = asyncio.Lock()
729                 cond = asyncio.Condition(lock)
740             lock = asyncio.Lock()
743                     asyncio.Condition(lock, loop=loop)
744                 cond = asyncio.Condition(lock)
756         condition = asyncio.Condition()
758             with self.assertRaises(asyncio.TimeoutError):
759                 await asyncio.wait_for(condition.wait(), timeout=0.5)
765         sem = asyncio.Semaphore(0)
769         sem = asyncio.Semaphore()
790         sem = asyncio.Semaphore()
803         self.assertRaises(ValueError, asyncio.Semaphore, -1)
806         sem = asyncio.Semaphore(3)
833         t1 = asyncio.create_task(c1(result))
834         t2 = asyncio.create_task(c2(result))
835         t3 = asyncio.create_task(c3(result))
837         await asyncio.sleep(0)
843         t4 = asyncio.create_task(c4(result))
849         await asyncio.sleep(0)
864         await asyncio.gather(*race_tasks)
867         sem = asyncio.Semaphore()
870         acquire = asyncio.create_task(sem.acquire())
871         asyncio.get_running_loop().call_soon(acquire.cancel)
872         with self.assertRaises(asyncio.CancelledError):
878         sem = asyncio.Semaphore(value=0)
880         t1 = asyncio.create_task(sem.acquire())
881         t2 = asyncio.create_task(sem.acquire())
882         t3 = asyncio.create_task(sem.acquire())
883         t4 = asyncio.create_task(sem.acquire())
885         await asyncio.sleep(0)
891         await asyncio.sleep(0)
892         await asyncio.sleep(0)
900         await asyncio.sleep(0)
903         sem = asyncio.Semaphore(value=0)
905         t1 = asyncio.create_task(sem.acquire())
906         t2 = asyncio.create_task(sem.acquire())
907         await asyncio.sleep(0)
911         await asyncio.sleep(0)
912         await asyncio.sleep(0)
918         sem = asyncio.Semaphore(1)
922                 await asyncio.sleep(0)
929         t1 = asyncio.create_task(c1())
930         t2 = asyncio.create_task(c2())
932         r1, r2 = await asyncio.gather(t1, t2, return_exceptions=True)
934         self.assertTrue(isinstance(r2, asyncio.CancelledError))
936         await asyncio.wait_for(sem.acquire(), timeout=1.0)
939         sem = asyncio.BoundedSemaphore()
944         sem = asyncio.Semaphore()
952         sem = asyncio.Semaphore(1)
958             await asyncio.sleep(0.01)
963             await asyncio.sleep(0.01)
966         async with asyncio.TaskGroup() as tg:
977         sem = asyncio.Semaphore(1)
998         t1 = asyncio.create_task(c1(result))
999         t2 = asyncio.create_task(c2(result))
1000         t3 = asyncio.create_task(c3(result))
1002         await asyncio.sleep(0)
1008         await asyncio.gather(*tasks)
1012         sem = asyncio.Semaphore(0)
1030         t1 = asyncio.create_task(c1(result))
1031         t2 = asyncio.create_task(c2(result))
1032         t3 = asyncio.create_task(c3(result))
1034         await asyncio.sleep(0)
1038         await asyncio.sleep(0)
1044         await asyncio.gather(*tasks, return_exceptions=True)
1055         tasks = [asyncio.create_task(coro()) for _ in range(n)]
1060         res = await asyncio.gather(*tasks)
1064         barrier = asyncio.Barrier(self.N)
1075         barrier = asyncio.Barrier(self.N)
1086             waiters.append(asyncio.create_task(wait(barrier)))
1087         await asyncio.sleep(0)
1095             waiters.append(asyncio.create_task(wait(barrier)))
1096         await asyncio.sleep(0)
1103             waiters.append(asyncio.create_task(wait(barrier)))
1104         await asyncio.sleep(0)
1113             waiters.append(asyncio.create_task(wait(barrier)))
1114         await asyncio.sleep(0)
1123         await asyncio.gather(*waiters, return_exceptions=True)
1126         self.assertRaises(ValueError, lambda: asyncio.Barrier(0))
1127         self.assertRaises(ValueError, lambda: asyncio.Barrier(-4))
1129         self.assertIsInstance(asyncio.Barrier(self.N), asyncio.Barrier)
1133         barrier = asyncio.Barrier(self.N)
1147         barrier = asyncio.Barrier(1)
1160         barrier = asyncio.Barrier(1)
1162         t1 = asyncio.create_task(barrier.wait())
1163         await asyncio.sleep(0)
1166         t2 = asyncio.create_task(barrier.wait())
1167         await asyncio.sleep(0)
1177         barrier = asyncio.Barrier(self.N)
1179         t1 = asyncio.create_task(barrier.wait())
1180         await asyncio.sleep(0)
1184         t2 = asyncio.create_task(barrier.wait())
1185         await asyncio.sleep(0)
1189         t3 = asyncio.create_task(barrier.wait())
1190         await asyncio.sleep(0)
1192         await asyncio.wait([t1, t2, t3])
1198         barrier = asyncio.Barrier(self.N)
1218         barrier = asyncio.Barrier(self.N)
1242         barrier = asyncio.Barrier(self.N)
1261         barrier = asyncio.Barrier(self.N)
1262         barrier_nowaiting = asyncio.Barrier(self.N - rewait)
1290         barrier = asyncio.Barrier(self.N)
1297         t1 = asyncio.create_task(coro())
1298         await asyncio.sleep(0)
1301         t2 = asyncio.create_task(coro())
1302         await asyncio.sleep(0)
1306         await asyncio.sleep(0)
1308         with self.assertRaises(asyncio.CancelledError):
1312         t3 = asyncio.create_task(coro())
1313         await asyncio.sleep(0)
1316         t4 = asyncio.create_task(coro())
1317         await asyncio.gather(t2, t3, t4)
1326         barrier = asyncio.Barrier(1)
1328         asyncio.create_task(barrier.reset())
1329         await asyncio.sleep(0)
1335         barrier = asyncio.Barrier(self.N)
1341             except asyncio.BrokenBarrierError:
1349         await asyncio.sleep(0)
1352         asyncio.create_task(coro_reset())
1353         await asyncio.gather(*tasks)
1362         barrier = asyncio.Barrier(self.N)
1369             except asyncio.BrokenBarrierError:
1386         barrier = asyncio.Barrier(self.N)
1396             except asyncio.BrokenBarrierError:
1405                     # reset now: raise asyncio.BrokenBarrierError for waiting tasks
1413                     except asyncio.BrokenBarrierError:
1426         barrier = asyncio.Barrier(self.N)
1433             except asyncio.BrokenBarrierError:
1446         asyncio.create_task(barrier.reset())
1447         await asyncio.sleep(0)
1450         asyncio.create_task(coro2())
1452         await asyncio.gather(*tasks)
1464         barrier = asyncio.Barrier(self.N)
1509         barrier = asyncio.Barrier(1)
1511         asyncio.create_task(barrier.abort())
1512         await asyncio.sleep(0)
1518         barrier = asyncio.Barrier(self.N)
1528             except asyncio.BrokenBarrierError:
1534                     # abort now: raise asyncio.BrokenBarrierError for all tasks
1539                     except asyncio.BrokenBarrierError:
1553         barrier = asyncio.Barrier(self.N)
1564             except asyncio.BrokenBarrierError:
1579         barrier1 = asyncio.Barrier(self.N)
1580         barrier2 = asyncio.Barrier(self.N)
1592             except asyncio.BrokenBarrierError: