[已解决]请教pyqt5子线程内使用QTimer循环运行长耗时函数的问题

很cool的阳

去除多余的QEventLoop和QTimer管理：直接使用QThread的run方法循环，并通过条件变量来控制暂停和恢复。
简化信号和槽的使用：直接在QThread中使用pyqtSignal来控制状态，无需额外的emit_函数。
移除不必要的threading.Event：QThread的isRunning方法已经足够用来判断线程是否在运行，结合条件变量（虽然在这个简单示例中未直接使用，但可以通过QMutex和QWaitCondition来实现更复杂的同步）。
以下是优化后的代码：
from PyQt5.QtCore import pyqtSignal, QThread, Qt  
from PyQt5.QtWidgets import QApplication, QWidget  
from PyQt5 import uic  
import sys  
import time  
  
class PrintThread(QThread):  
    pauseSignal = pyqtSignal()  
    resumeSignal = pyqtSignal()  
  
    def __init__(self):  
        super().__init__()  
        self.paused = False  
  
    def run(self):  
        while True:  
            if self.paused:  
                time.sleep(0.1)  # 简单轮询检查暂停状态  
                continue  
              
            print(f"打印: {time.ctime()}")  
            time.sleep(1)  # 模拟查询和打印操作  
  
    def pause(self):  
        self.paused = True  
        self.pauseSignal.emit()  
  
    def resume(self):  
        self.paused = False  
        self.resumeSignal.emit()  
  
class MyWindow(QWidget):  
    def __init__(self):  
        super().__init__()  
        self.init_ui()  
  
        self.p_thread = PrintThread()  
        self.p_thread.start()  
  
    def fun1(self):  
        self.p_thread.pause()  
  
        print(f"发送暂停信号: {time.ctime()}")  
        for i in range(10):  
            time.sleep(1)  
            print(f'主线程正在运行: {i}')  
  
        self.p_thread.resume()  
  
    def init_ui(self):  
        self.ui = uic.loadUi("./测试.ui")  
        self.btn1 = self.ui.pushButton  
        self.btn1.clicked.connect(self.fun1)  
  
if __name__ == "__main__":  
    app = QApplication(sys.argv)  
    w = MyWindow()  
    w.ui.show()  
    app.exec_()

很cool的阳

1. QTimer的线程安全问题
在PyQt中，QTimer对象应当与其关联的QObject（如QWidget）在同一线程中创建和使用。由于信号和槽的连接可能跨越线程边界，导致行为不确定或错误。QTimer应当始终在主线程（GUI线程）中创建和管理，即使它的定时事件需要在其他线程中处理。
解决方案
将QTimer放在主线程中，通过信号和槽将定时事件的处理转移到子线程。
2. QTimer在__init__中创建的问题
在__init__中创建QTimer会使其与创建它的线程（通常是主线程）绑定。应当在子线程的run方法中创建并启动QTimer，但正如之前所述，更好的做法是将QTimer放在主线程中。
3. 控制子线程中QTimer的启停
可以通过信号和槽来控制子线程中的任务执行。在子线程中，您可以使用QEventLoop来等待事件，但请注意，QEventLoop应仅在需要时才在子线程中创建，并且通常只应有一个实例。
修改
class PrintThread(QThread):  
    # 移除QTimer相关的属性和方法  
    # ...  
  
    def run(self):  
        # 创建一个工作队列或事件循环  
        self.worker_loop = True  
  
        while self.worker_loop:  
            # 模拟长时间任务  
            sleep(1)  
            print(f'更新数据,时间{datetime.datetime.now()}')  
  
            # 检查是否需要暂停  
            if self.paused.is_set():  
                # 暂停  
                while self.paused.is_set():  
                    sleep(0.1)  # 简短休眠，避免忙等  
  
    # 暂停和恢复方法  
    def pause(self):  
        self.paused.set()  
  
    def resume(self):  
        self.paused.clear()  
  
# 在主窗口类中  
class Mywindow(QWidget):  
    # ...  
    def fun1(self):  
        self.p_thread.pause()  # 发送暂停信号  
        # ...  
        self.p_thread.resume()  # 发送恢复信号  
  
# 主程序保持不变
4. 替代QTimer的方法
使用QTimer与信号槽系统
使用Python标准库中的threading.Timer，但需注意GUI线程的安全
使用asyncio和QEventLoop的集成
5. 优先处理主线程任务
在场景中，主线程执行的任务应当具有高优先级。使用信号和槽来管理子线程的任务执行是一个很好的方式。

很cool的阳

nsaizl 发表于 2024-8-16 09:31
为了偷懒，目前也是这样写的。在run方法中加个循环。
但是还是想讨论验证一下QTimer在子线程中运行的 ...

QTimer 是 Qt 提供的一个定时器类，它允许你在指定的时间间隔后执行某些操作。QTimer 的设计初衷是为了在 GUI 应用程序中实现时间相关的功能，比如动画、定时更新等，而不会阻塞主线程的用户界面。

在主线程（通常是 GUI 线程）中使用 QTimer 是非常简单和直接的，因为它自动与主线程的事件循环集成。然而，在子线程中使用 QTimer 就比较复杂，因为每个 QObject（包括 QTimer）都有一个与之关联的线程亲和性（thread affinity），这意味着 QObject 必须在它被创建的线程中执行它的事件和信号槽。因此，你不能在一个线程中创建 QTimer 对象，然后期望它在另一个线程中启动和运行。

在子线程中使用 QTimer 的正确方式是确保 QTimer 对象在该子线程中创建，并且该子线程有一个正在运行的事件循环。这通常是通过继承 QThread 类并重写 run() 方法来实现的，然后在 run() 方法内部创建 QTimer 对象，并调用 QThread::exec() 来启动事件循环。例如：

```cpp
class WorkerThread : public QThread
{
    Q_OBJECT
public:
    WorkerThread() {}
    void run() override {
        QTimer timer;
        timer.setInterval(1000);
        connect(&timer, &QTimer::timeout, this, &WorkerThread::onTimeout);
        timer.start();
        exec(); // 启动事件循环
    }

signals:
    void timeout();
};

void WorkerThread::onTimeout() {
    // 处理定时器超时
    qDebug() << "Timeout in thread:" << QThread::currentThreadId();
}
```

`WorkerThread` 继承自 `QThread`，在它的 `run` 方法中创建了 `QTimer` 对象，并启动了事件循环。这样，定时器就可以在子线程中正常工作了。