Hello! 欢迎来到小浪资源网!



Asyncio中await无效?如何正确实现异步任务并发执行?


Asyncio中await无效?如何正确实现异步任务并发执行?

异步编程中的 asyncio 的困惑

正如你所观察到的,在你的代码中,await 和 update_product_loop 并不是同步执行的,即使使用了 await。这是因为 update_product_loop 并未使用 async 声明,因此它只是一个常规的同步函数。

await 和 async 的作用如下:

  • async 表示一个函数是异步的,意味着它可以在不阻塞当前线程的情况下执行。
  • await 允许在异步函数内暂停执行,直到指定的任务完成。

为了让 update_product_loop 真正成为异步的,你需要使用 async 修饰它,并使用 asyncio.gather 将它与其他异步任务组合起来。以下是如何修改你的代码:

# Modifying the main function to use asyncio.gather instead of TaskGroup async def main_modified():     # Initialize products for each page     results = []     for page in JDServer.api("api/product/getPageNum"):         if True:  # Mocking products_insert_on as always True for testing             result = await recursion_products_init(page["page_num"])             results.append(result)          # Ensure all recursion_products_init are done before executing update_product_loop     if True:  # Mocking products_insert_on as always True for testing         results.append(update_product_loop())      # Synchronize categories for each page     if True:  # Mocking category_insert_on as always True for testing         for page in JDServer.api("api/product/getPageNum"):             result = await recursion_sync_category(page["page_num"])             results.append(result)      # Using asyncio.gather to run tasks concurrently     result1, result2 = await asyncio.gather(update_product_category(), update_products_price())     results.extend([result1, result2])      return results  # Using the auxiliary function to execute the modified main coroutine results_modified = await auxiliary_runner(main_modified())  # Printing the results print(results_modified)

通过这些修改,update_product_loop 将成为异步的,并且只有在所有初始化产品和同步类别的任务完成后才会执行。

相关阅读