在asyncio中,使用lock.acquire()方法获取锁时,如果在事件循环的末尾调用该方法,可能会导致死锁或阻塞。
为了避免这种情况,需要在async with语句中使用锁,并确保在协程完成后正确释放锁。
例如,下面的代码演示了如何使用asyncio锁:
import asyncio
async def worker(lock): async with lock: print('Worker started') await asyncio.sleep(2) print('Worker finished')
async def main(): lock = asyncio.Lock() tasks = [worker(lock) for _ in range(3)] await asyncio.gather(*tasks)
if name == 'main': asyncio.run(main())
在这个例子中,我们创建了一个asyncio锁,并将其传递给多个工作协程。每个工作协程都使用async with语句来获取锁,并在完成工作后释放锁。使用async with语句会自动管理锁的请求和释放,避免了潜在的死锁和阻塞问题。