在 PyQt 中,在主 window 和线程之间共享数据的最佳方式是什么
In PyQt, what is the best way to share data between the main window and a thread
我正在用 PyQt4 编写我的第一个 GUI 应用程序,我遇到了一个看起来非常基本的问题,但我似乎找不到好的答案:
我正在使用线程连续执行重复任务而不阻塞主线程 window。线程需要来自 main window 的一些信息(例如旋转框的当前值),这些信息也可以在线程运行时发生变化。在这种情况下,在主 window 和线程之间共享此类数据的正确方法是什么?
天真地,我可以想出以下可能性:
- 将对主机 window 的引用传递给线程,并使用它来检索相关变量的当前值(参见下面的示例)。
- 在线程中保留变量的副本,并通过在变量发生变化时发出信号使其与主线程保持同步window。
- 使用全局变量。
所有三个选项最有可能适用于我的特定用例(尽管 2 会有点复杂),但我觉得应该有一个 better/more Pythonic/more Qt-like 方式.
这是一个最小的工作示例,说明我想做什么,在这种情况下使用选项 1:
from PyQt4 import QtGui, QtCore
import time, sys
class MainWindow(QtGui.QWidget):
def __init__(self):
super(MainWindow, self).__init__()
self.layout = QtGui.QVBoxLayout(self)
self.spinbox = QtGui.QSpinBox(self)
self.spinbox.setValue(1)
self.layout.addWidget(self.spinbox)
self.output = QtGui.QLCDNumber(self)
self.layout.addWidget(self.output)
self.worker = Worker(self)
self.connect(self.worker, QtCore.SIGNAL('beep'), self.update)
self.worker.start()
def update(self, number):
self.output.display(number)
class Worker(QtCore.QThread):
def __init__(self, host_window):
super(Worker, self).__init__()
self.host = host_window
self.running = False
def run(self):
self.running = True
i = 0
while self.running:
i += 1
self.emit(QtCore.SIGNAL('beep'), i)
sleep_time = self.host.spinbox.value()
time.sleep(sleep_time)
def stop(self):
self.running = False
app = QtGui.QApplication(sys.argv)
window = MainWindow()
window.show()
app.exec_()
PS:由于我完全没有使用 PyQt 的经验,因此代码可能存在其他问题或问题不清楚。在这种情况下,请随时发表评论或编辑问题。
小部件不是线程安全的,请参阅 Threads and QObjects:
Although QObject is reentrant, the GUI classes, notably QWidget and
all its subclasses, are not reentrant. They can only be used from the
main thread.
并在此处查看更多定义:Reentrancy and Thread-Safety
您应该只在主线程中使用小部件,并使用信号和插槽与其他线程进行通信。
我不认为全局变量会起作用,但老实说我不知道为什么。
本例中如何使用信号:
#in main
self.worker = Worker(self.spinbox.value())
self.worker.beep.connect(self.update)
self.spinbox.valueChanged.connect(self.worker.update_value)
class Worker(QtCore.QThread):
beep=QtCore.pyqtSignal(int)
def __init__(self,sleep_time):
super(Worker, self).__init__()
self.running = False
self.sleep_time=sleep_time
def run(self):
self.running = True
i = 0
while self.running:
i += 1
self.beep.emit(i)
time.sleep(self.sleep_time)
def stop(self):
self.running = False
def update_value(self,value):
self.sleep_time=value
注意:我使用的是新式信号槽
我正在用 PyQt4 编写我的第一个 GUI 应用程序,我遇到了一个看起来非常基本的问题,但我似乎找不到好的答案:
我正在使用线程连续执行重复任务而不阻塞主线程 window。线程需要来自 main window 的一些信息(例如旋转框的当前值),这些信息也可以在线程运行时发生变化。在这种情况下,在主 window 和线程之间共享此类数据的正确方法是什么?
天真地,我可以想出以下可能性:
- 将对主机 window 的引用传递给线程,并使用它来检索相关变量的当前值(参见下面的示例)。
- 在线程中保留变量的副本,并通过在变量发生变化时发出信号使其与主线程保持同步window。
- 使用全局变量。
所有三个选项最有可能适用于我的特定用例(尽管 2 会有点复杂),但我觉得应该有一个 better/more Pythonic/more Qt-like 方式.
这是一个最小的工作示例,说明我想做什么,在这种情况下使用选项 1:
from PyQt4 import QtGui, QtCore
import time, sys
class MainWindow(QtGui.QWidget):
def __init__(self):
super(MainWindow, self).__init__()
self.layout = QtGui.QVBoxLayout(self)
self.spinbox = QtGui.QSpinBox(self)
self.spinbox.setValue(1)
self.layout.addWidget(self.spinbox)
self.output = QtGui.QLCDNumber(self)
self.layout.addWidget(self.output)
self.worker = Worker(self)
self.connect(self.worker, QtCore.SIGNAL('beep'), self.update)
self.worker.start()
def update(self, number):
self.output.display(number)
class Worker(QtCore.QThread):
def __init__(self, host_window):
super(Worker, self).__init__()
self.host = host_window
self.running = False
def run(self):
self.running = True
i = 0
while self.running:
i += 1
self.emit(QtCore.SIGNAL('beep'), i)
sleep_time = self.host.spinbox.value()
time.sleep(sleep_time)
def stop(self):
self.running = False
app = QtGui.QApplication(sys.argv)
window = MainWindow()
window.show()
app.exec_()
PS:由于我完全没有使用 PyQt 的经验,因此代码可能存在其他问题或问题不清楚。在这种情况下,请随时发表评论或编辑问题。
小部件不是线程安全的,请参阅 Threads and QObjects:
Although QObject is reentrant, the GUI classes, notably QWidget and all its subclasses, are not reentrant. They can only be used from the main thread.
并在此处查看更多定义:Reentrancy and Thread-Safety
您应该只在主线程中使用小部件,并使用信号和插槽与其他线程进行通信。
我不认为全局变量会起作用,但老实说我不知道为什么。
本例中如何使用信号:
#in main
self.worker = Worker(self.spinbox.value())
self.worker.beep.connect(self.update)
self.spinbox.valueChanged.connect(self.worker.update_value)
class Worker(QtCore.QThread):
beep=QtCore.pyqtSignal(int)
def __init__(self,sleep_time):
super(Worker, self).__init__()
self.running = False
self.sleep_time=sleep_time
def run(self):
self.running = True
i = 0
while self.running:
i += 1
self.beep.emit(i)
time.sleep(self.sleep_time)
def stop(self):
self.running = False
def update_value(self,value):
self.sleep_time=value
注意:我使用的是新式信号槽