2

我正在尝试将繁重的后台作业卸载到multiprocessing进程中。我只希望单独的进程能够向我的 GUI 报告它的进度。这是我的最后一次尝试，GUI 很简单，有几个按钮和一个进度条：

from PySide.QtGui import *
from PySide.QtCore import *
import sys
from multiprocessing import Process, Pipe
import time

class WorkerClass:
#This class has the job to run
    def worker(self, pipe):
        for i in range(101):
            pipe.send(i)
            time.sleep(.02)

class WorkStarter(QThread):
#this thread takes a widget and updates it using progress sent from
#process via Pipe
    def __init__(self, progressBar):
        super().__init__()
        self.progress_bar = progressBar

    def run(self):
        worker_obj = WorkerClass()
        myend, worker_end = Pipe(False)
        self.p = Process(target=worker_obj.worker, args=(worker_end,))
        self.p.start()
        while True:
            val = myend.recv()
            self.progress_bar.setValue(val)
            if val == 100:
                break

class WorkingWidget(QWidget):
    def __init__(self, parent=None):
        super().__init__(parent)
        self.setWindowTitle('Blue collar widget')
        layout = QHBoxLayout()
        start_btn = QPushButton('Start working')
        start_btn.clicked.connect(self.startWorking)
        end_btn = QPushButton('End working')
        end_btn.clicked.connect(self.endWorking)
        layout.addWidget(start_btn)
        layout.addWidget(end_btn)
        self.progress_bar = QProgressBar()
        layout.addWidget(self.progress_bar)
        self.setLayout(layout)

    def startWorking(self):
        self.thread = WorkStarter(self.progress_bar)
        self.thread.start()

    def endWorking(self):
        self.thread.terminate()

if __name__ == '__main__':
    app = QApplication(sys.argv)
    main = WorkingWidget()
    main.show()
    sys.exit(app.exec_())

我不能将任何QObject作为参数传递给该过程，因为这不能pickle：

#cannot do the following
...
def startWorking(self):
    self.worker_obj = WorkerClass()
    #pass the progress bar to the process and the process updates the bar
    self.p = Process(target=self.worker_obj.worker, args=(self.progress_bar,))

问题是这个gui有时可以工作，有时它会冻结（所以请多次按“开始”直到它冻结:)），在Windows上它说：pythonw.exe已停止工作......任何线索是什么原因是什么？我自己无法弄清楚。谢谢

4

1 回答 1

2

你不应该在 QThread 的“run”方法中创建对象，从“run”发出信号，实现一个函数说“callerFunction”在这个函数中创建对象，最后在“run”发出的信号上调用这个函数功能。

  • 您可以在已创建的 while 循环中发出信号。
  • 看看这个解决方案
  • 不要创建 python 进程，QThread 足以胜任这项工作
于 2013-09-29T07:51:30.163 回答