带有多线程的Python pyqt脉冲进度条

Question

由于我是初学者，请耐心等待我的问题。我在 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 应用程序中进度条的实现。你们至少能给我指出正确的方向吗？将不胜感激。

Answer 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 的外观。

它也应该感觉更灵敏，不会冻结。

Answer 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()

如果此答案中的某些内容有误，请纠正我，因为这将有助于更多地理解它，或者可能是一些应该做的事情，不要做