[已解决]pyqt5 多线程问题求助

rsj0315

两个py文件
一个ui的ui_Widget.py

1. # -*- coding: utf-8 -*-
   
2. 
   
3. # Form implementation generated from reading ui file 'Widget.ui'
   
4. #
   
5. # Created by: PyQt5 UI code generator 5.15.1
   
6. #
   
7. # WARNING: Any manual changes made to this file will be lost when pyuic5 is
   
8. # run again.  Do not edit this file unless you know what you are doing.
   
9. 
   
10. 
    
11. from PyQt5 import QtCore, QtGui, QtWidgets
    
12. 
    
13. 
    
14. class Ui_Widget(object):
    
15.     def setupUi(self, Widget):
    
16.         Widget.setObjectName("Widget")
    
17.         Widget.resize(710, 593)
    
18.         sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Fixed)
    
19.         sizePolicy.setHorizontalStretch(0)
    
20.         sizePolicy.setVerticalStretch(0)
    
21.         sizePolicy.setHeightForWidth(Widget.sizePolicy().hasHeightForWidth())
    
22.         Widget.setSizePolicy(sizePolicy)
    
23.         font = QtGui.QFont()
    
24.         font.setPointSize(16)
    
25.         Widget.setFont(font)
    
26.         self._2 = QtWidgets.QVBoxLayout(Widget)
    
27.         self._2.setContentsMargins(5, 5, 5, 5)
    
28.         self._2.setSpacing(6)
    
29.         self._2.setObjectName("_2")
    
30.         self.label = QtWidgets.QLabel(Widget)
    
31.         self.label.setEnabled(True)
    
32.         self.label.setText("")
    
33.         self.label.setPixmap(QtGui.QPixmap("22.jpg"))
    
34.         self.label.setObjectName("label")
    
35.         self._2.addWidget(self.label)
    
36.         self.groupBox_2 = QtWidgets.QGroupBox(Widget)
    
37.         self.groupBox_2.setObjectName("groupBox_2")
    
38.         self.verticalLayout = QtWidgets.QVBoxLayout(self.groupBox_2)
    
39.         self.verticalLayout.setContentsMargins(9, 9, 9, 9)
    
40.         self.verticalLayout.setSpacing(6)
    
41.         self.verticalLayout.setObjectName("verticalLayout")
    
42.         self.lineEdit = QtWidgets.QLineEdit(self.groupBox_2)
    
43.         self.lineEdit.setClearButtonEnabled(True)
    
44.         self.lineEdit.setObjectName("lineEdit")
    
45.         self.verticalLayout.addWidget(self.lineEdit)
    
46.         self._2.addWidget(self.groupBox_2)
    
47.         self.horizontalLayout = QtWidgets.QHBoxLayout()
    
48.         self.horizontalLayout.setSpacing(4)
    
49.         self.horizontalLayout.setObjectName("horizontalLayout")
    
50.         self.groupBox = QtWidgets.QGroupBox(Widget)
    
51.         self.groupBox.setObjectName("groupBox")
    
52.         self.gridLayout = QtWidgets.QGridLayout(self.groupBox)
    
53.         self.gridLayout.setContentsMargins(11, 11, 11, 11)
    
54.         self.gridLayout.setSpacing(6)
    
55.         self.gridLayout.setObjectName("gridLayout")
    
56.         self.comboBox = QtWidgets.QComboBox(self.groupBox)
    
57.         self.comboBox.setEditable(False)
    
58.         self.comboBox.setObjectName("comboBox")
    
59.         self.gridLayout.addWidget(self.comboBox, 1, 0, 1, 3)
    
60.         self.btnIniItems = QtWidgets.QPushButton(self.groupBox)
    
61.         self.btnIniItems.setObjectName("btnIniItems")
    
62.         self.gridLayout.addWidget(self.btnIniItems, 0, 0, 1, 1)
    
63.         self.btnClearItems = QtWidgets.QPushButton(self.groupBox)
    
64.         self.btnClearItems.setObjectName("btnClearItems")
    
65.         self.gridLayout.addWidget(self.btnClearItems, 0, 1, 1, 1)
    
66.         self.btnOkItems = QtWidgets.QPushButton(self.groupBox)
    
67.         self.btnOkItems.setStyleSheet("background-color: rgb(255, 0, 0);\n"
    
68. "font: 16pt "MS Shell Dlg 2";")
    
69.         self.btnOkItems.setObjectName("btnOkItems")
    
70.         self.gridLayout.addWidget(self.btnOkItems, 0, 2, 1, 1)
    
71.         self.horizontalLayout.addWidget(self.groupBox)
    
72.         self._2.addLayout(self.horizontalLayout)
    
73.         self.plainTextEdit = QtWidgets.QPlainTextEdit(Widget)
    
74.         self.plainTextEdit.setObjectName("plainTextEdit")
    
75.         self._2.addWidget(self.plainTextEdit)
    
76. 
    
77.         self.retranslateUi(Widget)
    
78.         self.comboBox.setCurrentIndex(-1)
    
79.         QtCore.QMetaObject.connectSlotsByName(Widget)
    
80. 
    
81.     def retranslateUi(self, Widget):
    
82.         _translate = QtCore.QCoreApplication.translate
    
83.         Widget.setWindowTitle(_translate("Widget", "Demo3_6 ComboBox"))
    
84.         self.groupBox_2.setTitle(_translate("Widget", "选择的工序如下"))
    
85.         self.groupBox.setTitle(_translate("Widget", "选择导出数据的工序"))
    
86.         self.btnIniItems.setText(_translate("Widget", "初始化列表"))
    
87.         self.btnClearItems.setText(_translate("Widget", "清除列表"))
    
88.         self.btnOkItems.setText(_translate("Widget", "确定"))
    

复制代码

第二个py，文件myWidget.py

1. import sys
   
2. from PyQt5.QtWidgets import  QApplication, QWidget
   
3. from PyQt5.QtCore import  pyqtSlot
   
4. from ui_Widget import Ui_Widget #ui界面
   
5. import itp_drawing as drawing #函数1
   
6. import itp_bunching as bunching #函数2
   
7. import itp_conductor as conductor #函数3
   
8. import itp_extruder as extruder #函数4
   
9. import itp_rubber as rubber #函数5
   
10. import itp_ccv as ccv #函数6
    
11. 
    
12. class QmyWidget(QWidget):
    
13.    def __init__(self, parent=None):
    
14.       super().__init__(parent)   #调用父类构造函数，创建窗体
    
15.       self.ui=Ui_Widget()        #创建UI对象
    
16.       self.ui.setupUi(self)      #构造UI界面
    
17. 
    
18. ##  ==========由connectSlotsByName() 自动连接的槽函数====================        
    
19.    def on_btnIniItems_clicked(self):   ##“初始化列表”按钮
    
20.       self.ui.comboBox.clear()    #清除列表
    
21.       provinces=["拉丝","束丝","导体","挤出","橡胶","ccv"]    #列表数据
    
22.       for i in range(len(provinces)):
    
23.          self.ui.comboBox.addItem(provinces[i])
    
24. 
    
25.    def on_btnClearItems_clicked(self):    ##“清除列表”按钮
    
26.       self.ui.comboBox.clear()
    
27. 
    
28.    def on_btnOkItems_clicked(self):  ##“确定”按钮
    
29.       if self.ui.lineEdit.text().strip()=='拉丝':
    
30.          self.ui.plainTextEdit.clear()
    
31.          drawing.concat_file()
    
32.          self.ui.plainTextEdit.insertPlainText('拉丝数据导出完毕\n==========\n')
    
33.       elif self.ui.lineEdit.text().strip()=='束丝':
    
34.          self.ui.plainTextEdit.clear()
    
35.          bunching.read_bunching()
    
36.          self.ui.plainTextEdit.insertPlainText('束丝数据导出完毕\n==========\n')
    
37.       elif self.ui.lineEdit.text().strip() == '导体':
    
38.          self.ui.plainTextEdit.clear()
    
39.          conductor.concat_file()
    
40.          self.ui.plainTextEdit.insertPlainText('导体数据导出完毕\n==========\n')
    
41.       elif self.ui.lineEdit.text().strip()=='挤出':
    
42.          self.ui.plainTextEdit.clear()
    
43.          extruder.concat_file()
    
44.          self.ui.plainTextEdit.insertPlainText('挤出数据导出完毕\n==========\n')
    
45.       elif self.ui.lineEdit.text().strip()=='橡胶':
    
46.          self.ui.plainTextEdit.clear()
    
47.          rubber.concat_file()
    
48.          self.ui.plainTextEdit.insertPlainText('橡胶数据导出完毕\n==========\n')
    
49.       elif self.ui.lineEdit.text().strip()=='ccv':
    
50.          self.ui.plainTextEdit.clear()
    
51.          ccv.concat_file()
    
52.          self.ui.plainTextEdit.insertPlainText('CCV数据导出完毕\n==========\n')
    
53.       else:
    
54.          self.ui.plainTextEdit.clear()
    
55.          self.ui.plainTextEdit.insertPlainText('请选择正确的工序！！！\n==========\n')
    
56. 
    
57.    @pyqtSlot(str)    ##“简单的ComboBox”的当前项变化
    
58.    def on_comboBox_currentIndexChanged(self,curText):
    
59.       self.ui.lineEdit.setText(curText)
    
60. 
    
61. ##  ===========窗体测试程序 ================================        
    
62. if  __name__ == "__main__":         
    
63.    app = QApplication(sys.argv)   
    
64.    form=QmyWidget()      
    
65.    form.show()
    
66.    sys.exit(app.exec_())
    

复制代码

现在的问题是，6个函数，选中某一个后，由于函数读取数据文本比较耗时，导致界面卡。
如何改成多线程模式？
比如把6个函数改成6个checkbutton，选中几个就新开几个线程，且主界面不死。

最佳答案

月排行榜 / 总排行榜

hrp

2021-2-25 18:14:57

rsj0315 发表于 2021-2-25 13:25
我先写了一个，是combox，选中后，点击按钮，然后开启线程，进行数据清洗。
你说的把dataframe发射出来 ...

不知道是不是必须的用信号发射出来才能实现。
还是我直接在线程中就把数据显示出来。

用信号发射出来不是必须的，但必须是在主线程中更新界面，也就是说你想在子线程中把数据显示出来是行不通的。
还是前面说过的两个方法：
1，类初始化时设置一个属性比如self.whatever = None。定义例如名为update_tableview的方法，方法内根据self.whatever的值设置tabwiew。定义一个清洗数据的方法getdata，方法内清洗数据并将最终结果赋值给self.whatever。实例化一个线程threadx(getdata)，先将其finished信号连接至update_tableview，然后可以threadx.start()，当线程结束后，self.whatever的值已经变为清洗后的数据了，然后threadx的finished信号会触发update_tableview，update_tableview会根据self.whatever的值显示tableview。
2.在你的Thread1类中定义一个list类型的信号signal1=pyqtSignal(list)，在处理完结果后，signal1.emit([dataFrame])将dataFrame包在列表内发射出去。在你的myWidget内定义一个接收一个参数a(即将被发射的[dataFrame])的显示tabwiew的方法update_tabview，update_tableview内根据a的值设置tableview。然后将Thread1的实例的signal1信号连接至update_tableview即可。

跳转到最佳答案楼层

hrp

用QThread，它的线程实例开始时发射started信号，线程结束后发射finished信号，可以用started和finished信号触发槽函数来更新界面。
为什么不用threading？因为子线程不能直接更新QT界面，只能用QT的信号机制来更新界面。
唯一要注意的只有QThread不能赋值给函数局部变量，应该赋值给实例属性或其他生命周期足够长的变量，否则函数一结束线程也将跟着被结束。

rsj0315

hrp 发表于 2021-2-22 14:55
用QThread，它的线程实例开始时发射started信号，线程结束后发射finished信号，可以用started和finished信 ...

你的意思是在确认按钮这里，threading开6个线程，然后判断，选中了哪个？然后start选中的线程。是这样吗？

hrp

rsj0315 发表于 2021-2-23 09:16
你的意思是在确认按钮这里，threading开6个线程，然后判断，选中了哪个？然后start选中的线程。是这样吗 ...

不是，是定义一个方法，将6个按钮的点击信号都连接到这个方法(甚至你可以分别定义6个不同的方法，将6个按钮的点击信号分别连接到这6个方法)。
方法的内部，先判断是哪个按钮发射的点击信号(用sender获取信号的发射者)，再根据不同按钮创建不同任务的线程，线程中处理数据，把结果赋值给一个实例属性a，线程的started和finished信号分别连接线程开始(如果有需要)和结束要执行的方法f，f方法根据a储存的结果更新界面(比如线程结束信号可以连接在界面显示表格的方法)，这就实现了线程结束后自动更新界面。

Cool_Breeze

hrp 发表于 2021-2-23 10:23
不是，是定义一个方法，将6个按钮的点击信号都连接到这个方法(甚至你可以分别定义6个不同的方法，将6个 ...

你的思路很清晰啊，很好！

rsj0315

hrp 发表于 2021-2-23 10:23
不是，是定义一个方法，将6个按钮的点击信号都连接到这个方法(甚至你可以分别定义6个不同的方法，将6个 ...

感谢，我去研究下这个信号和槽的部分。有好的帖子或者demo欢迎分享

hrp

rsj0315 发表于 2021-2-23 10:57
感谢，我去研究下这个信号和槽的部分。有好的帖子或者demo欢迎分享

我自己写的 AwesomePyKit 也用到多线程，可以看看，代码写的很烂还没时间重构。
QThread的使用：在RunPyKit.py中搜索NewTask(继承自QThread)就可以了。
NewTask的定义：在library/libm.py里面。

hrp

Cool_Breeze 发表于 2021-2-23 10:36
你的思路很清晰啊，很好！

之前写pykit的时候苦于在子线程中无法更新主界面，然后百度说需要通过信号更新主界面，最后摸索出来的办法

rsj0315

看到有人展示一个这样的，不传参数的

1. from PyQt5.Qt import (QApplication, QWidget, QPushButton,
   
2.                       QThread,QMutex,pyqtSignal)
   
3. import sys
   
4. import time
   
5. 
   
6. qmut_1 = QMutex() # 创建线程锁
   
7. qmut_2 = QMutex()
   
8. # 继承QThread
   
9. class Thread_1(QThread):  # 线程1
   
10.     def __init__(self):
    
11.         super().__init__()
    
12. 
    
13.     def run(self):
    
14.         qmut_1.lock() # 加锁
    
15.         values = [1, 2, 3, 4, 5]
    
16.         for i in values:
    
17.             print(i)
    
18.             time.sleep(0.5)  # 休眠
    
19.         qmut_1.unlock() # 解锁
    
20. 
    
21. 
    
22. class Thread_2(QThread):  # 线程2
    
23.     _signal =pyqtSignal()
    
24.     def __init__(self):
    
25.         super().__init__()
    
26. 
    
27.     def run(self):
    
28.         # qmut_2.lock()  # 加锁
    
29.         values = ["a", "b", "c", "d", "e"]
    
30.         for i in values:
    
31.             print(i)
    
32.             time.sleep(0.5)
    
33.         # qmut_2.unlock()  # 解锁
    
34.         self._signal.emit()
    
35. 
    
36. 
    
37. class MyWin(QWidget):
    
38.     def __init__(self):
    
39.         super().__init__()
    
40.         # 按钮初始化
    
41.         self.btn_1 = QPushButton('按钮1', self)
    
42.         self.btn_1.move(120, 80)
    
43.         self.btn_1.clicked.connect(self.click_1)  # 绑定槽函数
    
44. 
    
45.         self.btn_2 = QPushButton('按钮2', self)
    
46.         self.btn_2.move(120, 120)
    
47.         self.btn_2.clicked.connect(self.click_2)  # 绑定槽函数
    
48. 
    
49.     def click_1(self):
    
50.         self.thread_1 = Thread_1()  # 创建线程
    
51.         self.thread_1.start()  # 开始线程
    
52. 
    
53.     def click_2(self):
    
54.         self.btn_2.setEnabled(False)
    
55.         self.thread_2 = Thread_2()
    
56.         self.thread_2._signal.connect(self.set_btn)
    
57.         self.thread_2.start()
    
58. 
    
59.     def set_btn(self):
    
60.         self.btn_2.setEnabled(True)
    
61. 
    
62. 
    
63. if __name__ == "__main__":
    
64.     app = QApplication(sys.argv)
    
65.     myshow = MyWin()
    
66.     myshow.show()
    
67.     sys.exit(app.exec_())

复制代码

rsj0315

还有一种这样的

1. import sys
   
2. from PyQt5 import QtCore
   
3. from PyQt5.QtWidgets import *
   
4. from PyQt5.QtGui import *
   
5. from PyQt5.QtCore import *
   
6. 
   
7. class Demo(QWidget):
   
8.     def __init__(self):
   
9.         super().__init__()
   
10.         self.setGeometry(100, 50, 500, 400)
    
11.         self.setWindowTitle('QThread')
    
12. 
    
13.         self.thread = Worker()
    
14.         self.list = QListWidget()
    
15.         self.btn = QPushButton('开始')
    
16.         layout = QGridLayout(self)
    
17.         layout.addWidget(self.list,0,0,1,2)
    
18.         layout.addWidget(self.btn,1,1)
    
19.         self.btn.clicked.connect(self.slotStart)
    
20.         self.thread.sinOut.connect(self.slotAdd)
    
21. 
    
22.     def slotAdd(self,inf):
    
23.         self.list.addItem(inf)
    
24.         #实时刷新页面
    
25.         QApplication.processEvents()
    
26. 
    
27.     def slotStart(self):
    
28.         self.btn.setEnabled(False)
    
29.         self.thread.start()
    
30. 
    
31. class Worker(QThread):
    
32.     #自定义信号
    
33.     sinOut = pyqtSignal(str)
    
34. 
    
35.     def __init__(self):
    
36.         super().__init__()
    
37.         self.working = True
    
38.         self.num = 0
    
39. 
    
40.     def __del__(self):
    
41.         self.working = False
    
42.         self.wait()
    
43. 
    
44.     def run(self):
    
45.         while self.working == True:
    
46.             file_str = 'File index{0}'.format(self.num)
    
47.             self.num += 1
    
48.             #发射信号
    
49.             self.sinOut.emit(file_str)
    
50.             #休眠2秒
    
51.             self.sleep(2)
    
52. 
    
53. if __name__ == "__main__":
    
54.     app = QApplication(sys.argv)
    
55.     form = Demo()
    
56.     form.show()
    
57.     sys.exit(app.exec_())

复制代码

hrp

qthread自定义信号更方便

rsj0315

hrp 发表于 2021-2-23 16:43
qthread自定义信号更方便

信号我像传递的是用pandas库清洗出来的dataframe，我看了emit的几种形式，好像传输不了这种

hrp

rsj0315 发表于 2021-2-23 17:21
信号我像传递的是用pandas库清洗出来的dataframe，我看了emit的几种形式，好像传输不了这种

可以发射list等类型的啊，把数据装进列表再发射不就好了

rsj0315

hrp 发表于 2021-2-23 17:41
可以发射list等类型的啊，把数据装进列表再发射不就好了

我先写了一个，是combox，选中后，点击按钮，然后开启线程，进行数据清洗。
你说的把dataframe发射出来，应该怎么写呢？list.append？
我没太懂。

目的：
我是想把这个dataframe用model/view模式在tableview上显示出来。
不知道是不是必须的用信号发射出来才能实现。
还是我直接在线程中就把数据显示出来。

你看看我写的，还没发射dataframe的

1. import sys
   
2. from PyQt5.QtWidgets import  QApplication, QWidget
   
3. from PyQt5.QtCore import  pyqtSlot, QThread,pyqtSignal
   
4. from ui_Widget import Ui_Widget
   
5. import itp_drawing as drawing
   
6. 
   
7. class Thread1(QThread):
   
8.    signal1 = pyqtSignal()
   
9.    def __init__(self):
   
10.       super(Thread1, self).__init__()
    
11. 
    
12.    def run(self):
    
13.       df = drawing.concat_file()
    
14. 
    
15. 
    
16. 
    
17. class QmyWidget(QWidget):
    
18.    def __init__(self, parent=None):
    
19.       super().__init__(parent)   #调用父类构造函数，创建窗体
    
20.       self.ui=Ui_Widget()        #创建UI对象
    
21.       self.ui.setupUi(self)      #构造UI界面
    
22. 
    
23. 
    
24. ##  ==========由connectSlotsByName() 自动连接的槽函数====================        
    
25.    def on_btnIniItems_clicked(self):   ##“初始化列表”按钮
    
26.       self.ui.comboBox.clear()    #清除列表
    
27.       provinces=["拉丝","束丝","导体","挤出","橡胶","ccv"]    #列表数据
    
28.       for i in range(len(provinces)):
    
29.          self.ui.comboBox.addItem(provinces[i])
    
30. 
    
31.    def on_btnClearItems_clicked(self):    ##“清除列表”按钮
    
32.       self.ui.comboBox.clear()
    
33. 
    
34.    @pyqtSlot()
    
35.    def on_btnOkItems_clicked(self):  ##“确定”按钮
    
36.       self.thread1 = Thread1()
    
37.       self.thread1.start()
    
38.       
    
39.    @pyqtSlot(str)    ##“简单的ComboBox”的当前项变化
    
40.    def on_comboBox_currentIndexChanged(self,curText):
    
41.       self.ui.lineEdit.setText(curText)
    
42. 
    
43. ##  ===========窗体测试程序 ================================        
    
44. if  __name__ == "__main__":         
    
45.    app = QApplication(sys.argv)
    
46.    form=QmyWidget()
    
47.    form.show()
    
48.    sys.exit(app.exec_())
    

复制代码

hrp

rsj0315 发表于 2021-2-25 13:25
我先写了一个，是combox，选中后，点击按钮，然后开启线程，进行数据清洗。
你说的把dataframe发射出来 ...

不知道是不是必须的用信号发射出来才能实现。
还是我直接在线程中就把数据显示出来。

用信号发射出来不是必须的，但必须是在主线程中更新界面，也就是说你想在子线程中把数据显示出来是行不通的。
还是前面说过的两个方法：
1，类初始化时设置一个属性比如self.whatever = None。定义例如名为update_tableview的方法，方法内根据self.whatever的值设置tabwiew。定义一个清洗数据的方法getdata，方法内清洗数据并将最终结果赋值给self.whatever。实例化一个线程threadx(getdata)，先将其finished信号连接至update_tableview，然后可以threadx.start()，当线程结束后，self.whatever的值已经变为清洗后的数据了，然后threadx的finished信号会触发update_tableview，update_tableview会根据self.whatever的值显示tableview。
2.在你的Thread1类中定义一个list类型的信号signal1=pyqtSignal(list)，在处理完结果后，signal1.emit([dataFrame])将dataFrame包在列表内发射出去。在你的myWidget内定义一个接收一个参数a(即将被发射的[dataFrame])的显示tabwiew的方法update_tabview，update_tableview内根据a的值设置tableview。然后将Thread1的实例的signal1信号连接至update_tableview即可。

rsj0315

hrp 发表于 2021-2-25 18:14
用信号发射出来不是必须的，但必须是在主线程中更新界面，也就是说你想在子线程中把数据显示出来是行不 ...

赞

xm_zhu

关注,还看不懂,等看懂了再来

rsj0315

按照这个，子线程的额数据清洗后，存储在pkl，然后主线程显示表格的时候再读取pkl

591821661

转一下大佬的代码，有个 @hrp
NewTask定义

1. from PyQt5.QtCore import QThread
   
2. 
   
3. class NewTask(QThread):
   
4.     def __init__(self, target, args=tuple()):
   
5.         super().__init__()
   
6.         self._args = args
   
7.         self._target = target
   
8. 
   
9.     def run(self):
   
10.         self._target(*self._args)
    
11. 
    
12.     def __repr__(self):
    
13.         return f"{self._target} with args:{self._args}"
    
14. 
    
15.     __str__ = __repr__
    
16. 
    
17.     def at_start(self, *callable_objs):
    
18.         for cab in callable_objs:
    
19.             if callable(cab):
    
20.                 self.started.connect(cab)
    
21. 
    
22.     def at_finish(self, *callable_objs):
    
23.         for cab in callable_objs:
    
24.             if callable(cab):
    
25.                 self.finished.connect(cab)

复制代码

应用实例

1.         def do_install():
   
2.             for name, code in loop_install(
   
3.                 cur_env,
   
4.                 package_to_be_installed,
   
5.                 pre=install_pre,
   
6.                 user=user,
   
7.                 index_url=index_url,
   
8.             ):
   
9.                 item = self.cur_pkgs_info.setdefault(name, ["", "", ""])
   
10.                 if not item[0]:
    
11.                     item[0] = "- N/A -"
    
12.                 item[2] = "安装成功" if code else "安装失败"
    
13. 
    
14.         thread_install_pkgs = NewTask(do_install)
    
15.         thread_install_pkgs.at_start(
    
16.             self.lock_widgets,
    
17.             lambda: self.show_loading("正在安装，请稍候..."),
    
18.         )
    
19.         thread_install_pkgs.at_finish(
    
20.             self.table_widget_pkgs_info_update,
    
21.             self.hide_loading,
    
22.             self.release_widgets,
    
23.         )
    
24.         thread_install_pkgs.start()
    
25.         self.thread_repo.put(thread_install_pkgs, 0)

复制代码

进程池定义

1. 
   
2. from PyQt5.QtCore import QMutex
   
3. class ThreadRepo:
   
4.     def __init__(self, interval):
   
5.         """interval: 清理已结束线程的时间间隔，单位毫秒。"""
   
6.         self._thread_repo = []
   
7.         self._timer_clths = QTimer()
   
8.         self._mutex = QMutex()
   
9.         self._timer_clths.timeout.connect(self.clean)
   
10.         self._timer_clths.start(interval)
    
11.         self._flag_cleaning = False
    
12. 
    
13.     def put(self, threadhandle, level=0):
    
14.         """将(线程句柄、重要等级)元组加入线程仓库。"""
    
15.         self._mutex.lock()
    
16.         self._thread_repo.append((threadhandle, level))
    
17.         self._mutex.unlock()
    
18. 
    
19.     def clean(self):
    
20.         """清除已结束的线程。"""
    
21.         if self._flag_cleaning:
    
22.             return
    
23.         self._mutex.lock()
    
24.         index = 0
    
25.         self._flag_cleaning = True
    
26.         while index < len(self._thread_repo):
    
27.             if self._thread_repo[index][0].isRunning():
    
28.                 index += 1
    
29.                 continue
    
30.             del self._thread_repo[index]
    
31.         self._flag_cleaning = False
    
32.         self._mutex.unlock()
    
33. 
    
34.     def stop_all(self):
    
35.         """
    
36.         按线程重要等级退出线程。
    
37.         0级：重要，安全退出；
    
38.         1级：不重要，立即退出；
    
39.         其他：未知等级，安全退出。
    
40.         """
    
41.         for thread, level in self._thread_repo:
    
42.             if level == 0:
    
43.                 thread.quit()
    
44.             elif level == 1:
    
45.                 thread.terminate()
    
46.             else:
    
47.                 thread.quit()
    
48. 
    
49.     def kill_all(self):
    
50.         """立即终止所有线程。"""
    
51.         for thread, _ in self._thread_repo:
    
52.             thread.terminate()
    
53. 
    
54.     def is_empty(self):
    
55.         """返回线程仓库是否为空。"""
    
56.         return not self._thread_repo

复制代码

均转自AwesomePyKit项目
开源精神！
Salute!

591821661

我有一个大胆的想法 ：之前的Threading线程结果放到queue里面 然后用Qthread 来读取这个queue里面的东西显示，也就是说 该 Qthread只用来做显示结果用 不参与数据处理过程 （我想到了Iphone系统 不论程序怎么卡 它系统都不会卡）主要是为了实现显示进程和算法进程的互不干扰@hrp 你觉得这个想法怎么样