在Python中,并行化多个异步函数的调用可以使用asyncio
库来实现。下面是一个示例代码:
import asyncio
async def async_function(name, delay):
print(f'{name} started')
await asyncio.sleep(delay)
print(f'{name} finished')
async def main():
tasks = [
asyncio.create_task(async_function('Task 1', 2)),
asyncio.create_task(async_function('Task 2', 1)),
asyncio.create_task(async_function('Task 3', 3))
]
await asyncio.wait(tasks)
asyncio.run(main())
在上面的示例中,我们定义了一个async_function
异步函数,它接受一个名称和延迟时间作为参数,然后打印开始和结束的消息,并使用asyncio.sleep
函数模拟异步操作。
在main
函数中,我们创建了三个异步任务,并使用asyncio.create_task
函数将它们添加到任务列表中。然后,我们使用asyncio.wait
函数等待所有任务完成。
最后,我们使用asyncio.run
函数来运行main
函数。
当运行上述代码时,你会看到三个任务同时开始,并且在不同的时间完成。这是因为asyncio
库使用事件循环来调度异步任务,从而实现并行化调用多个异步函数的目的。
上一篇:并行化独立创建数据帧
下一篇:并行化反序列化步骤