Pyqt5实现多线程程序

主从架构

Pyqt常常使用**主从架构(Master-Workers 架构)**来避免界面卡死的情况。

Master-Workers 架构就像它的名字,一个master统领着几个workers一起干活。其中某个worker倒下了不会导致整体任务失败。matser不用干活,因此可以专心指挥workers。

在qt5中,master代表主线程,主要维持主界面的运行。当触发某项耗时耗力的任务时,主线程将这项任务分配给其他线程(workers)来做。其他线程出现了灾难性的错误,不会影响到主线程,因此程序不会完全崩溃。且主线程不承担耗时耗力的任务,因此避免了复杂运算时主界面卡顿的问题。

进程和线程详见1

pyqt5多线程的架构一般由三个模块实现:

  • Gui.py:只存放GUI界面,一般是Qt Designer生成的代码,无需做任何修改
  • Thread.py:从线程,主要的逻辑代码都放在这里。接收主线程的指令,并向主线程返回信号。
  • Main.py:主线程,负责运行GUI界面,向从线程发送指令并接收从线程返回的信号。

GUI模块

Qt Designer保存的文件为Gui.ui的格式,使用下面命令转为Gui.py

pyuic5 Gui.ui -o Gui.py

转换后的代码结构如下,我们不需要对这个代码做任何修改。

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

# Form implementation generated from reading ui file 'mainwindow.ui'
#
# Created by: PyQt5 UI code generator 5.5.1
#
# WARNING! All changes made in this file will be lost!

from PyQt5 import QtCore, QtGui, QtWidgets

class Ui_MainWindow(object): # 注意这个类名,后面在Main.py中找到它
    def setupUi(self, MainWindow):
        MainWindow.setObjectName("MainWindow")
        # ------- 省略很多行... ------- #
        self.retranslateUi(MainWindow)
        QtCore.QMetaObject.connectSlotsByName(MainWindow)
    
    def retranslateUi(self, MainWindow):
        _translate = QtCore.QCoreApplication.translate
        MainWindow.setWindowTitle(_translate("MainWindow", "标题"))
        # ------- 省略很多行... ------- #

不同线程间的信号与槽

在讨论主线程和从线程之前,首先要明确线程间传递信号的方法2

信号与槽机制示意图

主 -> 从

主线程到从线程的信号就是最基本信号与槽的机制,使用槽函数来与从线程通信。一般是Wight被clicked,然后触发槽函数。传递的路径为:1.触发信号事件 -> 2.信号clicked -> 3.槽函数接收信号并运行。使用以下语句绑定槽函数:

from Thread import New_thread # 从线程的引用

class MainWindow(QMainWindow, Ui_MainWindow):

    def __init__(self, parent=None) -> None:
        super(MainWindow,self).__init__(parent)
        self.setupUi(self)
        
        # ----------------------------------------- #
        # ↓↓↓↓↓↓↓ 不用管上面的代码,主要看下面 ↓↓↓↓↓↓↓ #
        # ----------------------------------------- #
        
        self.thread = None # 先预定义一个从线程的实例属性,这里无需将从线程实例化
        # self.btn为Ui_MainWindow中定义的按钮,这里将按钮点击的信号与槽函数self.func连接起来
        self.btn.clicked.connect(self.func) 

    def func(self):
        self.thread = New_thread() # 在槽函数中实例化从线程,然后就可以操作从线程了
        self.thread.start()
        pass

有时我们需要向槽函数传递参数,一般使用偏函数或lambda,偏函数可参见3

from functools import partial # 偏函数的引用
from Thread import New_thread # 从线程的引用

class MainWindow(QMainWindow, Ui_MainWindow):

    def __init__(self, parent=None) -> None:
        super(MainWindow,self).__init__(parent)
        self.setupUi(self)
        
        # ----------------------------------------- #
        # ↓↓↓↓↓↓↓ 不用管上面的代码,主要看下面 ↓↓↓↓↓↓↓ #
        # ----------------------------------------- #
        
        self.thread = None # 先预定义一个从线程的实例属性,这里无需将从线程实例化
        # 第一种方法:这个槽函数被写成了偏函数的形式 partial(self.func, param1, param2)
	    self.btn1.clicked.connect(partial(self.func, param1=1, param2=2)) 
        # 第二种方法:这个槽函数被写成了lambda的形式 lambda:self.func(param1=1, param2=2)
        self.btn2.clicked.connect(lambda:self.func(param1=1, param2=2))
        
    # 这个槽函数监听了两个信号哦
    def func(self, param1, param2):
         # 在槽函数中实例化从线程,然后就可以操作从线程了
        self.thread = New_thread(param1, param2) # 从线程实例化也可以放在__init__里面,但我喜欢放在这。
        self.thread.start()
        pass

从 -> 主

从线程向主线程传递信号一般使用自定义信号,触发后,从线程的自定义信号传递给主线程连接的槽函数。触发的路径为1.从线程触发信号emit -> 2.声明信号pyqtSignal -> 3.传递给主线程连接的槽函数。使用下面代码建立自定义信号。

先在Thread.py中定义信号:

# Thread.py
from PyQt5.QtCore import QThread, pyqtSignal

class New_Thread(QThread):
    # 声明定义信号,注意它必须是类属性。
    mySignal = pyqtSignal(int,str) # 后面的参数是信号的数据类型
    
    def __init__(self) -> None:
        super(New_Thread, self).__init__(parent)
        pass 
    
    def run(self):
        pass
    
    # ------------------------------------------ #
    # ↓↓↓↓↓↓↓ 上面的两个函数不用理会,看下面 ↓↓↓↓↓↓↓ #
    # ------------------------------------------ #
    
    # 下面是从线程的逻辑代码
    def func(self):
        # ------- 省略很多逻辑代码... ------- #
        # 向主线程发送信号
        self.mySignal.emit(1,"Hello, Pyqt5")

在主线程Main.py中监听信号并连接到槽:

# Main.py
from Thread import New_thread # 从线程的引用

class MainWindow(QMainWindow, Ui_MainWindow):

    def __init__(self, parent=None) -> None:
        super(MainWindow,self).__init__(parent)
        self.setupUi(self)
        
        # ----------------------------------------- #
        # ↓↓↓↓↓↓↓ 不用管上面的代码,主要看下面 ↓↓↓↓↓↓↓ #
        # ----------------------------------------- #
        
    def func1(self):
        self.thread = New_thread() # 从线程实例化(也可以放在__init__里面)
        self.thread.start()
        # 监听从线程发出的信号,并连接到槽函数func2
        # 记得吗?mySignal发出了两个数据,一个是int类型,一个str类型
        self.thread.mySignal.connect(self.func2) 
    
    # 槽函数接收了从线程的信号
    def func2(self, param1:int, param2:str):
        pass

主线程Main模块

主线程的作用是维护UI界面运行,下面给出Main模块的一般架构

import sys # 显示ui界面必要的引用
from PyQt5.QtWidgets import QMainWindow, QApplication # 显示ui界面必要的引用
from GUI import * # 引用Qt Designer生成的GUI模块
from Thread import New_thread # 从线程的引用

# 第一个父类是PyQt5.QtWidgets.QMainWindow(取决于你在Qt Designer选择的窗口类型)
# 第二个父类是GUI.Ui_MainWindow
class MainWindow(QMainWindow, Ui_MainWindow): 

    def __init__(self, parent=None) -> None:
        super(MainWindow,self).__init__(parent)
        self.setupUi(self) # 初始化UI界面
        self.thread = None # 先预定义一个从线程的实例属性,这里无需将从线程实例化
        self.btn1.clicked.connect(self.func1) # 绑定控件的槽函数,以启动从线程
        self.thread.finished.connect(self.func3) # 监听线程是否完成任务,以结束从线程
        # 省略一万行绑定槽函数的代码...
        
    # 定义槽函数,这里可以放入从线程。
    def func1(self):
        self.thread = New_Thread() # 实例化一个从函数
        self.thread.start()
        self.thread.mySignal.connect(self.func2) # 监听从线程的信号,并绑定槽函数
    
    # 定义响应从线程信号的槽函数
    def func2(self,param:int):
        pass
    
    # 定义结束从线程的槽函数
    def func3(self):
        self.thread.stop()
    
    # 省略一万个槽函数...

if __name__ == '__main__':
    # 任何一个qt应用都必须有且仅有一个QApplication对象
    # sys.argv是一组命令行参数的列表。
    # 这行代码就是实例化一个QApplication
    app = QApplication(sys.argv) 
    
    # 主线程实例化
    main_window = MainWindow()
    
    # 显示窗口
    main_window.show()
    
    # sys.exit()是Python退出进程的函数
    # QApplication.exec_()的功能是“qt程序进入主循环,直到exit()被调用”
    # 没有exec_()的话,程序不会进入主循环,会闪退。没有sys.exit()的话,程序退出后进程不会结束。
    sys.exit(app.exec_())

从线程Thread模块

from PyQt5.QtCore import QThread, pyqtSignal
from functools import partial

class New_Thread(QThread):
    # 声明定义信号,注意它必须是类属性。
    mySignal = pyqtSignal(int,str) # 后面的参数是信号的数据类型
    finishedSignal = pyqtSignal() # 线程完成的信号
    
    def __init__(self) -> None:
        super(New_Thread, self).__init__(parent)
    
    # run()是父类的方法,这里要重写run方法
    # 将逻辑代码放在run里面,当主线程调用thead.start()时会自动运行run函数。
    def run(self):
        # 省略一万行代码
        self.finishedSignal.emit()
    
    # 停止线程
    def stop(self):
        self.isRunning = False # isRunning是父类的属性,可以停止线程。

  1. 进程和线程 ↩︎

  2. 信号与槽函数 ↩︎

  3. 偏函数 ↩︎

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/180650.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

UltraCompare 23 for Mac文件对比工具

UltraCompare是一款功能强大的文件比较和合并工具, 以下是它的特色介绍: 多种文件格式支持:UltraCompare支持比较和合并多种文件格式,包括文本文件、二进制文件、office文档、PDF文件等。 文件差异高亮显示:UltraComp…

动态规划求二维网格中从左上角到右下角的最短路径( 每次只能向下、向右、向右下走 ) java 实现

dp[i][j] 表示在以点(0,0)作为左上角,点(i,i) 作为右下角的二维网格中 左上角到右下角的最短路径, 动态转移方程为:dp[i][j] min{ dp[i][j-1],dp[i-1][j],dp[i-1][j-1] }.distance weight[i][j] ImageUtils.java: import java.a…

凸问题与非凸问题

凸函数:曲线上任意两点连线上的点对应的函数值不大于该两点对应的函数值得连线上的值,例如yx^2; 非凸函数:曲线上任意两点连线上的点对应的函数值既有大于该两点对应的函数值得连线上的值的部分也有小于的部分,例如&am…

filebeat配置解析【待续】

目录 filebeat概览filebeat是如何工作的工作原理采集日志注册表发送日志 容器日志采集的三种方式方式一:Filebeat 与 应用运行在同一容器(不推荐)方式二:Filebeat 与 应用运行不在同一容器方式三:通过 Kubernetes File…

springboot使用redis缓存乱码(key或者 value 乱码)一招解决

如果查看redis中的值是这样 创建一个配置类就可以解决 package com.deka.config;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; i…

最新EasyRecovery14中文版安装下载步骤

EasyRecovery是一款功能强大的数据恢复软件,可以一直免费使用下去,可以将受损的文件恢复过来,也可以检索数据格式化或损坏卷,还可以初始化磁盘。它拥有强大的数据恢复能力和快速地查找恢复机制,非常的简洁实用。拥有4大…

2023年亚太数学建模C题数据分享+详细思路

在报名截止的前一天,我尝试进行了报名。到那时,已有11,000个队伍注册参赛。在我的了解中,在数模比赛中除了国赛美赛外,几乎没有其他竞赛的参赛队伍数量能与此相媲美。即便不考虑赛题的难度和认可度,亚太地区的这场竞赛…

Java中的字符串String

目录 一、常用方法 1、字符串构造 2、String对象的比较 (1)、equals方法 (2)、compareTo方法 (3)、compareToIgnoreCase方法(忽略大小写进行比较) 3、字符串查找 4、转化 &…

盘点一下:为了考上本科,你需要放弃什么?

专转本除了胜利后喜悦,更多的则是过程的艰辛,为了专转本成功,我们放弃了自己的娱乐时间、放弃了自己的兴趣爱好。 专转本考试相当于人生第二次“高考”,在学历门槛的今天,越来越多的人都在通过各类途径提转个人学历。…

基准电压源的工作原理和作用是什么(高精度电压源)

基准电压源是一种能够提供固定、稳定的直流电压输出的电源设备。它广泛应用于精密仪器、测试设备、通信设备等领域,是实现精确电压测量和校准的重要工具。本文将为您介绍基准电压源的工作原理和作用。 一、基准电压源的工作原理 基准电压源采用了高精度的电路设计和…

【数据结构】深入浅出理解链表中二级指针的应用

🦄个人主页:修修修也 🎏所属专栏:数据结构 ⚙️操作环境:Visual Studio 2022 (注:为方便演示本篇使用的x86系统,因此指针的大小为4个字节) 目录 📌形参的改变不影响实参! 1.调用函数更改整型时传值调用与传址调用的区别 🎏传值…

【23真题】最后一套两电一邮,纸老虎偏多!

今天分享的是23年西安电子科技大学811的信号与系统试题及解析。更新完这套,两电一邮的全部23真题已更新完毕! 本套试卷难度分析:22年西电811考研真题,我发布过,若有需要戳这里自取!这里统计了811的上岸平均…

Linux本地MinIO存储服务远程调用上传文件

🔥博客主页: 小羊失眠啦. 🎥系列专栏:《C语言》 《数据结构》 《Linux》《Cpolar》 ❤️感谢大家点赞👍收藏⭐评论✍️ 文章目录 前言1. 创建Buckets和Access Keys2. Linux 安装Cpolar3. 创建连接MinIO服务公网地址4. …

数据结构算法-贪心算法

引言 贪心:人只要有 “需求“ ,都会有有点“贪“, 这种“贪“是一种选择,或者“”取舍“ RTS(即时战略)游戏: 帝国时代里 首先确保拥有足够的人口 足够的粮食,足够的战略资源 足够的…

【linux】服务器CPU占用50%,top/htop/ps却看不到异常进程?使用unhide可以查看!

问题描述 htop发现前32个核全被占满了,但是却找不到对应进程号 查杀 安装unhide查看隐藏进程 apt-get install unhideunhide使用 unhide proc果然发现了隐藏进程 杀死隐藏进程 kill -9 [pid]这么多pid号,我这边杀了其中一个,发现CPU…

Docker 安装 Apache

目录 拉取官方 Apache 镜像 查看本地镜像 列出正在运行的容器 运行 Apache 容器 创建一个 HTML 文件:index.html 访问 Apache 拉取官方 Apache 镜像 查找 Docker Hub 上的 httpd 镜像。 可以通过 Tags 查看其他版本的 httpd,默认是最新版本 httpd…

vue2.0+elementui集成file-loader之后图标失效问题

背景 跑vue2elementUI项目时,由于前端这边需要在本地存放xlsx模板文件,供用户下载模板文件,所以需要在webpack构建的时候增加file-loader进行解析xlsx文件打包。 vue版本2.x element-ui 版本 2.13.x 注意 npm i -D file-loader版本号给vue项…

史诗级云故障敲响警钟,应用保障不能没有“连续键”!

近日,知名云服务商出现一次史诗级的云故障:全球所有区域/所有服务同时异常,故障持续长达3小时之多,云上众多应用受到极大影响。 如今,在一个充满不确定性和复杂性的数字化时代,哪怕是顶级云服务商亦不能避…

3.7寸墨水屏蓝牙卡证

超薄机身,厚度不足一厘米,轻松佩戴无负重感。 无需基站,服务器,手机APP直接更新~ 独创快速扫描技术,智能感应标签 超长待机,超低功耗,Type C接口充电,一次充电可续航一年&#xf…

docker安装以及idea访问docker

其他目录: docker 安装环境(有空更新) url “” docker 打包java包,并运行(有空更新) url “” docker 打包vue (有空更新) url “” docker 多服务 (有空更新&#xff…