如何停止线程？能否绑定全局变量？解决thread2访问报错问题

1. 如何停止线程？ #

Python 的 threading.Thread 没有内置的 stop() 方法，直接强制终止线程可能导致资源泄漏或程序不稳定。正确的做法是使用**线程事件（threading.Event）**向线程发送停止信号，让线程自行退出。具体实现：

• 创建全局的 Event 对象，用于标记是否需要停止播放。
• 修改 play_video 函数，使其周期性检查该事件状态，一旦事件被触发，立即执行清理操作并退出。
• 如果 play_video 是通过 subprocess 调用外部播放器，可在触发停止信号时直接终止子进程。

2. 是否可以将线程绑定到全局变量解决可见性问题？ #

可以，但需注意两个关键点：

• 不能直接将 thread.start() 的返回值赋值给变量（start() 返回 None），必须先创建 Thread 对象，再调用 start()，确保变量持有有效的线程实例。
• 全局变量需正确初始化，避免在未创建线程时访问导致 NoneType 错误。

修正后的完整代码 #

import PySimpleGUI as sg
from my_scripts import *
from my_constants import *
import sys
import glob
import yt_dlp
import threading
import time
import os
import re

# 全局变量：线程实例和停止事件
thread2 = None
stop_playback_event = threading.Event()

sg.LOOK_AND_FEEL_TABLE['MyCreatedTheme'] = {
    'BACKGROUND': '#000066', 
    'TEXT': '#ffebbf', 
    'INPUT': '#354230', 
    'TEXT_INPUT': '#ffebbf', 
    'SCROLL': '#99CC99', 
    'BUTTON': ('#003333', '#FFCC66'), 
    'PROGRESS': ('#D1826B', '#CC8019'), 
    'BORDER': 1, 'SLIDER_DEPTH': 0, 'PROGRESS_DEPTH': 0
} 

sg.theme('MyCreatedTheme') 
sg.theme_background_color('#4eae61')
sg.set_options(font=('Fira Code', 16), background_color='#555f9a')

l1 = sg.Text('Put url here', font=('Fira Code', 16), expand_x=True, justification='center')
t1 = sg.Text('', enable_events=True, font=('Fira Code', 16), justification='left')
t2 = sg.InputText(font=('Fira Code', 16), justification='left', default_text='5', key='-folder-')

def delete_video_in_D():
    list_of_files = [os.remove(p) for p in glob.glob(r'D:\\*.*') if (os.path.isfile(p) and is_video(p))]

# 适配停止信号的play_video函数（根据实际播放逻辑调整）
def play_video(video_path, stop_event):
    # 示例1：自定义播放循环场景
    # while not stop_event.is_set():
    #     # 执行播放逻辑（如逐帧渲染）
    #     time.sleep(0.1)  # 定期检查停止信号
    
    # 示例2：调用外部播放器场景（如mpv、vlc）
    import subprocess
    proc = subprocess.Popen(["mpv", video_path])  # 替换为你的播放器命令
    while proc.poll() is None and not stop_event.is_set():
        time.sleep(0.1)
    if proc.poll() is None:
        proc.terminate()  # 终止播放器进程
        proc.wait()

layout = [
    [l1],
    [t1, sg.InputText(key='-url-')], 
    [t2],
    [sg.Button('Download', button_color='#b1defb')],
    [sg.Button('Cancel playing', button_color='#fbceb1')],
]

FOLDERS = {
    '1': Chef_Max_Mariola_PATH,
    '2': JuliaCrossBow_PATH,
    '3': French_Vibes_PATH,
    '4': Studio_Italiano_InClasse_PATH,
    '5': 'D:\\'
}

window = sg.Window('Main Window', layout)

while True:
    event, values = window.read()

    if event == sg.WIN_CLOSED:
        # 关闭窗口时清理播放线程
        if thread2 and thread2.is_alive():
            stop_playback_event.set()
            thread2.join()
        break
    elif event == 'Download':
        delete_video_in_D()
        url = values['-url-']
        folder = values['-folder-']
        os.chdir(FOLDERS[folder])
        try:
            with yt_dlp.YoutubeDL() as ydl:
                thread1 = threading.Thread(target=ydl.download, args=(url,), daemon=True)
                thread1.start()
                while thread1.is_alive():
                    time.sleep(0.1)  # 避免空循环占用CPU
                
                list_of_files = [x for x in glob.glob(r'*.*') if os.path.isfile(x) and is_video(x)]
                latest_file = max(list_of_files, key=os.path.getctime)
                new_name = re.sub(r'\s*\[.*?\]\s*', '', latest_file)
                os.rename(latest_file, new_name)
                
                # 重置停止事件并启动播放线程
                stop_playback_event.clear()
                thread2 = threading.Thread(target=play_video, args=(new_name, stop_playback_event), daemon=True)
                thread2.start()
            
        except Exception as e:
            print(f'Error on line {sys.exc_info()[-1].tb_lineno}: {type(e).__name__} - {e}')

    elif event == 'Cancel playing':
        if thread2 and thread2.is_alive():
            stop_playback_event.set()
            thread2.join()  # 等待线程完成清理
            thread2 = None  # 重置线程变量

window.close()

关键修改点说明 #

1. 修复线程实例赋值：将 thread2 = threading.Thread(...).start() 拆分为两行，确保 thread2 持有有效的 Thread 对象，而非 None。
2. 添加停止事件：使用 threading.Event 实现线程间安全通信，避免强制终止线程带来的风险。
3. 安全处理停止逻辑：在「Cancel playing」事件中，先检查线程是否存在且活跃，再触发停止信号并等待线程退出。
4. 优化空循环：将原有的 while True: pass 改为带 time.sleep 的循环，减少CPU占用。

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