在线程中使用Pyside6

Question

QT有一个有希望的SCXML模块。由于PYSCXML已过时，因此没有其他本机Python SCXML库，它使我可以运行SCXML statemachine。这就是为什么我尝试pyside6。

由于尽管有SCXML库，但我不需要任何QT，因此我考虑过在单独的线程中运行QCoreApplication，以便将事件循环放在那里。 根据文档，QSCXMLSTATATEMACHINE需要一个。

不幸的是，我的start_statemachine（）方法不会返回，但是statemachine开始工作。

欢迎有关如何在线程中启动QSCXMLSTATATEMACHINE的任何建议。

from PySide6.QtCore import QCoreApplication, QObject
from PySide6.QtScxml import QScxmlStateMachine
from PySide6.QtCore import QTimer
import threading


def start_statemachine(filename):
    app = QCoreApplication()
    mysm = MyStateMachine(filename)
    mysm.start_sm()
    app.exec()


class MyStateMachine(QObject):

    def __init__(self, filename):
        super(MyStateMachine, self).__init__()
        self.sm = QScxmlStateMachine.fromFile(filename)
        self.counter = 0
        self.timer = QTimer()
        self.timer.setInterval(2000)
        self.timer.timeout.connect(self.recurring_timer)
        self.timer.start()

    def start_sm(self):
        print('starting statemachine')
        self.sm.setRunning(True)

    def recurring_timer(self):
        print(self.sm.activeStateNames())
        self.counter += 1
        print("Counter: %d" % self.counter)
        print('statemachine running status: ' + str(self.sm.isRunning()))


if __name__ == '__main__':
    x = threading.Thread(target=start_statemachine('statemachine.scxml'))
    x.start() #won't be reached
    while True:
        pass #do something else
    x.join()

Answer 1

线程目标需要是参考 to在外部线程中会调用的函数，但是您在另一个线程中未运行start_statemachine（）实际将其执行到位：

x = threading.Thread(target=start_statemachine('statemachine.scxml'))
                                              ^^^^^^^^^^^^^^^^^^^^^^

您的程序被在内粘住，甚至没有创建线程，因为构造函数仍在“等待” start_statemachine（）返回，并且由于exec（）正在阻止，没有其他事情发生。

一个基本的解决方案可能是使用lambda：

x = threading.Thread(target=lambda: start_statemachine('statemachine.scxml'))

但是您需要访问该应用程序才能退出它：x.join（）不会无能为力，因为qcoreApplication事件循环将继续前进，因此有可能创建一个基本类，以提供对应用程序的参考：

class StateMachineWrapper:
    app = None
    def __init__(self, filename):
        self.filename = filename

    def start(self):
        self.app = QCoreApplication([])
        mysm = MyStateMachine(self.filename)
        mysm.start_sm()
        self.app.exec()

# ...

if __name__ == '__main__':
    statemachine = StateMachineWrapper('statemachine.scxml')
    x = threading.Thread(target=statemachine.start)
    x.start()
    while True:
        pass #do something else

    if statemachine.app:
        statemachine.app.quit()

    x.join()