Telegram Bot中如何启动新线程，无需等待函数执行完成？

问题分析 #

你开发的Telegram Bot中，/send命令调用的sendmail函数耗时约5秒，希望实现命令可同时多次执行且无需等待，但现有两种尝试均存在问题：

• 直接使用Thread时，主线程仍需等待sendmail执行完成
• 使用ThreadPoolExecutor时，触发RuntimeError: cannot schedule new futures after interpreter shutdown错误

错误原因拆解 #

1. Thread用法错误：

   Thread(target=sendmail(email, amount, update, context)).start()
   

   这里sendmail(...)会被立即执行，你实际是把函数的返回值传给了target，线程并未真正异步执行任务，所以主线程会等待函数完成。

2. ThreadPoolExecutor用法错误：

   • with语句块结束时会自动关闭执行器，后续无法提交新任务
   • .result()会强制主线程等待任务执行完毕，完全失去异步效果

正确实现方案 #

方案1：正确使用Thread异步执行 #

将函数对象传给target，通过args传递参数，避免提前执行函数：

import threading

def send(update, context):
    # 处理email、amount等参数逻辑
    # 异步启动sendmail
    threading.Thread(
        target=sendmail,
        args=(email, amount, update, context),
        daemon=True  # 设置为守护线程，随主线程退出而结束
    ).start()
    # 立即给用户回复，不用等待sendmail完成
    context.bot.send_message(chat_id=update.effective_chat.id, text="任务已启动，稍后完成")

方案2：使用全局ThreadPoolExecutor #

在Bot初始化时创建全局线程池，避免每次调用命令时创建/关闭执行器，且不调用.result()：

from concurrent.futures import ThreadPoolExecutor

# 在Bot启动时初始化全局线程池，不要在命令函数内部创建
executor = ThreadPoolExecutor(max_workers=10)

def send(update, context):
    # 处理参数逻辑
    # 提交任务到线程池，无需等待结果
    executor.submit(sendmail, email, amount, update, context)
    # 立即回复用户
    context.bot.send_message(chat_id=update.effective_chat.id, text="任务已启动")

额外注意事项 #

• 确保sendmail函数线程安全，避免多个线程同时操作共享资源
• 若需处理任务结果或异常，可添加回调函数：

  def task_callback(future):
      try:
          result = future.result()
          # 处理成功结果
      except Exception as e:
          # 捕获并处理异常
          print(f"任务执行失败: {e}")
  
  executor.submit(sendmail, email, amount, update, context).add_done_callback(task_callback)
  

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