PyQt5中如何等待QThread信号绑定的槽函数执行完成

在PyQt5开发中使用QThread加载DataFrame到绑定自定义抽象模型的QTableView控件，因跨线程不能直接操作UI，通过子线程定义信号触发主线程的加载逻辑，自定义线程代码如下：

class load_tables(QtCore.QThread):
    any_signal = QtCore.pyqtSignal(tuple)
    finished = QtCore.pyqtSignal(int)

    def __init__(self,parent=None,index=0,df=None,tabletype=0,extracount=0):
        super(load_tables,self).__init__(parent)
        self.index = index
        self.df = df
        self.tabletype = tabletype
        self.extracount = extracount

    def run(self):
        print('Starting thread...',self.index)
        
        self.any_signal.emit((self.df,self.tabletype,self.extracount))
        
        self.finished.emit(self.index)

其中any_signal绑定的槽函数负责执行大规模数据加载到UI控件的逻辑，耗时较长。
调用wait()方法等待线程结束时，子线程会很快执行完毕，主程序继续向下运行，但此时信号绑定的槽函数实际仍在执行，需要实现等待逻辑直到槽函数完全运行结束。

问题本质是Qt跨线程信号的默认连接机制导致的：

• 跨线程信号默认使用Qt.QueuedConnection连接方式，子线程执行emit()时，仅会将槽函数的调用事件投递到主线程的事件队列，不会同步等待槽函数执行完成，emit语句会立刻返回
• 上述线程类的run方法仅做了信号发送操作，没有其他耗时逻辑，因此会瞬间执行完毕，wait()自然会马上返回，但此时主线程可能还未处理事件队列中的加载槽任务
• 该写法本身没有正确利用QThread的并行能力：耗时的加载逻辑全部运行在主线程，子线程仅承担信号转发作用，反而增加了线程切换开销。

方案1：重构线程逻辑，将耗时操作全部移到子线程（推荐） #

这是QThread的标准正确用法，从根源上避免等待错位问题：

• 子线程run方法中完成所有耗时的DataFrame预处理、模型数据格式转换逻辑，全程不操作任何UI对象
• 子线程仅在数据全部处理完成后发送信号，将处理完毕的纯数据传递给主线程
• 主线程的槽函数仅执行数据绑定、视图刷新的轻量操作，耗时极短，此时绑定线程的finished信号触发后续逻辑即可，无需额外等待。

参考改法：

class LoadTablesThread(QtCore.QThread):
    data_prepared = QtCore.pyqtSignal(object, int, int)
    thread_finished = QtCore.pyqtSignal(int)

    def __init__(self, parent=None, index=0, df=None, tabletype=0, extracount=0):
        super().__init__(parent)
        self.index = index
        self.df = df
        self.tabletype = tabletype
        self.extracount = extracount

    def run(self):
        print('Starting thread...', self.index)
        # 所有耗时数据处理逻辑全部放在子线程执行
        processed_model_data = self._convert_data_for_model(self.df)
        # 仅将最终可直接使用的数据发送给UI线程
        self.data_prepared.emit(processed_model_data, self.tabletype, self.extracount)
        self.thread_finished.emit(self.index)

    def _convert_data_for_model(self, raw_df):
        # 此处放原槽函数中所有不涉及UI操作的耗时数据处理逻辑
        return converted_data

主线程接收到data_prepared信号后，直接将处理好的数据传入自定义模型，触发视图刷新即可，整个槽执行时间在毫秒级，不会出现执行时序错位的问题。

方案2：指定阻塞式队列连接，强制信号等待槽执行完成（临时方案，不推荐长期用） #

如果暂时不想重构现有代码，可以在绑定信号时手动指定连接方式为Qt.BlockingQueuedConnection：该连接方式下，子线程发射信号后会阻塞，直到主线程的槽函数执行完成才会继续运行后续代码。

注意：该连接方式绝对不能用于同一线程内的信号槽绑定，会直接触发死锁。

信号绑定代码修改如下：

# 绑定信号时显式指定连接方式
self.load_worker.any_signal.connect(
    self.load_data_to_table_slot, 
    QtCore.Qt.BlockingQueuedConnection
)

修改后子线程执行any_signal.emit()时会卡住，等主线程跑完耗时的加载槽后，才会继续执行后续的finished信号发送和线程退出逻辑，此时调用wait()可以保证槽函数已经执行完毕。
该方案的缺点是如果槽函数执行时间过长，很容易导致界面无响应，逻辑编写不当还可能触发死锁，仅适合临时调试使用。

方案3：添加状态标记，循环等待槽执行完成 #

可以通过布尔标记位记录槽函数的执行状态，在需要等待的位置循环处理主线程事件、检查状态，直到槽执行完成：

# 主线程初始化时添加状态标记
self.is_table_loaded = False

def load_data_to_table_slot(self, data_pack):
    try:
        df, tabletype, extracount = data_pack
        # 原有数据加载逻辑
        ...
    finally:
        # 无论加载成功失败都标记完成
        self.is_table_loaded = True

# 需要等待加载完成的代码段
self.is_table_loaded = False
self.load_worker.start()
# 循环处理事件直到加载完成
while not self.is_table_loaded:
    QtCore.QCoreApplication.processEvents()
# 此处槽函数已执行完毕，可继续执行后续逻辑

该方案无需修改线程逻辑，但代码冗余度较高，processEvents处理不当可能引发重入问题，优先级低于前两种方案。

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