如何确保一个异步任务完成后再启动依赖其结果的另一个异步任务？

你当前的写法里，两次调用loop.create_task()会把process和postprocess两个任务同时加入事件循环调度，它们会并行执行，不会等待前一个完成，完全不符合你想要的“第一个完成后再启动第二个”的需求。

要实现顺序执行并传递第一个函数的结果，有几种常用写法：

方式1：在主异步函数中按顺序await #

这是最直观的写法，把两个任务的执行逻辑封装到一个主函数里，依次等待每个任务完成：

async def process(x):
    # 让process返回处理结果，供postprocess使用
    result = await do_something(x)
    return result

async def postprocess(processed_data):
    await do_something_else(processed_data)

async def main(x):
    # 先等待process完成，拿到结果
    processed_result = await process(x)
    # 再用结果执行postprocess
    await postprocess(processed_result)

# Python 3.7+ 推荐用asyncio.run启动
import asyncio
asyncio.run(main(x))

# 如果是Python 3.6及以下，用事件循环的方式
# loop = asyncio.get_event_loop()
# loop.run_until_complete(main(x))

方式2：显式创建任务并依次等待 #

如果需要手动跟踪任务对象（比如查看任务状态），可以先创建第一个任务并等待完成，再创建第二个任务：

import asyncio

loop = asyncio.get_event_loop()
# 创建第一个任务并等待完成，获取结果
task_process = loop.create_task(process(x))
processed_result = loop.run_until_complete(task_process)
# 用结果创建第二个任务并执行
task_postprocess = loop.create_task(postprocess(processed_result))
loop.run_until_complete(task_postprocess)

不管用哪种方式，核心都是必须等待第一个异步函数完成后，再启动第二个，同时把第一个函数的返回值传递给第二个函数作为参数。

内容的提问来源于stack exchange，提问作者user19976975