线程间共享变量问题：Vosk音频播放器无法响应停止指令

核心问题 #

• 变量作用域失效：playMusic函数接收的stop是局部变量，是全局stop的副本，全局变量修改后，局部变量不会同步更新。
• 循环逻辑无效：playMusic的while循环执行一次播放后直接break，根本没有持续检测stop状态的机会。
• 硬编码索引脆弱：通过固定索引提取Vosk返回的文本（如[14:-3]），一旦返回格式变化就会出错。

修复方案 #

方案1：全局变量+修正循环逻辑 #

直接在playMusic中使用全局stop，同时调整循环逻辑，让播放过程中能及时响应停止指令：

import threading
import time

stop = False

def playMusic():
    global stop
    while not stop:
        music.play()
        # 播放过程中周期性检查停止信号，避免全程阻塞
        while music.is_playing() and not stop:
            time.sleep(0.5)
        if stop:
            music.stop()  # 如果音乐播放库支持，立即停止播放
    return

def checkwhileplaying():
    global stop
    data = q.get()
    if rec.AcceptWaveform(data):
        time.sleep(1)
        # 用字符串分割提取文本，替代硬编码索引
        result = rec.Result()
        stopmessage = result.split('"text":"')[1].split('"')[0]
    else:
        partial_result = rec.PartialResult()
        stopmessage = partial_result.split('"partial":"')[1].split('"')[0]
    
    if 'stop' in stopmessage.lower():  # 兼容大小写指令
        stop = True

# 创建线程，playMusic无需传参
play = threading.Thread(target=playMusic, daemon=True)
check = threading.Thread(target=checkwhileplaying, daemon=True)
play.start()
check.start()

方案2：使用threading.Event（更推荐的线程同步方式） #

threading.Event是线程安全的信号量，比全局布尔变量更可靠，专门用于线程间的信号传递：

import threading
import time

# 用Event替代布尔变量，线程安全
stop_event = threading.Event()

def playMusic():
    while not stop_event.is_set():
        music.play()
        # 播放过程中检查停止信号
        while music.is_playing() and not stop_event.is_set():
            time.sleep(0.5)
        if stop_event.is_set():
            music.stop()
    return

def checkwhileplaying():
    data = q.get()
    if rec.AcceptWaveform(data):
        time.sleep(1)
        result = rec.Result()
        stopmessage = result.split('"text":"')[1].split('"')[0]
    else:
        partial_result = rec.PartialResult()
        stopmessage = partial_result.split('"partial":"')[1].split('"')[0]
    
    if 'stop' in stopmessage.lower():
        stop_event.set()  # 设置事件，通知播放线程停止

play = threading.Thread(target=playMusic, daemon=True)
check = threading.Thread(target=checkwhileplaying, daemon=True)
play.start()
check.start()

关键修改说明 #

1. 移除playMusic的stop参数：原传参是值传递，局部变量与全局变量完全独立，修改全局变量无法影响局部变量的状态。
2. 优化播放循环：新增内层循环周期性检查停止信号，避免播放全程阻塞，确保能及时响应指令。
3. 替换硬编码索引：用字符串分割提取Vosk返回的文本，避免因返回格式变化导致的解析错误。
4. 线程安全优化（方案2）：threading.Event天然支持线程间安全通信，避免全局变量可能引发的竞态条件。
5. 指令兼容性：将识别文本转小写，兼容用户不同大小写的"stop"指令。

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