为何启动run_forever的asyncio事件循环无法处理新提交的任务？

核心原因 #

asyncio事件循环的run_forever()方法并非持续轮询任务队列，当循环内没有待执行任务、回调函数，也无IO事件等待处理时，它会进入内核休眠状态，仅在收到唤醒信号时才会恢复运行。

你在非事件循环线程调用loop.create_task()时，只是将任务加入了队列，但该操作不会主动触发唤醒信号。休眠中的事件循环无法感知新任务的加入，因此永远不会执行它。

而当存在一个持续运行的任务（如你写的main函数），该任务会通过await asyncio.sleep(0.1)定期唤醒事件循环。每次唤醒时，事件循环会扫描任务队列，发现并执行新提交的任务。

线程安全问题说明 #

需要注意：直接在非事件循环线程调用loop.create_task()属于线程不安全操作，asyncio的多数API未做线程安全保障，可能导致意外问题。

正确解决方案 #

方案1：使用线程安全的协程提交方法 #

跨线程提交协程任务时，优先使用asyncio.run_coroutine_threadsafe()，它既保证线程安全，又会主动唤醒事件循环：

# 提交任务并获取Future对象
future = asyncio.run_coroutine_threadsafe(dostuff(0), loop)
# 如需获取任务结果，可调用（会阻塞当前线程直到任务完成）
# result = future.result()

方案2：手动唤醒事件循环 #

如果坚持使用create_task，需在提交任务后手动唤醒事件循环（但仍需注意线程安全，建议配合call_soon_threadsafe）：

# 线程安全地提交任务并唤醒循环
def submit_task():
    loop.create_task(dostuff(0))

loop.call_soon_threadsafe(submit_task)

call_soon_threadsafe会主动唤醒休眠的事件循环，使其扫描任务队列并执行新任务。

方案3：避免跨线程操作事件循环 #

如果业务允许，尽量将任务提交逻辑放在事件循环所在线程，从根源避免线程安全和唤醒问题。

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