为何通过run_forever启动的asyncio事件循环在无未完成任务时无法接收新任务？

这个问题的核心在于asyncio事件循环的休眠机制和线程安全规范，咱们一步步拆解：

1. 事件循环的休眠逻辑 #

当你调用loop.run_forever()时，事件循环会进入一个轮询循环，持续检查三类工作项：

• 待执行的回调函数
• 就绪的IO事件
• 等待调度的任务（Future/Task）

如果这三类工作项全为空，事件循环会进入阻塞休眠状态，直到有新的IO事件触发，或者被显式唤醒。此时你通过loop.create_task()添加的任务，只是被放进了任务队列，但不会主动唤醒休眠的事件循环——循环根本没机会去检查队列里的新任务，自然不会执行它。

2. 为什么加了持续任务就管用？ #

你写的main()任务是一个无限循环，每隔0.1秒就会执行await asyncio.sleep(0.1)。每次sleep结束后，事件循环会被唤醒，重新轮询所有工作项，这时候它就会发现你新提交的dostuff()任务，然后调度执行。本质上是这个持续任务不断“唤醒”循环，让它有机会检查新任务队列。

3. 更规范的解决方式（不用持续任务） #

首先要注意：在非事件循环线程直接调用loop.create_task()是线程不安全的，asyncio的大部分API都不支持跨线程调用。正确的跨线程提交任务方式是用asyncio.run_coroutine_threadsafe()，它不仅保证线程安全，还会主动唤醒事件循环，让新任务立刻被调度：

import asyncio, threading, time

loop = asyncio.new_event_loop()
thread = threading.Thread(target=loop.run_forever)
thread.start()

async def dostuff(i):
    await asyncio.sleep(5)
    print("doing something", i)

# 跨线程安全提交任务，自动唤醒事件循环
future = asyncio.run_coroutine_threadsafe(dostuff(0), loop)
# 如果需要获取任务结果，可以调用 future.result()（会阻塞当前线程直到任务完成）

补充小技巧 #

如果你不想用run_coroutine_threadsafe，也可以用loop.call_soon_threadsafe()来提交一个回调，在回调里创建任务，同样能唤醒循环：

loop.call_soon_threadsafe(lambda: loop.create_task(dostuff(0)))

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