Pyqt 如何安全立即中止Qthread？

Question

当我的任务正在执行文件操作时，如果使用terminate 中止Qthread线程后，开启新的任务或者重新执行中止的任务后，执行文件的操作会被阻塞，任务无法继续执行，也没有报错（我的项目里没有使用锁，阻塞跟锁没有关系）。怎么安全的立即中止掉Qthread线程？

# 执行操作线程
class WorkerThread(QThread):
    finished = pyqtSignal(object)

    def __init__(self, param=None):
        super().__init__()
        self.param = param

    def run(self):
        # 模拟耗时操作
        try:
            analyse(self.param)
            self.finished.emit()
        except Exception as e:
            traceback.print_exc()


class PythonToJS(QObject):
    def __init__(self, view):
        super().__init__()
        self.th = None

    # 执行
    def run(self, reportId):
        try:
            self.th = WorkerThread(reportId)
            self.th.finished.connect(self.finished)
            self.th.start()
        except Exception as e:
            print('e', e)

    # 终止任务
    @pyqtSlot(str)
    def terminate(self):
        if self.th:
            self.th.terminate()
            self.th.wait()
            self.th = None

Answer 1

AIGC生成：

---

Pyqt 如何安全立即中止Qthread？

terminate 方法可以立即中止 QThread，但是它不会释放线程所占用的资源，包括文件操作的锁定。如果你想要安全地中止 QThread，可以使用 QThread::requestInterruption() 方法。

在你的 QThread 中，使用 QThread::isInterruptionRequested() 方法来检查是否有中止请求，然后根据需要进行相应的处理。

例如：

class MyThread(QThread):
    def run(self):
        while True:
            # 文件操作
            if self.isInterruptionRequested():
                break
        # 中止请求处理
        print("Thread interrupted")

在主线程中，可以使用 QThread::requestInterruption() 方法来请求中止线程：

my_thread = MyThread()
my_thread.start()
# 等待线程执行一段时间
my_thread.requestInterruption()
my_thread.wait()

这样可以安全地中止 QThread，释放资源，并且不会阻塞新的任务或重新执行中止的任务。

---