不能直接在子线程调用 loop.create_task()，因为事件循环非线程安全；必须用 loop.call_soon_threadsafe() 提交同步回调，在其中调用 create_task() 调度协程。
为什么不能直接在子线程里用 loop.create_task()
因为事件循环对象（loop）不是线程安全的，直接从非主线程调用 create_task() 会触发 RuntimeError: This event loop is already running 或静默失败。Python 的 asyncio 默认只允许在运行 loop 的线程中调度协程，跨线程必须走线程安全的桥接接口。
loop.call_soon_threadsafe() 的正确用法
它把一个普通函数（不是协程！）提交到事件循环线程中立即执行。关键点在于：你得自己在里面手动创建任务，不能传协程对象进去。
- 传入的回调函数必须是同步函数，比如
lambda: loop.create_task(my_coro()) - 确保
loop是正在运行的实例（通常用asyncio.get_running_loop()获取） - 如果 loop 尚未启动（比如还没进
asyncio.run()），call_soon_threadsafe()会抛RuntimeError: no running event loop - 回调中不要做耗时操作，否则会阻塞事件循环；复杂逻辑建议封装成协程再
create_task
import asyncio
import threading
import time
<p>async def worker(n):
print(f"Task {n} started")
await asyncio.sleep(1)
print(f"Task {n} done")</p><p>def add_task_from_thread(loop, n):</p><h1>✅ 正确：在回调里调用 create_task</h1><pre class='brush:python;toolbar:false;'>loop.call_soon_threadsafe(lambda: loop.create_task(worker(n)))loop = asyncio.new_event_loop() t = threading.Thread(target=lambda: [add_task_from_thread(loop, i) for i in range(3)]) t.start() asyncio.set_event_loop(loop) loop.run_forever() # 注意：这里不会自动退出，需额外控制
常见错误：传协程对象或忘记捕获异常
下面两种写法都会出问题：
提示词大师-python版
下载
图片提示词生成器？不止如此。 马甲系统 —— 把脑海中的画面，翻译成AI能理解的专业表达。 用得越多，它越懂你：首次需要多问几句确认方向，用久了几乎一说就懂。 用得越多，它越快：缓存机制让后续对话越来越省。 RAG进化：成功案例持续入库，越跑越聪明。 输入「新手指南」查看完整功能介绍
立即学习“Python免费学习笔记（深入）”；
-
loop.call_soon_threadsafe(worker(1))—— 错！worker(1)立即执行并返回coroutine对象，但call_soon_threadsafe期望的是可调用对象，且该协程根本没被调度 - 回调函数内部抛异常（比如
create_task参数错）不会冒泡到子线程，而是被事件循环吞掉，日志里也看不到 —— 建议加try/except包裹
# ❌ 危险写法
loop.call_soon_threadsafe(worker(1))
<h1>✅ 更健壮的写法</h1><p>def safe_add(loop, coro):
try:
loop.create_task(coro)
except Exception as e:
print(f"Failed to schedule task: {e}")</p><p>loop.call_soon_threadsafe(safe_add, loop, worker(1))</p>替代方案：用 asyncio.Queue 解耦线程与协程
当任务来源多、频率高或需要限流时，call_soon_threadsafe 容易让主线程瞬间积压大量回调。更稳的方式是用队列中转：
- 子线程往
asyncio.Queue放任务描述（如函数名+参数） - 主协程里用
await queue.get()拿到后调用create_task - 队列天然支持背压，避免事件循环过载
- 注意：Queue 实例必须在事件循环线程中创建，不能在子线程里 new
真正难的不是“怎么加”，而是“加完之后怎么确保它不卡住 loop、不丢任务、不出错又可观测”——这些细节往往在压测或长时间运行时才暴露。
