Python协程动态添加任务的实现方案

Luna

发布时间：2026-10-13| 4人浏览过

原创

本文介绍在Python中如何通过多线程机制实现协程任务的动态添加。核心思路是创建独立线程运行事件循环，利用run_coroutine_threadsafe将协程注册到该循环中，从而避免阻塞主线程。文章包含详细代码示例及注意事项，帮助开发者理解异步编程中的线程与协程协作模式。

Python中的协程必须依托于事件循环才能执行，但事件循环一旦启动，便会阻塞当前所在的线程或任务。为了解决这一问题，通常的做法是在当前进程内额外开启一个独立线程，专门用于运行事件循环（event_loop）。由于事件循环是一个无限执行的机制，它会持续占用该线程的资源。

以下提供一个包含详细注释的演示代码，供参考学习。

此外，需要特别注意：在同一个事件循环实例中，不允许嵌套运行另一个事件循环。

程序运行结果如下：

import asyncio
from threading import Thread
 
 
async def production_task():
  i = 0
  while True:
    # 将consumption这个协程每秒注册一个到运行在线程中的循环，thread_loop每秒会获得一个一直打印i的无限循环任务
    asyncio.run_coroutine_threadsafe(consumption(i),
                     thread_loop) # 注意：run_coroutine_threadsafe 这个方法只能用在运行在线程中的循环事件使用
    await asyncio.sleep(1) # 必须加await
    i += 1
 
 
async def consumption(i):
  while True:
    print("我是第{}任务".format(i))
    await asyncio.sleep(1)
 
 
def start_loop(loop):
  # 运行事件循环， loop以参数的形式传递进来运行
  asyncio.set_event_loop(loop)
  loop.run_forever()
 
 
thread_loop = asyncio.new_event_loop() # 获取一个事件循环
run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 将次事件循环运行在一个线程中，防止阻塞当前主线程
run_loop_thread.start() # 运行线程，同时协程事件循环也会运行
 
advocate_loop = asyncio.get_event_loop() # 将生产任务的协程注册到这个循环中
advocate_loop.run_until_complete(production_task()) # 运行次循环

以上就是关于Python协程动态添加任务方法的完整分享，希望能为读者提供有价值的参考，欢迎支持本站。