带有多线程的Python pyqt脉冲进度条
Posted
技术标签:
【中文标题】带有多线程的Python pyqt脉冲进度条【英文标题】:Python pyqt pulsing progress bar with multithreading 【发布时间】:2017-07-18 03:31:21 【问题描述】:由于我是初学者,请耐心等待我的问题。我在 pyqt 中实现进度条时遇到问题,我看到的所有示例并没有真正解释如何正确实现它,从这个 example 和这个 example 我在某种程度上使它工作但它仍然挂起。我有这个代码:
class Window(QtGui.QMainWindow):
def __init__(self):
super(Window, self).__init__()
self.setGeometry(750, 450, 400, 200)
self.setFixedSize(self.size())
btn1 = QtGui.QPushButton("Convert", self)
btn1.move(210,171)
btn1.clicked.connect(self.progbar)
def progbar (self):
self.prog_win = QDialog()
self.prog_win.resize(400, 100)
self.prog_win.setFixedSize(self.prog_win.size())
self.prog_win.setWindowTitle("Processing request")
self.lbl = QLabel(self.prog_win)
self.lbl.setText("Please Wait. . .")
self.lbl.move(15,18)
self.progressBar = QtGui.QProgressBar(self.prog_win)
self.progressBar.resize(410, 25)
self.progressBar.move(15, 40)
self.progressBar.setRange(0,1)
self.myLongTask = TaskThread()
#I think this is where I am wrong
#because all of the answers here is very specific
#or just not for beginners
self.prog_win.show()
self.myLongTask.taskFinished.connect(self.onStart)
self.output_settings()
def onStart(self):
self.progressBar.setRange(0,0)
self.myLongTask.start()
def output_convert(self):
#very long process to convert a txt file to excel
#My Thread
class TaskThread(QtCore.QThread):
taskFinished = QtCore.pyqtSignal()
def run(self):
time.sleep(3)
self.taskFinished.emit()
def run():
app = QtGui.QApplication(sys.argv)
GUI = Window()
app.exec_()
run()
这里的所有示例和帖子都对理解进度条的实现非常有帮助,但是所有示例都有针对特定问题的特定答案,我无法理解标准 pyqt 应用程序中进度条的实现。你们至少能给我指出正确的方向吗?将不胜感激。
【问题讨论】:
【参考方案1】:这是一个非常基本的进度条,仅使用最少需要的内容。
将整个示例阅读到最后是明智的。
import sys
import time
from PyQt5.QtWidgets import (QApplication, QDialog,
QProgressBar, QPushButton)
TIME_LIMIT = 100
class Actions(QDialog):
"""
Simple dialog that consists of a Progress Bar and a Button.
Clicking on the button results in the start of a timer and
updates the progress bar.
"""
def __init__(self):
super().__init__()
self.initUI()
def initUI(self):
self.setWindowTitle('Progress Bar')
self.progress = QProgressBar(self)
self.progress.setGeometry(0, 0, 300, 25)
self.progress.setMaximum(100)
self.button = QPushButton('Start', self)
self.button.move(0, 30)
self.show()
self.button.clicked.connect(self.onButtonClick)
def onButtonClick(self):
count = 0
while count < TIME_LIMIT:
count += 1
time.sleep(1)
self.progress.setValue(count)
if __name__ == "__main__":
app = QApplication(sys.argv)
window = Actions()
sys.exit(app.exec_())
进度条首先导入像这样from PyQt5.QtWidgets import QProgressBar
然后它像QtWidgets
中的任何其他小部件一样被初始化
self.progress.setGeometry(0, 0, 300, 25)
行方法定义了对话框上的x,y
位置以及进度条的宽度和高度。
然后我们将使用.move()
的按钮向下移动30px
,这样两个小部件之间就会有5px
的间隙。
这里self.progress.setValue(count)
用于更新进度。使用.setMaximum()
设置最大值也会自动为您计算值。例如,如果最大值设置为 50,那么由于 TIME_LIMIT
是 100,它将每秒从 0% 跳到 2% 到 4%,而不是从 0% 跳到 1% 到 2%。您还可以使用.setMinimum()
设置最小值,强制进度条从给定值开始。
执行此程序将产生与此类似的 GUI。
如您所见,在计数器满足TIME_LIMIT
条件之前,GUI 肯定会冻结并且无响应。这是因为time.sleep
导致操作系统认为程序已陷入无限循环。
QThread
那么我们如何克服这个问题呢?我们可以使用 PyQt5 提供的线程类。
import sys
import time
from PyQt5.QtCore import QThread, pyqtSignal
from PyQt5.QtWidgets import (QApplication, QDialog,
QProgressBar, QPushButton)
TIME_LIMIT = 100
class External(QThread):
"""
Runs a counter thread.
"""
countChanged = pyqtSignal(int)
def run(self):
count = 0
while count < TIME_LIMIT:
count +=1
time.sleep(1)
self.countChanged.emit(count)
class Actions(QDialog):
"""
Simple dialog that consists of a Progress Bar and a Button.
Clicking on the button results in the start of a timer and
updates the progress bar.
"""
def __init__(self):
super().__init__()
self.initUI()
def initUI(self):
self.setWindowTitle('Progress Bar')
self.progress = QProgressBar(self)
self.progress.setGeometry(0, 0, 300, 25)
self.progress.setMaximum(100)
self.button = QPushButton('Start', self)
self.button.move(0, 30)
self.show()
self.button.clicked.connect(self.onButtonClick)
def onButtonClick(self):
self.calc = External()
self.calc.countChanged.connect(self.onCountChanged)
self.calc.start()
def onCountChanged(self, value):
self.progress.setValue(value)
if __name__ == "__main__":
app = QApplication(sys.argv)
window = Actions()
sys.exit(app.exec_())
让我们分解这些修改。
from PyQt5.QtCore import QThread, pyqtSignal
这一行导入Qthread
,这是一个PyQt5
实现,用于在后台(也称为多线程)划分和运行程序的某些部分(例如:函数、类)。这些部分也称为螺纹。默认情况下,所有PyQt5
程序都有一个主线程,而其他(工作线程)用于将额外的耗时和处理密集型任务卸载到后台,同时仍保持主程序正常运行。
第二个导入pyqtSignal
用于在工作线程和主线程之间发送数据(信号)。在本例中,我们将使用它来告诉主线程更新进度条。
现在我们将计数器的 while 循环移到了一个名为 External
的单独类中。
class External(QThread):
"""
Runs a counter thread.
"""
countChanged = pyqtSignal(int)
def run(self):
count = 0
while count < TIME_LIMIT:
count +=1
time.sleep(1)
self.countChanged.emit(count)
通过对QThread
进行子类化,我们实质上是将External
转换为可以在单独线程中运行的类。线程也可以随时启动或停止以增加它的好处。
这里countChanged
是当前进度,pyqtSignal(int)
告诉工作线程正在发送的信号是int
类型。而self.countChanged.emit(count)
只是将信号发送到主线程中的任何连接(通常它也可以用于与其他工作线程通信)。
def onButtonClick(self):
self.calc = External()
self.calc.countChanged.connect(self.onCountChanged)
self.calc.start()
def onCountChanged(self, value):
self.progress.setValue(value)
单击按钮时,self.onButtonClick
将运行并启动线程。线程以.start()
开头。还需要注意的是,我们将之前创建的信号self.calc.countChanged
连接到了用于更新进度条值的方法。每次更新 External::run::count
时,int
的值也会发送到 onCountChanged
。
这是进行这些更改后 GUI 的外观。
它也应该感觉更灵敏,不会冻结。
【讨论】:
虽然我使用的是 PyQt4,但这确实对我帮助很大 @JuanCarlosAsuncion ^_^ 最佳答案!应该投票让每个人都能看到。【参考方案2】:我自己的问题的答案。如果你能理解线程和通过类传递变量的概念,这并不难。我的第一个错误是缺乏关于Worker
线程的知识,第二个是我认为一旦你声明了Thread
,这意味着你只需要调用它以便它可以在主类中运行函数,所以我是搜索你将如何实现它以及我认为是错误的。
解决方案
所有硬/长进程应该在def run
下的子类QThread
中,应该在你的class Window(QtGui.QMainWindow):
或主循环中调用,这就是我的代码现在的样子
class Window(QtGui.QMainWindow):
def __init__(self):
super(Window, self).__init__()
self.setGeometry(750, 450, 400, 200)
self.setFixedSize(self.size())
btn1 = QtGui.QPushButton("Convert", self)
btn1.move(210,171)
btn1.clicked.connect(self.progbar)
def progbar (self):
self.prog_win = QDialog()
self.prog_win.resize(400, 100)
self.prog_win.setFixedSize(self.prog_win.size())
self.prog_win.setWindowTitle("Processing request")
self.lbl = QLabel(self.prog_win)
self.lbl.setText("Please Wait. . .")
self.lbl.move(15,18)
self.progressBar = QtGui.QProgressBar(self.prog_win)
self.progressBar.resize(410, 25)
self.progressBar.move(15, 40)
self.progressBar.setRange(0,1)
self.myLongTask = TaskThread(var = DataYouWantToPass) #initializing and passing data to QThread
self.prog_win.show()
self.onStart() #Start your very very long computation/process
self.myLongTask.taskFinished.connect(self.onFinished) #this won't be read until QThread send a signal i think
def onStart(self):
self.progressBar.setRange(0,0)
self.myLongTask.start()
#added this function to close the progress bar
def onFinished(self):
self.progressBar.setRange(0,1)
self.prog_win.close()
#My Thread
class TaskThread(QtCore.QThread):
taskFinished = QtCore.pyqtSignal()
#I also added this so that I can pass data between classes
def __init__(self, var, parent=None):
QThread.__init__(self, parent)
self.var = var
def run(self):
#very long process to convert a txt file to excel
def run():
app = QtGui.QApplication(sys.argv)
GUI = Window()
app.exec_()
run()
如果此答案中的某些内容有误,请纠正我,因为这将有助于更多地理解它,或者可能是一些应该做的事情,不要做
【讨论】:
以上是关于带有多线程的Python pyqt脉冲进度条的主要内容,如果未能解决你的问题,请参考以下文章