下面是使用asyncio.wait
函数等待动态列表中的每个任务完成或被取消的代码示例:
import asyncio
async def some_task():
# 执行某些操作
await asyncio.sleep(1)
print("任务完成")
async def main():
tasks = []
num_tasks = 5
# 创建动态任务列表
for i in range(num_tasks):
tasks.append(asyncio.create_task(some_task()))
# 等待任务完成或被取消
done, pending = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
# 处理已完成的任务
for task in done:
print(f"已完成的任务:{task.result()}")
# 取消所有未完成的任务
for task in pending:
task.cancel()
try:
# 等待取消的任务完成
await asyncio.wait(pending)
except asyncio.CancelledError:
print("取消的任务已完成")
asyncio.run(main())
此代码示例创建了一个动态的任务列表,并使用asyncio.wait
函数来等待任务完成或被取消。asyncio.wait
函数返回一个已完成和未完成的任务集合。然后,我们可以处理已完成的任务,取消所有未完成的任务,并等待取消的任务完成。
请注意,在实际应用中,您可能需要根据您的需求进行修改和调整此示例代码。