Tkinter与Multiprocessing结合时的对象序列化问题

# 错误示例 (简化)
class MediaPlayer:
    def __init__(self, ruta, frame_visualizer, ...):
        # frame_visualizer 等 Tkinter 对象被作为 self 的属性
        self.frame_visualizer = frame_visualizer
        # ...
        # 启动进程时，尝试序列化 self (因为 target 是 self.funcion1)
        p = Process(target=self.funcion1) # 此时 self 包含不可序列化的 Tkinter 对象
        p.start()

    def funcion1(self):
        # 这个函数在子进程中运行
        # 如果它尝试直接访问 self.frame_visualizer，也会有问题
        pass

import tkinter as tk
from tkinter import ttk
from multiprocessing import Process, Queue
import time
import sys # 用于在Windows下确保多进程的入口点

# 确保在Windows上使用if __name__ == "__main__": 保护多进程代码
# 这是multiprocessing模块的要求，特别是在使用'spawn'启动方式时
if sys.platform.startswith('win'):
    # 在Windows上，Process对象需要能够导入模块以查找目标函数。
    # 放置此检查以确保在主脚本运行时不会出现导入错误。
    pass

# --- 独立的工作函数 ---
def background_media_processor(file_path, output_queue):
    """
    这是一个在单独进程中运行的函数，负责媒体处理。
    它只接收可序列化的数据（如文件路径），并通过队列发送结果。
    """
    print(f"工作进程启动，处理文件: {file_path}")
    output_queue.put(f"开始处理: {file_path}")

    try:
        # 模拟耗时媒体处理
        for i in range(1, 6):
            time.sleep(1) # 模拟处理时间
            progress = i * 20
            message = f"处理中... {progress}%"
            print(f"工作进程: {message}")
            output_queue.put(message) # 发送进度更新到主进程

        final_result = f"文件 '{file_path}' 处理完成！"
        print(f"工作进程: {final_result}")
        output_queue.put(final_result) # 发送最终结果
    except Exception as e:
        error_message = f"处理 '{file_path}' 时发生错误: {e}"
        print(f"工作进程错误: {error_message}")
        output_queue.put(error_message)

class MediaApp(tk.Tk):
    def __init__(self):
        super().__init__()
        self.title("Tkinter多进程媒体处理示例")
        self.geometry("400x300")

        self.status_label = ttk.Label(self, text="请选择一个媒体文件开始处理", wraplength=350)
        self.status_label.pack(pady=10)

        self.tree = ttk.Treeview(self, columns=("Path",), show="headings")
        self.tree.heading("Path", text="媒体文件路径")
        self.tree.insert("", "end", iid="media1", values=("C:/Videos/my_movie.mp4",))
        self.tree.insert("", "end", iid="media2", values=("D:/Music/audio_track.mp3",))
        self.tree.insert("", "end", iid="media3", values=("/home/user/docs/presentation.pptx",)) # 示例非视频文件
        self.tree.pack(pady=10, fill="both", expand=True)

        self.tree.bind("<<TreeviewSelect>>", self.on_item_selected)

        self.current_process = None
        self.result_queue = Queue() # 用于接收子进程的消息

        # 定期检查队列，以更新UI
        self.after(100, self.check_queue_for_updates)

    def on_item_selected(self, event):
        selected_item_ids = self.tree.selection()
        if not selected_item_ids:
            return

        selected_item_id = selected_item_ids[0]
        item_data = self.tree.item(selected_item_id)
        file_path = item_data["values"][0] # 获取文件路径字符串

        # 如果有正在运行的进程，先尝试终止它
        if self.current_process and self.current_process.is_alive():
            self.status_label.config(text="正在终止上一个处理进程...")
            print("主线程: 正在终止上一个进程...")
            self.current_process.terminate() # 强制终止进程
            self.current_process.join() # 等待进程结束
            print("主线程: 上一个进程已终止。")
            # 清空队列中可能残留的消息
            while not self.result_queue.empty():
                self.result_queue.get()

        self.status_label.config(text=f"准备处理: {file_path}")
        print(f"主线程: 启动新进程处理 '{file_path}'")

        # 启动新进程，只传递可序列化的数据 (文件路径和队列)
        self.current_process = Process(target=background_media_processor, args=(file_path, self.result_queue))
        self.current_process.start()

    def check_queue_for_updates(self):
        """
        定期检查队列是否有来自子进程的消息，并在主线程中更新UI。
        """
        while not self.result_queue.empty():
            message = self.result_queue.get()
            self.status_label.config(text=message)
            print(f"主线程收到消息: {message}")

            # 如果收到完成或错误消息，可以进一步处理，例如重置UI或记录日志
            if "处理完成" in message or "错误" in message:
                if self.current_process and not self.current_process.is_alive():
                    self.current_process.join() # 确保进程完全结束
                    self.current_process = None
                    print("主线程: 工作进程已彻底结束。")

        # 继续定期检查
        self.after(100, self.check_queue_for_updates)

if __name__ == "__main__":
    # 在Windows上，Process对象的创建必须放在 if __name__ == "__main__": 块内
    # 否则在子进程导入模块时会再次执行主脚本，导致无限循环或错误。
    app = MediaApp()
    app.mainloop()