Lines Matching refs:lock
13 async def task_loop(id, lock): argument
16 async with lock:
21 async def task_sleep(lock): argument
22 async with lock:
23 print("task have", lock.locked())
25 print("task release", lock.locked())
26 await lock.acquire()
28 lock.release()
31 async def task_cancel(id, lock, to_cancel=None): argument
33 async with lock:
44 lock = asyncio.Lock()
47 print(lock.locked())
48 await lock.acquire()
49 print(lock.locked())
51 lock.release()
52 print(lock.locked())
56 async with lock:
61 asyncio.create_task(task_loop(1, lock))
62 asyncio.create_task(task_loop(2, lock))
63 t3 = asyncio.create_task(task_loop(3, lock))
64 await lock.acquire()
66 lock.release()
71 asyncio.create_task(task_sleep(lock))
73 await task_sleep(lock)
78 asyncio.create_task(task_cancel(0, lock, ts))
79 ts[0] = asyncio.create_task(task_cancel(1, lock))
80 asyncio.create_task(task_cancel(2, lock))
82 print(lock.locked())
86 t0 = asyncio.create_task(task_cancel(0, lock))
87 t1 = asyncio.create_task(task_cancel(1, lock))
88 t2 = asyncio.create_task(task_cancel(2, lock))
94 print(lock.locked())