我进行了这个快速而肮脏的测试,我在 Python 2.7 上的 PyQt4 中一个接一个地运行 QThreadPool 中的 QRunner 线程。基本上看起来运行得很好,但是一旦所有线程完成执行,线程/池似乎就不会停止 QThreadPool。
我想知道它是否像在执行完代码后从 QRunnable (
ProductImporter
)返回一些内置方法一样简单,但我似乎在文档中找不到任何内容。
我正在将一些代码从 QThread 结构移至此设置,因为我不能同时运行并发线程。
关于如何让 ProductImportTasks 知道它的任务已全部完成,以便我可以在之后或调用该类之后执行更多代码,有什么想法吗?任何帮助将不胜感激!
import sys
from PyQt4.QtGui import QApplication
from PyQt4.QtCore import QThreadPool, QObject, QRunnable, pyqtSignal
class WorkerSignals(QObject):
productResult = pyqtSignal(str)
class ProductImporter(QRunnable):
def __init__(self, product):
super(ProductImporter, self).__init__()
self.product = product
self.signals = WorkerSignals()
def run(self):
self.signals.productResult.emit(self.product['name'])
return
class ProductImportTasks(QObject):
def __init__(self, products):
super(ProductImportTasks, self).__init__()
self.products = products
self.pool = QThreadPool()
self.pool.setMaxThreadCount(1)
def process_result(self, product):
return
def start(self):
for product in self.products:
worker = ProductImporter(product)
worker.signals.productResult.connect(view.text)
self.pool.start(worker)
self.pool.waitForDone()
class ViewController(QObject):
def __init__(self, parent=None):
super(ViewController, self).__init__(parent)
#@pyqtSlot(str)
def text(self, message):
print "This is the view.text method: " + message
return
if __name__ == "__main__":
app = QApplication(sys.argv)
view = ViewController()
main = ProductImportTasks([{"name": "test1"}, {"name": "test2"}, {"name": "test3"}])
main.start()
sys.exit(app.exec_())
这是您的脚本的作用:
main.start()
main.start()
事件循环启动后,将处理可运行对象发出的信号,并打印消息。这是因为默认情况下跨线程发送的信号是“排队”的。通常,信号是同步发送的,不需要运行事件循环。 如果更改信号的连接类型,并添加一些打印语句,应该清楚发生了什么:
worker.signals.productResult.connect(view.text, Qt.DirectConnection)
self.pool.start(worker)
self.pool.waitForDone()
print('finished')
...
main.start()
print('exec')
sys.exit(app.exec_())