PyQt:moveToThread在对s使用partial（）时不起作用

Question

我正在构建一个小型GUI应用程序，它运行一个producer（worker），GUI按需使用输出并绘制输出（使用pyqtgraph）。在

由于producer是一个阻塞函数（需要一段时间才能运行），所以我（应该）将它移动到它自己的线程中。在

打电话时QThread.currentThreadId（）它从producer输出与主GUI线程相同的数字。因此，首先执行worker，然后执行所有的绘图函数调用（因为它们正在同一线程的事件队列中排队）。我该怎么解决这个问题？在

部分运行示例：

gui thread id 140665453623104
worker thread id: 140665453623104

以下是我的完整代码：

^{pr2}$

Answer 1

问题是Qt试图根据slot所在的线程选择连接类型（当您调用signal.connect(slot)）时。因为您已经用partial将插槽包装在QThread中，所以要连接的插槽位于主线程（GUI线程）中。您可以重写连接类型（作为connect()的第二个参数），但这没有帮助，因为partial创建的方法将始终存在于主线程中，因此将连接类型设置为by ^{}没有帮助。在

我能看到的唯一解决方法是设置一个中继信号，其唯一目的是有效地将没有参数的发射信号（例如从按钮单击的信号）更改为具有一个参数（您的m参数）的信号。这样，您就不需要用partial()来包装QThread中的插槽。在

代码如下。我在主windows类中创建了一个带有一个参数（int）的信号，称为'relay'。buttonclicked信号连接到主窗口类中的一个方法，这个方法有一行代码，它发出我创建的自定义信号。您可以扩展此方法（relay_signal()）以获得要传递给QThread的整数m（本例中为500），从任何地方开始！在

代码如下：

from functools import partial
from Queue import Queue
import math
import sys
import time

class Worker(QtCore.QObject):

    termino = pyqtSignal()

    def __init__(self, q=None, parent=None):
        super(Worker, self).__init__(parent) 
        self.q = q

    def run(self, m=30000):
        print('worker thread id: {}'.format(QtCore.QThread.currentThreadId()))
        for x in xrange(m):
            #y = math.sin(x)
            y = x**2
            #time.sleep(0.001) # Weird, plotting stops if this is not present...
            self.q.put((x,y,y))
        print('Worker finished')

        self.termino.emit()

class MainWindow(QtGui.QWidget):

    relay = pyqtSignal(int)

    def __init__(self, parent=None):
        super(MainWindow, self).__init__(parent)

        self.q = Queue()
        self.termino = False       

        self.worker = Worker(self.q)

        self.workerThread = None
        self.btn = QtGui.QPushButton('Start worker')
        self.pw = pg.PlotWidget(self)
        pi = self.pw.getPlotItem()
        pi.enableAutoRange('x', True)
        pi.enableAutoRange('y', True)
        self.ge1 = pi.plot(pen='y')
        self.xs = []
        self.ys = []

        layout = QtGui.QVBoxLayout(self)
        layout.addWidget(self.pw)
        layout.addWidget(self.btn)

        self.resize(400, 400)

    def run(self):
        self.workerThread = QtCore.QThread()
        self.worker.termino.connect(self.setTermino)
        self.worker.moveToThread(self.workerThread)
        # moveToThread doesn't work here
        # self.btn.clicked.connect(partial(self.worker.run, 30000))
        # moveToThread will work here
        # assume def worker.run(self): instead of def worker.run(self, m=30000)
        #self.btn.clicked.connect(self.worker.run)        
        self.relay.connect(self.worker.run)
        self.btn.clicked.connect(self.relay_signal)
        self.btn.clicked.connect(self.graficar)

        self.workerThread.start()
        self.show()

    def relay_signal(self):
        self.relay.emit(500)

    def setTermino(self):
        self.termino = True

    def graficar(self):
        if not self.q.empty():
            e1,e2,ciclos = self.q.get()       
            self.xs.append(ciclos)
            self.ys.append(e1)
            self.ge1.setData(y=self.ys, x=self.xs)

        if not self.termino or not self.q.empty():
            QtCore.QTimer.singleShot(1, self.graficar)

if __name__ == '__main__':

    app = QtGui.QApplication([])
    window = MainWindow()

    QtCore.QTimer.singleShot(0, window.run);
    sys.exit(app.exec_())

我还修改了graficar方法，以便在队列中仍有数据时继续绘制（即使在线程终止之后）。我想这可能就是为什么您需要在QThread中使用time.sleep，它现在也被删除了。在

另外，关于代码中关于moveToThread放置位置的注释，它现在的位置是正确的。它应该在将QThread slot连接到信号的调用之前，其原因在这个堆栈溢出帖子中讨论：PyQt: Connecting a signal to a slot to start a background operation