0

我想使用 Qt 的 QThreadPool，但如果队列中的工作人员在调用 QApplication.quit() 之前没有完成，它似乎正在挂起我的应用程序。谁能告诉我我在下面的简化测试用例中是否做错了什么？

import logging
log = logging.getLogger(__name__)

import sys

from PySide import QtCore

import time

class SomeWork(QtCore.QRunnable):
    def __init__(self, sleepTime=1):
        super(SomeWork, self).__init__()
        self.sleepTime = sleepTime

    def run(self):
        time.sleep(self.sleepTime)
        print "work", QtCore.QThread.currentThreadId()

def _test(argv):
    logging.basicConfig(level=logging.NOTSET)

    app = QtCore.QCoreApplication(argv)

    pool = QtCore.QThreadPool.globalInstance()

    TASK_COUNT = int(argv[1]) if len(argv) > 1 else 1

    mainThread = QtCore.QThread.currentThreadId()
    print "Main thread: %s"%(mainThread)
    print "Max thread count: %s"%(pool.maxThreadCount())
    print "Work count: %s"%(TASK_COUNT)

    for i in range(TASK_COUNT):
        pool.start(SomeWork(1))

    def boom():
        print "boom(); calling app.quit()"
        app.quit()

    QtCore.QTimer.singleShot(2000, boom)

    #import signal
    #signal.signal(signal.SIGINT, signal.SIG_DFL)

    return app.exec_()

if __name__ == '__main__':
    sys.exit(_test(sys.argv))

需要明确的是，这是我得到的输出：

(env)root@localhost:# python test_pool.py 1
Main thread: 3074382624
Max thread count: 1
Work count: 1
work 3061717872
boom(); calling app.quit()

(env)root@workshop:/home/workshop/workshop/workshop# python test_pool.py 20
Main thread: 3074513696
Max thread count: 1
Work count: 20
work 3060783984
boom(); calling app.quit()

它永远挂在第二个命令上，但不是第一个。

感谢您提供的任何帮助。

编辑：

  • 需要明确的是，我希望如果 app.quit() 在线程位于线程队列中时被调用，它们不会运行。已经运行的线程应该运行完成。然后，应用程序应该关闭。
  • 此示例在 Windows 机器上也失败了
  • 此示例适用于同一台 Windows 机器，但使用 PyQt4
4

1 回答 1

0

在 exec() 修复问题之前将其添加到 _test() 中，尽管所有线程都运行：

def waitForThreads():
    print "Waiting for thread pool"
    pool.waitForDone()
app.aboutToQuit.connect(waitForThreads)
于 2013-05-06T23:20:12.400 回答