异步编程中的 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 将成为异步的，并且只有在所有初始化产品和同步类别的任务完成后才会执行。
