Python 利用asyncio同时运行多个协程
asyncio 的一个好处是我们可以同时运行许多协程。这些协同程序可以在一个组中创建并存储,然后同时一起执行。这可以使用 asyncio.gather() 函数来实现。1. 什么是 Asyncio gather()
asyncio.gather() 模块函数允许调用者将多个可等待对象组合在一起。分组后,可等待对象可以并发执行、等待和取消。results = await asyncio.gather(coro1(), asyncio.create_task(coro2()))
在我们可能预先创建许多任务或协程然后希望一次执行它们并等待它们全部完成后再继续的情况下,我们可以使用 asyncio.gather() 函数。通过 await 表达式执行并等待组中的所有可等待对象完成。
从所有分组的等待对象中获取结果,稍后通过 result() 方法检索。
要通过 cancel() 方法取消的一组等待对象。
通过 done() 方法检查组中的所有可等待对象是否已完成。仅当组中的所有任务完成时才执行回调函数。
2. 如何使用 Asyncio gather()
在本节中,我们将仔细研究如何使用 asyncio.gather() 函数。多项任务
多个协程任务和协程的混合
...asyncio.gather(coro1(), coro2())
如果 Task 对象被提供给 gather(),它们将已经在运行,因为 Tasks 被安排为创建的一部分。asyncio.gather() 函数将可等待对象作为位置参数。asyncio.gather([coro1(), coro2()])
如果首先使用星号运算符 (*) 将其解压缩到单独的表达式中,则可以提供等待列表。点击查看剩余70%
网友评论