asyncio未await任务执行等三个核心技术问题咨询

代码示例 #

import asyncio

async def run_test():
    print("run1")
    await asyncio.sleep(1)
    print("run2")

async def main():
    print("main1")
    loop = asyncio.get_event_loop()
    task = loop.create_task(run_test())
    #task = asyncio.create_task(run_test())
    #task = asyncio.ensure_future(run_test())
    print("main2")

print("________________")
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
print("________________")

不同场景下的输出 #

预期输出 #

________________
main1
main2
________________

（原预期认为未await的任务不会运行）

实际输出（含asyncio.sleep(1)） #

________________
main1
main2
run1
________________

移除asyncio.sleep(1)后的输出 #

________________
main1
main2
run1
run2
________________

注：使用asyncio.create_task()和asyncio.ensure_future()测试，结果一致。

问题与解答 #

1. 为什么未被await的run_test()仍会运行？ #

当你用loop.create_task()、asyncio.create_task()或asyncio.ensure_future()创建任务时，任务会被自动加入事件循环的待执行队列，只要事件循环处于运行状态，就会调度执行这些任务。

run_test()作为协程被包装成任务后，事件循环会在当前运行的协程（即main()）结束或让出控制权后，立刻调度执行它。main()执行到结束时没有任何阻塞操作，事件循环就会转而执行已加入队列的run_test()任务，直到它遇到第一个await（也就是asyncio.sleep(1)）——此时任务暂停，事件循环发现没有其他可运行的任务，才会终止，所以你会看到run1输出，但run2因sleep未完成没机会执行。

如果移除asyncio.sleep(1)，run_test()没有任何挂起点，会被事件循环一次性执行完，因此run1和run2都会输出。

2. 是否可以创建不加入事件循环的task？ #

可以，但不推荐直接操作底层实现。你可以直接实例化asyncio.Task对象并跳过自动注册步骤，但这种方式不在官方公开支持范围内，可能存在兼容性问题。

更稳妥的方式是：如果只是不想让协程被自动调度，完全没必要包装成task，直接保留协程对象即可：

# 仅创建协程对象，不会加入事件循环
coro = run_test()

若确实需要task但不想让它被自动执行，可创建后调用task.cancel()，但常规场景下没必要这么做。

3. run_until_complete()是否应在main()完成后立即返回？ #

loop.run_until_complete(future)的核心逻辑是：运行事件循环，直到传入的future完成，但事件循环会同时调度所有已加入队列的任务。

当main()完成时，传入的future（main()对应的协程）已经结束，但事件循环会检查是否还有其他待执行的任务（比如你创建的run_test() task）。如果有，事件循环会继续运行这些任务，直到所有任务进入暂停状态（如遇到await）或完成，才会终止。

这看似和函数名“run_until_complete”冲突，但实际上函数名的意思是“直到传入的future完成”，而非“传入的future完成后立刻停止事件循环”。事件循环的设计逻辑就是尽可能调度所有已注册的任务，直到没有可运行的任务为止——这是异步IO循环的核心，保证所有已提交的任务都有机会执行到挂起点或完成。

内容的提问来源于stack exchange，提问作者白井結衣