Pyqt5实现多线程程序

news2024/9/23 11:21:51

主从架构

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. 偏函数 ↩︎

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

2021年9月15日 Go生态洞察:TLS加密套件的自动排序机制

🌷🍁 博主猫头虎(🐅🐾)带您 Go to New World✨🍁 🦄 博客首页——🐅🐾猫头虎的博客🎐 🐳 《面试题大全专栏》 🦕 文章图文…

4年功能测试裸辞找不到工作,一周我就后悔了····

我们可以从以下几个方面来具体分析下,想通了,理解透了,才能更好的利用资源提升自己。 一、我会什么? 先说第一个我会什么?第一反应:我只会功能测试,在之前的4年的中我只做了功能测试。内心存在…

autogen的理解和实践

什么是autogen? AutoGen 是一个框架,支持使用多个代理来开发 LLM 应用程序,这些代理可以相互对话来解决任务。AutoGen 代理是可定制的、可对话的,并且无缝地允许人类参与。他们可以采用法学硕士、人力投入和工具组合的各种模式运作。简单来说…

高级IO select 多路转接实现思路

文章目录 select 函数fd_set 类型timeval 结构体select 函数的基本使用流程文件描述符就绪条件以select函数为中心实现多路转接的思路select 缺陷 select 函数 int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout); selec…

3款厉害的小工具,小黑子都在用!

大家好,我是 Javapub。 程序员与普通人最大的区别是什么,当然是会使用工具。基于一些同学经常问我的问题,接下来给大家分享几款我经常使用的工具,主打一个提升效率。 第一款 Everything 用 windwos 的同学都体会过,…

咨询+低代码,强强联合为制造业客户赋能

内容来自演讲:沈毅 | 遨睿智库 | 董事长 & 王劭禹 | 橙木智能 | 联合创始人 摘要 文章主要讲述了智库董事长沈毅创办广告公司的经历,以及他在管理公司过程中遇到的问题和挑战,最后通过与明道云以及橙木智能联合创始人王邵禹老师的合作&…

STM32/GD32_分散加载

Q:如何将一个变量、某个源文件的函数在编译阶段就存储在用户指定的区域? KEIL环境:.map后缀文件、.sct后缀文件 IAR环境:.map后缀文件、.icf后缀文件 【map文件】 对固件里面的变量、函数、常量等元素的存储空间进行分配的说明…

【计算机毕业设计】springboot+java高校实验室器材耗材料借用管理系统94l73

实验室耗材管理系统在Eclipse/idea环境中,使用Java语言进行编码,使用Mysql创建数据表保存本系统产生的数据。系统可以提供信息显示和相应服务,本系统教师和学生申请使用实验材料,管理员管理实验材料,审核实验材料的申请…

项目设计---MQ

文章目录 一. 项目描述二. 核心技术三. 需求分析概要设计四. 详细设计4.1 服务器模块4.1.1 内存管理4.1.2 硬盘管理4.1.2.1 数据库管理4.1.2.2 文件管理 4.1.3 消息转发 4.2 客户端模块4.2.1 连接管理4.2.2 信道管理 4.3 公共模块4.3.1 通信协议4.3.2 序列化/反序列化 一. 项目…

Linux 如何在文件中查找指定内容,grep的用法

Linux 如何在文件中查找指定内容 1、 如我们 查找 log_file_catalina.out 文件中,包含 ‘总数:900’ 的字符内容 2、 在日志中查看 83910_law_21CFBC7EB25B1FF60255FE7F4BE1BCCF1CE726F6_0.bdyhf 的相关内容 grep 83910_law_21CFBC7EB25B1FF60255FE7…

Redis String类型

String 类型是 Redis 最基本的数据类型,String 类型在 Redis 内部使用动态长度数组实现,Redis 在存储数据时会根据数据的大小动态地调整数组的长度。Redis 中字符串类型的值最大可以达到 512 MB。 关于字符串需要特别注意∶ 首先,Redis 中所…

[vue3] 使用 vite 创建vue3项目的详细流程

一、vite介绍 Vite(法语意为 “快速的”,发音 /vit/,发音同 “veet”) 是一种新型前端构建工具,能够显著提升前端开发体验(热更新、打包构建速度更快)。 二、使用vite构建项目 【学习指南】学习新技能最…

IDE1007:当前上下文中不存在名称“xxx“

这种在Halcon中直接导出的代码不能直接放程序中,应该在控件中比如一个按钮中,就不会出错了。

MacOS + Android Studio 通过 USB 数据线真机调试

环境:Apple M1 MacOS Sonoma 14.1.1 软件:Android Studio Giraffe | 2022.3.1 Patch 3 设备:小米10 Android 13 一、创建测试项目 安卓 HelloWorld 项目: 安卓 HelloWorld 项目 二、数据线连接手机 1. 手机开启开发者模式 参考&#xff1…

ruoyi+Hadoop+hbase实现大数据存储查询

前言 有个现实的需求,数据量可能在100亿条左右。现有的数据库是SQL Server,随着采集的数据不断的填充,查询的效率越来越慢(现有的SQL Server查询已经需要数十秒钟的时间),看看有没有优化的方案。 考虑过S…

解决webpack打包生成gz格式css/js文件没法在nginx使用的问题--全网唯一正确

本文绝对是全网解决这个问题唯一正确的文章,没有之一! 很多人都说开启nginx gzip压缩,这些人完全是胡说八道!你们到底懂不懂叫gzip压缩啊?! 不信你就试试,如果css/js只有gz文件,ng…

国外客户跟我要佣金,该给不该给?

“Jack,这次你要是不帮我,我就死定了!” 收到美国公司采购Antony的信息时,我有些哭笑不得,因为在我电脑屏幕上除了他的信息外,还有来自他公司监察部门的邮件: “jack先生,我们调查…

Java+SSM springboot+MySQL家政服务预约网站设计en24b

随着社区居民对生活品质的追求以及社会老龄化的加剧,社区居民对家政服务的需求越来越多,家政服务业逐渐成为政府推动、扶持和建设的重点行业。家政服务信息化有助于提高社区家政服务的工作效率和质量。 本次开发的家政服务网站是一个面向社区的家政服务网…

osgSim扩展库

1.osgSim扩展库 osgSim是0SG的一个工具箱(NodeKit),提供了仿真系统中以及染OpenFlight 数据库所需的特殊渲染功能,如地形高程图、光点节点和 DOF 变换节点等。 下面对一些可能会用到的类进行简单介绍。 1.1 DOFTransform类 osgSim::DOFTransform类是对 …

冒泡排序算法是对已知的数列进行从小到大的递增排序。

题目描述冒泡排序算法是对已知的数列进行从小到大的递增排序每个实例输出两行,第一行输出第1轮结果, 第二行输出最终结果 它的排序方法如下: 1.对数列从头开始扫描,比较两个相邻的元素,如果前者大于后者,则交换两者位置 2.重复步骤1,直到没有…