python - 从用作进度监视器的 QDialog 中启动 QProcess

Question

我有一个主要的 pyqt 程序需要运行带有参数的外部程序。我想使用 QDialog 作为一种状态监视器，它可以在外部程序执行时捕获它的标准输出，并将它们显示在 QDialog 内的文本框中。我有以下状态监视器代码:

class ProgressInfo(QtGui.QDialog):
    def __init__(self, cmd, args, parent=None):
        #super(self).__init__(parent)
        QDialog.__init__(self)
        self.ui = Ui_Dialog()
        self.ui.setupUi(self)
        self.cmd = cmd
        self.args = args
        self.keepGoing = True
        layout = QFormLayout()
        layout.setContentsMargins(10, 10, 10, 10)
        self.output = QtGui.QTextEdit()
        layout.addRow(self.output)
        layout.addRow(self.ui.buttonBox)
        self.setLayout(layout)

        self.ext_process = QtCore.QProcess(self)
        #self.ext_process.waitForFinished(-1)
        #self.ext_process.waitForStarted()
        #self.ext_process.readyRead.connect(self.dataReady)
        self.ext_process.started.connect(self.open)
        self.ext_process.readyReadStandardOutput.connect(self.dataReady)
        self.ext_process.finished.connect(self.onProcessFinished)
        self.ext_process.start(self.cmd, self.args)

    def dataReady(self):
        cursor = self.output.textCursor()
        cursor.movePosition(cursor.End)
        cursor.insertText(str(self.ext_process.readAll()))
        self.output.ensureCursorVisible()

    def onProcessFinished(self):
        cursor = self.output.textCursor()
        cursor.movePosition(cursor.End)
        #cursor.insertText(str(self.ext_process.readAll()))
        cursor.insertText(str(self.ext_process.readAllStandardOutput()))
        self.output.ensureCursorVisible()

然后我将使用以下命令实例化它:

prog='C:/Program Files (x86)/My Program/Execute.exe'
margs=['D:/Data/Input1.txt', 'D:/Data/Input2.txt']
status = ProgressInfo(prog, margs, self)

到目前为止，这还没有奏效。

问题 1:只有在我取消对 waitForFinished(-1) 行的注释后，外部程序才会运行。

问题2.QDialog框只是一闪而过，然后就消失了。

问题3.很明显，运行的程序没有突出显示。

最后，我整理的代码吸取了很多人的想法和教训，但我看了一下，好像只能在程序结束后才能打印出所有的standout，但我希望它能逐行显示程序在运行时将它们写出。

我的工具链:Python 64 位版本 2.7.5，我在 Windows 7 box 上开发

('Qt version:', '4.8.5')
('SIP version:', '4.14.7')
('PyQt version:', '4.10.2')

感谢您的帮助。

Answer 1

这里是一个例子，你可以如何做到这一点(我使用 QWidget 但你也可以使用 QDialog 或其他)。我不使用单独的线程，因为 UI 不需要交互。如果您想添加按钮等，那么您应该考虑使用 Qt 提供的运行 QObject 模型的旧式 QThread。

#!/usr/bin/python
from PyQt4.QtGui import * 
from PyQt4.QtCore import * 
import sys


class MyQProcess(QWidget):     
  def __init__(self):    
   super(QWidget, self).__init__()

   # Add the UI components (here we use a QTextEdit to display the stdout from the process)
   layout = QVBoxLayout()
   self.edit = QTextEdit()
   self.edit.setWindowTitle("QTextEdit Standard Output Redirection")
   layout.addWidget(self.edit)
   self.setLayout(layout)

   # Add the process and start it
   self.process = QProcess()
   self.setupProcess()   

   # Show the widget
   self.show()

  def setupProcess(self):
    # Set the channels
    self.process.setProcessChannelMode(QProcess.MergedChannels)
    # Connect the signal readyReadStandardOutput to the slot of the widget
    self.process.readyReadStandardOutput.connect(self.readStdOutput)
    # Run the process with a given command
    self.process.start("df -h")

  def __del__(self):
    # If QApplication is closed attempt to kill the process
    self.process.terminate()
    # Wait for Xms and then elevate the situation to terminate
    if not self.process.waitForFinished(10000):
      self.process.kill()

  @pyqtSlot()
  def readStdOutput(self):
    # Every time the process has something to output we attach it to the QTextEdit
    self.edit.append(QString(self.process.readAllStandardOutput()))


def main():  
    app = QApplication(sys.argv)
    w   = MyQProcess()

    return app.exec_()

if __name__ == '__main__':
    main()

请注意，我正在使用的命令 (df -h) 运行一次(这是一个 Linux 命令，显示硬盘驱动器上的磁盘使用情况)然后就结束了。您也可以将其替换为可以无限期运行的 Execute.exe。我已经使用 htop(基于终端的高级任务管理器)对其进行了测试，它一旦启动就不会停止，除非用户希望它停止或系统停止(崩溃、关机等)。

请注意，您必须确保以干净的方式停止外部进程。这可以在 __del__(析构函数)或在给定小部件生命周期结束时调用的另一个函数中完成。我所做的基本上是向外部进程发送一个 SIGTERM (terminate)，一旦经过了给定的时间但进程仍在运行，我会提升情况到 SIGKILL(kill)。

代码显然需要更多的工作，但它应该足以让您了解事情是如何工作的。

这里是上面代码的相同版本，但有一个额外的线程。请注意，我将外部进程的输出重定向到我的工作程序中的一个插槽。除非您想处理该输出，否则您不必这样做。所以你可以跳过这个并将你的过程信号连接到你的小部件中接收它并输出其内容的插槽。输出的处理将在单独的线程中再次完成，因此您可以继续进行而不是卡住您的 UI(如果您遵循

from PyQt4.QtGui import * 
from PyQt4.QtCore import * 
import sys

class Worker(QObject):
  sendOutput = pyqtSignal(QString)  

  def __init__(self):
    super(Worker, self).__init__()
    self.process = QProcess()
    self.setupProcess()

  def __del__(self):
    self.process.terminate()
    if not self.process.waitForFinished(10000):
      self.process.kill()

  def setupProcess(self):
    self.process.setProcessChannelMode(QProcess.MergedChannels)
    self.process.readyReadStandardOutput.connect(self.readStdOutput)
    self.process.start("htop")

  @pyqtSlot()
  def readStdOutput(self):
    output = QString(self.process.readAllStandardOutput())
    # Do some extra processing of the output here if required
    # ...
    self.sendOutput.emit(output)



class MyQProcess(QWidget):     
  def __init__(self):    
   super(QWidget, self).__init__()
   layout = QVBoxLayout()
   self.edit = QTextEdit()
   self.thread = QThread()

   self.setupConnections()

   self.edit.setWindowTitle("QTextEdit Standard Output Redirection")
   layout.addWidget(self.edit)
   self.setLayout(layout)
   self.show()

  def setupConnections(self):
    self.worker = Worker()
    self.thread.finished.connect(self.worker.deleteLater)
    self.worker.sendOutput.connect(self.showOutput)

    self.worker.moveToThread(self.thread)
    self.thread.start()

  def __del__(self):
    if self.thread.isRunning():
      self.thread.quit()
      # Do some extra checking if thread has finished or not here if you want to

  #Define Slot Here 
  @pyqtSlot(QString)
  def showOutput(self, output):
    #self.edit.clear()
    self.edit.append(output)


def main():  
    app = QApplication(sys.argv)
    w   = MyQProcess()

    return app.exec_()

if __name__ == '__main__':
    main()

进一步说明:正如我在他的回答的评论部分告诉@BrendanAbel 的那样，将插槽与 QThread 一起使用的问题是插槽具有与 相同的线程亲和性(=它们所属的线程) QThread 实例本身，它与创建 QThread 的线程相同。唯一 - 我重复 唯一 - 当涉及到 QThread 时，它在单独的线程中运行的是它的事件循环，由 QThread.run()。如果你在 Internet 上查看，你会发现这种做事方式是不鼓励的(除非你真的、真的知道你必须子类化 QThread)因为自 Qt 4 的早期版本以来run() 是抽象的，您必须继承 QThread 才能使用 QThread。后来抽象 run() 得到了一个具体的实现，因此子类化 QThread 的需要被移除了。关于线程安全和信号，@BrendanAbel 所写的只是部分正确。它归结为连接类型(默认为 AutoConnection)。如果您手动指定连接类型，您实际上可能会使信号成为线程不安全的。在 Qt documentation 中阅读更多相关信息.