如何实现在Python异步环境中动态添加任务_通过loop.call_soon

不能直接在子线程调用 loop.create_task()，因为事件循环非线程安全；必须用 loop.call_soon_threadsafe() 提交同步回调，在其中调用 create_task() 调度协程。

如何实现在python异步环境中动态添加任务_通过loop.call_soon_threadsafe

为什么不能直接在子线程里用 `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() # 注意：这里不会自动退出，需额外控制

常见错误：传协程对象或忘记捕获异常

下面两种写法都会出问题：

A Python CLI skill for Cutout.Pro visual APIs — background removal, face cutout, and photo enhancement. Supports file upload & image URL input.

调用 Cutout.Pro 视觉处理 API 进行背景移除、人像抠图和照片增强，支持文件上传与图片 URL 输入。

下载

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>