pyqt6 线程销毁

PyQt6是一个用于Python的Qt应用程序开发库，它提供了丰富的GUI工具和跨平台的支持。在线程销毁方面，特别是在使用QThread子类时，确保线程安全并且资源被适当地释放是非常关键的。

当创建一个自定义QThread子类并启动一个新的线程时，通常会有一个生命周期管理的问题。例如，当主线程（通常是应用窗口）关闭或退出时，你可能希望停止并清理掉所有后台运行的线程。为了做到这一点，你需要关注以下几个点：

1. **信号连接**: 在QThread内部执行的工作常常通过槽函数（slot）接收来自主线程或其他线程的信号。在开始线程前，你需要确保这些信号已经连接到正确的槽，并设置成能被父线程取消或关闭的信号类型，如`QMetaObject::Connection`类型的`Qt::QueuedConnection`。

from PyQt6.QtCore import Qt, QRunnable, QObject, QThreadPool, pyqtSignal

class WorkerSignals(QObject):
    finished = pyqtSignal()
    error = pyqtSignal(tuple)
    progress = pyqtSignal(int)

class Worker(QRunnable):
    def __init__(self, fn, *args, **kwargs):
        super().__init__()
        self.fn = fn
        self.args = args
        self.kwargs = kwargs
        self.signals = WorkerSignals()

    @pyqtSlot()
    def run(self):
        # ... 执行任务 ...

# 在主线程中创建并启动线程
pool = QThreadPool()
worker = Worker(lambda: some_expensive_task())
pool.start(worker)

2. **线程完成标志**: 创建一个标识符（比如bool变量或future对象）来表示线程是否已完成它的任务。这样，在主线程关闭时，你可以检查这个标志并手动结束任务或者关闭线程。

worker.signals.finished.connect(self.worker_done)
...

def worker_done():
    self.worker.stop()  # 假设stop()方法是你的线程终止逻辑
    self.worker.wait()  # 等待线程完全结束

if not app.isRunning():  # 应用即将退出
    worker.signals.finished.disconnect(self.worker_done)  # 防止重复调用
    if not worker.isFinished():
        worker.quit()  # 如果任务未完成，提前结束它

3. **垃圾回收**: 使用`QObject.deleteLater()`而不是直接删除，因为这允许Qt在合适的时机释放资源，包括在QThread销毁时。

pool.waitForDone()  # 等待所有线程完成后
for worker in pool.activethreads():  # 或者使用activeThreads()获取活跃线程列表
    worker.deleteLater()
pool.quit()  # 关闭线程池
app.exit()  # 主线程退出