如何终止Python Thread？解决语音播报多线程重复创建问题

看起来你现在的困扰是每次调用speak()都会启动新线程，导致多个语音播放线程同时运行，而你希望每次调用后上一个线程能完全执行完毕，再处理下一个请求。下面给你几个实用的解决方案：

方法1：使用线程锁（Lock）保证串行执行 #

我们可以用threading.Lock来确保同一时间只有一个text_to_speach函数在执行。当一个线程获取锁后，其他线程必须等待锁释放才能继续执行逻辑。

修改后的代码如下：

import threading
from gtts import gTTS
from playsound import playsound
import os

# 创建全局锁对象
speak_lock = threading.Lock()

def text_to_speach(text):
    try:
        # 自动获取/释放锁，确保同一时间仅一个线程执行这段逻辑
        with speak_lock:
            tts = gTTS(text=text, lang='fr', tld="com", slow=False)
            tts.save("audio.mp3")
            playsound.playsound('audio.mp3', False)
            os.remove('audio.mp3')
    except Exception as e:
        print(f'Check Speak issue !!! Error details: {e}')

def speak(reply):
    thread = threading.Thread(target=text_to_speach, args=(reply,), daemon=True)
    thread.start()

说明：

• with speak_lock语法会自动处理锁的获取和释放，避免手动操作遗漏导致死锁。
• 后续调用speak()时，新线程会先等待前一个线程释放锁，再执行语音播放，完美实现串行执行。

方法2：维护全局线程对象，等待上一个线程结束再启动新线程 #

我们可以保存当前正在运行的线程实例，每次调用speak()时，先检查上一个线程是否还在运行，如果是则等待它结束，再启动新线程。

代码示例：

import threading
from gtts import gTTS
from playsound import playsound
import os

# 存储当前正在执行的语音线程
current_speak_thread = None

def text_to_speach(text):
    try:
        tts = gTTS(text=text, lang='fr', tld="com", slow=False)
        tts.save("audio.mp3")
        playsound.playsound('audio.mp3', False)
        os.remove('audio.mp3')
    except Exception as e:
        print(f'Check Speak issue !!! Error details: {e}')

def speak(reply):
    global current_speak_thread
    # 如果上一个线程还在运行，等待它结束
    if current_speak_thread is not None and current_speak_thread.is_alive():
        current_speak_thread.join()
    # 创建并启动新的语音线程
    current_speak_thread = threading.Thread(target=text_to_speach, args=(reply,), daemon=True)
    current_speak_thread.start()

说明：

• current_speak_thread.join()会阻塞当前调用speak()的线程，直到上一个语音播放完成，再启动新线程。
• 注意：如果你的主线程不能被阻塞（比如需要同时处理其他任务），这种方法可能不适合。

方法3：使用队列实现异步串行处理（推荐） #

这种方法更优雅，我们创建一个队列存储待播放的文本，再启动一个单独的常驻线程，不断从队列中取出文本进行播放。每次调用speak()只是把文本加入队列，不用重复创建新线程，所有请求会按顺序串行处理。

代码示例：

import threading
from queue import Queue
from gtts import gTTS
from playsound import playsound
import os

# 创建队列存储待播放的文本
speak_queue = Queue()

def speak_worker():
    """常驻工作线程，负责处理队列中的语音请求"""
    while True:
        text = speak_queue.get()
        try:
            tts = gTTS(text=text, lang='fr', tld="com", slow=False)
            tts.save("audio.mp3")
            playsound.playsound('audio.mp3', False)
            os.remove('audio.mp3')
        except Exception as e:
            print(f'Check Speak issue !!! Error details: {e}')
        finally:
            # 标记当前队列任务完成
            speak_queue.task_done()

# 启动常驻工作线程（守护线程，主线程退出时自动结束）
threading.Thread(target=speak_worker, daemon=True).start()

def speak(reply):
    # 将待播放文本加入队列
    speak_queue.put(reply)

说明：

• 只需要启动一次工作线程，后续所有speak()调用都只是往队列里添加任务，工作线程会按顺序处理，完全避免多线程并行问题。
• 这种方法不会阻塞主线程，同时保证语音播放的顺序，是最推荐的方案。

额外小提示 #

• 你原来的except块没有捕获具体异常，建议改成except Exception as e，这样可以打印具体错误信息，方便排查问题。
• 如果遇到playsound播放失败，可以尝试更换tld参数（比如法语用tld="fr"可能更稳定），或者检查音频文件是否被正确生成和删除。

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