PySide6中如何从GUI向Worker Thread传递多个对象？

问题背景 #

需要将MainWidget中的多个测试对象（Test1/Test2/Test3）、参数及文件列表传递给Worker线程执行耗时的perform_task方法，但当前WorkerThread的构造函数参数过多，存在GUI与线程重复初始化变量的问题，希望找到更简洁的实现方式。

优化方案 #

核心思路 #

• 封装任务配置：将需要执行的测试实例、开关状态、临时参数打包成统一结构，避免逐个传递零散参数
• 明确线程职责：GUI线程仅负责用户输入验证、测试对象初始化；Worker线程专注执行耗时任务
• 简化Worker构造：减少构造函数参数数量，降低代码耦合

优化后代码示例 #

main.py

import sys
from PySide6.QtWidgets import QWidget, QApplication
from ui_widget import Ui_Form
from class1 import Test1
from class2 import Test2
from class3 import Test3
from pathlib import Path
from worker import WorkerThread

class MainWidget(QWidget, Ui_Form):
    def __init__(self):
        super().__init__()
        self.setupUi()
        self.files = Path().glob("*")  # 替换为实际的文件获取逻辑
        # 初始化变量，仅在验证通过后创建Test实例
        self.t1 = None
        self.t2 = None
        self.t3 = None
        self.t1_temp = ""
        self.t2_temp = ""
        self.t3_temp = ""

        # 修正信号连接：传递函数对象而非调用结果
        self.pushButton.clicked.connect(self.check_and_run)
    
    def check_and_run(self):
        task_list = []
        # 验证用户输入并收集需要执行的任务
        if self.test1.isChecked():
            x_val = self.test1_x.text()
            y_val = self.test1_y.text()
            # 这里添加实际的输入验证逻辑
            if x_val and y_val:
                self.t1 = Test1(x_val, y_val)
                task_list.append({"instance": self.t1, "temp_param": self.t1_temp})
        
        if self.test2.isChecked():
            x_val = self.test2_x.text()
            y_val = self.test2_y.text()
            if x_val and y_val:
                self.t2 = Test2(x_val, y_val)
                task_list.append({"instance": self.t2, "temp_param": self.t2_temp})
        
        if self.test3.isChecked():
            x_val = self.test3_x.text()
            y_val = self.test3_y.text()
            if x_val and y_val:
                self.t3 = Test3(x_val, y_val)
                task_list.append({"instance": self.t3, "temp_param": self.t3_temp})
        
        # 创建并启动Worker线程
        self.worker = WorkerThread(task_list, self.files)
        # 可选：连接finished信号更新GUI状态
        # self.worker.finished.connect(self.on_task_completed)
        self.worker.start()
    
    # 可选：任务完成后的GUI回调
    # def on_task_completed(self):
    #     self.pushButton.setEnabled(True)
    #     # 添加GUI更新逻辑

worker.py

from PySide6.QtCore import QThread

class WorkerThread(QThread):
    def __init__(self, task_list: list, files):
        super().__init__()
        self.task_list = task_list
        self.files = files
    
    def run(self):
        # 遍历文件并执行所有选中的测试任务
        for file in self.files:
            for task in self.task_list:
                test_instance = task["instance"]
                temp_param = task["temp_param"]
                # 根据实际Test类的方法参数调整传参
                test_instance.perform_task(temp_param, file)

class1.py（Test2/Test3类结构类似）

class Test1():
    def __init__(self, x, y) -> None:
        self.x = x
        self.y = y
    
    def perform_task(self, temp_param, file):
        # 这里编写耗时任务逻辑
        print(f"Test1 processing file: {file.name}, temp param: {temp_param}")
        # 实际耗时操作（如文件解析、计算等）

关键优化点说明 #

• 任务封装：用列表存储任务配置，每个元素包含测试实例和对应参数，避免Worker构造函数参数过多
• 线程安全：所有GUI相关操作（如获取输入、创建Test实例）都在主线程完成，Worker线程仅执行耗时任务
• 信号连接修正：原代码中pushButton.clicked.connect(self.check_and_run())会立即执行函数，正确写法是传递函数引用self.check_and_run
• 降低耦合：Worker线程无需了解GUI组件细节，只处理任务执行逻辑，代码更易维护

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