本站资源收集于互联网,不提供软件存储服务,每天免费更新优质的软件以及学习资源!

PythonAsyncio如何实现真正的异步并发?

网络教程 app 1℃

PythonAsyncio如何实现真正的异步并发

python 异步编程 asyncio 的作用

在 python 中,await 和 async 用于异步编程,可以暂停一个协程,直到其依赖的异步任务完成。

修改主函数以实现真正的异步

问题中提到的 await 并没有立即执行更新产品循环,是因为异步任务在启动后需要等到所有依赖任务完成才能真正执行。要实现真正的异步,需要修改主函数:

    使用 asyncio.gather 来并发运行任务,而不是使用 taskgroup。在 update_product_loop 之前等待所有 recursion_products_init 任务完成。

修改后的主函数

async def main_modified(): results = [] for page in jdserver.api("api/product/getpagenum"): result = await recursion_products_init(page["page_num"]) results.append(result) results.append(update_product_loop()) for page in jdserver.api("api/product/getpagenum"): result = await recursion_sync_category(page["page_num"]) results.append(result) result1, result2 = await asyncio.gather(update_product_category(), update_products_price()) results.extend([result1, result2]) return results

测试结果

执行修改后的主协程:

results_modified = await auxiliary_runner(main_modified())results_modified

结果将显示所有任务真正以异步的方式完成。

以上就是Python Asyncio 如何实现真正的异步并发?的详细内容,更多请关注范的资源库其它相关文章!

转载请注明:范的资源库 » PythonAsyncio如何实现真正的异步并发?

喜欢 (0)