[ PyQt入门教程 ] PyQt5中多线程模块QThread使用方法

摘要:
本文主要介绍了如何使用多线程模块QThread来解决PyQt接口程序执行耗时的操作且接口输出无法实时显示时无响应的问题。接下来,我们将模拟上述问题,并描述如何使用多线程QThread模块来解决这些问题。要解决这个问题,请考虑使用多线程模块QThread。多线程模块QThreadQThread的基本原理是Qt线程类的核心底层类。由于PyQt的跨平台特性,QThread通过隐藏所有平台相关代码使用的QThreads来启动线程。您可以创建QThread的子类,然后覆盖其他QThread。run()函数。

本文主要讲解使用多线程模块QThread解决PyQt界面程序唉执行耗时操作时,程序卡顿出现的无响应以及界面输出无法实时显示的问题。用户使用工具过程中出现这些问题时会误以为程序出错,从而把程序关闭。这样,导致工具的用户使用体验不好。下面我们通过模拟上述出现的问题并讲述使用多线程QThread模块解决此类问题的方法。

PyQt程序卡顿和无法实时显示问题现象

使用PyQt实现在文本框中每秒打印1个数字。程序代码如下(QThread_Example_UI.py和QThread_Example_UI.ui见附录):

#-*- coding: utf-8 -*-

importsys
importtime
from PyQt5.QtCore importQThread, pyqtSignal
from PyQt5.QtWidgets importQApplication, QMainWindow
from QThread_Example_UI importUi_Form

classMyMainForm(QMainWindow, Ui_Form):
    def __init__(self, parent=None):
        super(MyMainForm, self).__init__(parent)
        self.setupUi(self)
        self.runButton.clicked.connect(self.display)

    defdisplay(self):
        for i in range(20):
            time.sleep(1)
            self.listWidget.addItem(str(i))

if __name__ == "__main__":
    app =QApplication(sys.argv)
    myWin =MyMainForm()
    myWin.show()
    sys.exit(app.exec_())

程序运行过程结果如下(点击Run按钮后界面出现未响应字样同时程序也没有出现每隔1秒打印1个数字,实际结果是循环结束后20个数字一同展示):

[ PyQt入门教程 ] PyQt5中多线程模块QThread使用方法第1张[ PyQt入门教程 ] PyQt5中多线程模块QThread使用方法第2张

问题分析

上述实现的GUI程序都是单线程运行,对于需要执行一个特别耗时的操作时就会出现该问题现象。要解决这种问题可以考虑使用多线程模块QThread。

多线程模块QThread基本原理

QThread是Qt的线程类中最核心的底层类。由于PyQt的的跨平台特性,QThread要隐藏所有与平台相关的代码要使用的QThread开始一个线程,可以创建它的一个子类,然后覆盖其它QThread.run()函数。

classThread(QThread):
    def __init__(self):
        super(Thread,self).__init__()
    defrun(self):
        #

接下来创建一个新的线程

thread =Thread()
thread.start()

可以看出,PyQt的线程使用非常简单,建立一个自定义的类(如Thread),自我继承自QThread ,并实现其run()方法即可。在使用线程时可以直接得到Thread实例,调用其start()函数即可启动线程,线程启动之后,会自动调用其实现的run()的函数,该方法就是线程的执行函数 。

业务的线程任务就写在run()函数中,当run()退出之后线程就基本结束了,QThread有started和finished信号,可以为这两个信号指定槽函数,在线程启动和结束之时执行一段代码进行资源的初始化和释放操作,更灵活的使用方法是,在自定义的QThread实例中自定义信号,并将信号连接到指定的槽函数,当满足一定的业务条件时发射此信号。

QThread类中的常用方法

start():启动线程

wait():阻止线程,直到满足如下条件之一

(1)与此QThread对象关联的线程已完成执行(即从run返回时),如果线程完成执行,此函数返回True,如果线程尚未启动,也返回True

(2)等待时间的单位是毫秒,如果时间是ULONG_MAX(默认值·),则等待,永远不会超时(线程必须从run返回),如果等待超时,此函数将会返回False

sleep():强制当前线程睡眠多少秒

QThread类中的常用信号

started:在开始执行run函数之前,从相关线程发射此信号

finished:当程序完成业务逻辑时,从相关线程发射此信号

使用QThread重新实现程序解决问题

先继承QThread类创建多线程,使用主线程更新界面,使用子线程实时处理数据(重写run()函数,将耗时的操作放入run()函数中),最后将结果显示到界面上。代码如下:

#-*- coding: utf-8 -*-

importsys
importtime
from PyQt5.QtCore importQThread, pyqtSignal
from PyQt5.QtWidgets importQApplication, QMainWindow
from QThread_Example_UI importUi_Form

classMyMainForm(QMainWindow, Ui_Form):
    def __init__(self, parent=None):
        super(MyMainForm, self).__init__(parent)
        self.setupUi(self)
        #实例化线程对象
        self.work =WorkThread()
        self.runButton.clicked.connect(self.execute)

    defexecute(self):
        #启动线程
self.work.start()
        #线程自定义信号连接的槽函数
self.work.trigger.connect(self.display)

    defdisplay(self,str):
        #由于自定义信号时自动传递一个字符串参数,所以在这个槽函数中要接受一个参数
self.listWidget.addItem(str)

classWorkThread(QThread):
    #自定义信号对象。参数str就代表这个信号可以传一个字符串
    trigger =pyqtSignal(str)

    def __int__(self):
        #初始化函数
        super(WorkThread, self).__init__()

    defrun(self):
        #重写线程执行的run函数
        #触发自定义信号
        for i in range(20):
            time.sleep(1)
            #通过自定义信号把待显示的字符串传递给槽函数
self.trigger.emit(str(i))

if __name__ == "__main__":
    app =QApplication(sys.argv)
    myWin =MyMainForm()
    myWin.show()
    sys.exit(app.exec_())

程序运行结果如下(实现了每隔1秒打印1个数字):

[ PyQt入门教程 ] PyQt5中多线程模块QThread使用方法第3张

小结

如果你实现的工具需要执行特别耗时的操作,可以参考使用本文多线程QThread处理方法实现。当然,工具实际实现过程中的场景会比这复杂。比如,你的输出并不是有固定时间间隔输出的文本框,可以尝试使用多次self.trigger.emit(str)方法进行操作。

附录

1、使用pyuic5转换界面.ui程序后的QThread_Example_UI.py代码如下:

#-*- coding: utf-8 -*-

from PyQt5 importQtCore, QtGui, QtWidgets

classUi_Form(object):
    defsetupUi(self, Form):
        Form.setObjectName("Form")
        Form.resize(498, 331)
        self.runButton =QtWidgets.QPushButton(Form)
        self.runButton.setGeometry(QtCore.QRect(190, 30, 75, 23))
        self.runButton.setObjectName("runButton")
        self.listWidget =QtWidgets.QListWidget(Form)
        self.listWidget.setGeometry(QtCore.QRect(30, 70, 431, 192))
        self.listWidget.setObjectName("listWidget")

        self.retranslateUi(Form)
        QtCore.QMetaObject.connectSlotsByName(Form)

    defretranslateUi(self, Form):
        _translate =QtCore.QCoreApplication.translate
        Form.setWindowTitle(_translate("Form", "Qthread Example"))
        self.runButton.setText(_translate("Form", "Run"))

2、Qtdesigner设计的界面源程序代码QThread_Example_UI.ui如下:

<?xml version="1.0" encoding="UTF-8"?>
<ui version="4.0">
 <class>Form</class>
 <widget class="QWidget" name="Form">
  <property name="geometry">
   <rect>
    <x>0</x>
    <y>0</y>
    <width>498</width>
    <height>331</height>
   </rect>
  </property>
  <property name="windowTitle">
   <string>Qthread Example</string>
  </property>
  <widget class="QPushButton" name="runButton">
   <property name="geometry">
    <rect>
     <x>190</x>
     <y>30</y>
     <width>75</width>
     <height>23</height>
    </rect>
   </property>
   <property name="text">
    <string>Run</string>
   </property>
  </widget>
  <widget class="QListWidget" name="listWidget">
   <property name="geometry">
    <rect>
     <x>30</x>
     <y>70</y>
     <width>431</width>
     <height>192</height>
    </rect>
   </property>
  </widget>
 </widget>
 <resources/>
 <connections/>
</ui>

免责声明:文章转载自《[ PyQt入门教程 ] PyQt5中多线程模块QThread使用方法》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇android基本架构ssh分发秘钥时出现错误“Permission denied (publickey,gssapi-keyex,gssapi-with-mic)”下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

阿里巴巴开源性能监控神器Arthas初体验

如果问性能测试中最难的是哪部分,相信很多人会说“性能调优”。确实是这样,性能调优是一个非常复杂、技术含量很高的工作。涉及到的知识面很广。以我多年从业经验来看,在企业里,大多数的性能调优都是由开发架构师来完成,涉及到数据库的,可能需要DBA的介入。 而性能测试工程师在实际工作中,主要的职责是发现问题和定位问题,确定性能问题出现在哪部分,需要定位到具体函数、...

从点击Button到弹出一个MessageBox, 背后发生了什么

思考一个最简单的程序行为:我们的Dialog上有一个Button, 当用户用鼠标点击这个Button时, 我们弹出一个MessageBox。 这个看似简单的行为, 谁能说清楚它是如何运行起来的,背后究竟发生了什么?  下面是我个人尝试的解答: (1)我们的鼠标点击事件到达设备的驱动程序, 驱动程序把消息放入系统硬件输入队列SHIQ(system ha...

C# 线程手册 第二章 .NET 中的线程 终止/等待线程

Abort()方法可以用来终止当前线程。不论何种情况下你想终止线程,比如线程执行了太长时间或者用户取消了之前的决定,Abort()方法都很重要。在一个花费很长时间的搜索进程中你可能想使用这个方法。一个搜索引擎可能在继续运行但是用户已经看到了他们想要的结果,所以用户会终止搜索引擎所运行的线程。当在一个线程外调用Abort()方法时,会引发一个ThreadAb...

FastMM5来了!

FastMM是Embarcadero Delphi的内存管理器的替代品,可在多线程和CPU内核之间很好地扩展,不易出现内存碎片,并且无需使用外部.DLL文件即可支持内存共享。版本5是完全重写了FastMM,从头开始设计,目的是同时保持其优势并解决4.992版的bug。这一版本极大的改进对跨多CPU内核的多线程扩展,而不会出现内存使用中断的情况。对于任意数量...

ExtJS入门教程02,form也可以很优雅

在上一篇《Extjs window 入门》中,我们已经看到了如何将一个form组件放到window中,今天我们来看看form的一些优雅的工作方式。 使用fieldDefaults,优雅的设置字段默认值 form中的子项,通常都是field控件,而这些field控件通常都会使用一些相同的配置,例如labelWidth、labelAlign等,如果在每一个f...

Go语言的调度模型(GPM)

GPM模型 定义于src/runtime/runtime2.go G: Gourtines(携带任务), 每个Goroutine对应一个G结构体,G保存Goroutine的运行堆栈,即并发任务状态。G并非执行体,每个G需要绑定到P才能被调度执行。 P: Processors(分配任务), 对G来说,P相当于CPU核,G只有绑定到P(在P的local ru...