Q线程信号/插槽到Q进程

Question

我有一个程序，它使用qthread和Signals/slot与GUI通信。 它的简化形式如下所示。在

但是，我想把它改成QProcess，这样我就可以利用多核处理了。有简单的方法吗？在

如果我简单地将QThread更改为QProcess，那么进程没有{}函数。我已经尝试了几种不同的多核处理方法，比如Pipes()和{}模块中的multiprocessing，但是我不能让任何东西都很好地工作。我觉得在陆地上用起来比较容易。在

这是我为QThreads、信号和插槽而准备的简化代码。在

from PyQt4 import QtCore, QtGui
import multiprocessing as mp
import numpy as np
import sys

class Spectra(QtCore.QObject):

    update_signal = QtCore.pyqtSignal(str)
    done_signal = QtCore.pyqtSignal()

    def __init__(self, spectra_name, X, Y):
        QtCore.QObject.__init__(self)
        self.spectra_name = spectra_name
        self.X = X
        self.Y = Y
        self.iteration = 0

    @QtCore.pyqtSlot() 
    def complex_processing_on_spectra(self):
        for i in range(0,99999):
            self.iteration += 1
            self.update_signal.emit(str(self.iteration))
        self.done_signal.emit()

class Spectra_Tab(QtGui.QTabWidget):
    start_comp = QtCore.pyqtSignal()
    kill_thread = QtCore.pyqtSignal()
    def __init__(self, parent, spectra):
        self.parent = parent
        self.spectra = spectra
        QtGui.QTabWidget.__init__(self, parent)

        self.treeWidget = QtGui.QTreeWidget(self)
        self.properties = QtGui.QTreeWidgetItem(self.treeWidget, ["Properties"])
        self.step = QtGui.QTreeWidgetItem(self.properties, ["Iteration #"])

        thread = QtCore.QThread(parent=self)
        self.worker = self.spectra
        self.worker.moveToThread(thread)
        self.worker.update_signal.connect(self.update_GUI)
        self.worker.done_signal.connect(self.closeEvent)
        self.start_comp.connect(self.worker.complex_processing_on_spectra)
        self.kill_thread.connect(thread.quit)
        thread.start()

    @QtCore.pyqtSlot(str)
    def update_GUI(self, iteration):
        self.step.setText(0, iteration)

    def start_computation(self):
        self.start_comp.emit()

    def closeEvent(self):
        print 'done with processing'
        self.kill_thread.emit()

class MainWindow(QtGui.QMainWindow):
    def __init__(self, parent = None):
        QtGui.QMainWindow.__init__(self)

        self.setTabShape(QtGui.QTabWidget.Rounded)
        self.centralwidget = QtGui.QWidget(self)
        self.top_level_layout = QtGui.QGridLayout(self.centralwidget)

        self.tabWidget = QtGui.QTabWidget(self.centralwidget)
        self.top_level_layout.addWidget(self.tabWidget, 1, 0, 25, 25)

        process_button = QtGui.QPushButton("Process")
        self.top_level_layout.addWidget(process_button, 0, 1)
        QtCore.QObject.connect(process_button, QtCore.SIGNAL("clicked()"), self.process)

        self.setCentralWidget(self.centralwidget)
        self.centralwidget.setLayout(self.top_level_layout)

        # Open several files in loop from button - simplifed to one here
        X = np.arange(0.1200,.2)
        Y = np.arange(0.1200,.2)
        self.spectra = Spectra('name', X, Y)
        self.spectra_tab = Spectra_Tab(self.tabWidget, self.spectra)
        self.tabWidget.addTab(self.spectra_tab, 'name')

    def process(self):
        self.spectra_tab.start_computation()
        return

if __name__ == "__main__":
    app = QtGui.QApplication([])
    win = MainWindow()
    win.show()
    sys.exit(app.exec_())

Answer 1

进程没有moveToThread()，因为进程存在于自己的内存空间中，因此它看不到MainWindow或其任何成员。开始使用QProcess的应用程序应该能够作为独立应用程序执行。在

要在另一个QProcess中运行spectra，您需要使spectra成为一个单独的可执行模块，而不是像现在这样的MainWindow成员。在

编辑：

您需要定义对MainWindow依赖性最小的自包含模块-它可以是spectra process only，也可以是spectra process with tab。您可以在构造时或通过标准输入将信息传递给流程，并通过标准输出从流程中检索数据。在选择律师来放置进程时，关键思想是尽量减少进程和主窗口之间的通信和依赖。你可以把一个过程看作一个简单的C程序：

int main(int argc,char* argv[]);

您可以在启动时传递参数，如有必要，通过cin/stdin从MainWindow获取额外的输入，通过cout/stdout/stderr（QProcess有接口）将一些结果输出到MainWindow。在