异步函数中的变量赋值可能存在冲突,需要使用 asyncio.Lock 等锁机制来避免。
示例代码:
import asyncio
async def foo():
global cnt
cnt += 1
async def bar():
global cnt
cnt -= 1
async def main():
global cnt
cnt = 0
task1 = asyncio.create_task(foo())
task2 = asyncio.create_task(bar())
await task1
await task2
print(cnt)
asyncio.run(main()) # 输出结果可能不为0
在以上示例中,foo() 和 bar() 都会修改全局变量 cnt,由于异步执行的不确定性,可能会出现非预期的冲突问题,导致结果不为0。可以通过使用 asyncio.Lock 等锁机制来避免:
import asyncio
async def foo():
global cnt
async with lock:
cnt += 1
async def bar():
global cnt
async with lock:
cnt -= 1
async def main():
global cnt
cnt = 0
global lock
lock = asyncio.Lock()
task1 = asyncio.create_task(foo())
task2 = asyncio.create_task(bar())
await task1
await task2
print(cnt)
asyncio.run(main()) # 输出结果为0
以上代码中,使用 asyncio.Lock 操作 cnt 变量,确保了不会出现竞争条件的问题。