python - PyQt - Main 挂在 QThread
问题描述
我有一个连接到 CG 服务器 (CasparCG) 的 Python QT 应用程序。QT 应用程序触发一个 QThread,它使用模块pynput监听热键- 并向 CasparCG 发送一个命令,以便为每个按下的键播放不同的视频文件。
在主 GUI 中,我可以将视频文件分配给热键列表,并从子菜单项触发热键侦听线程。
self.actionStart_Hotkeys = QtWidgets.QAction(MainWindow)
self.menuCasparCG.addAction(self.actionStart_Hotkeys)
self.actionStart_Hotkeys.triggered.connect(self.StartHotkeys)
主应用程序和 Ui_Window 代码很长,没有任何问题 - 它的功能应有尽有。当通过按键激活热键时,视频也会像我预期的那样播放,但是在播放几个视频文件后应用程序的主窗口会冻结 - 我不确定为什么主 GUI 在热键之后没有响应输入线程已启动。
到目前为止的代码看起来像这样..
from pynput import keyboard
class HotKeys(QThread):
def __init__(self, parent):
QThread.__init__(self, parent)
self.COMBINATIONS = [
{keyboard.KeyCode(char='0')},
{keyboard.KeyCode(char='1')},
{keyboard.KeyCode(char='2')},
{keyboard.KeyCode(char='3')},
]
self.caspar = None
self.current = set()
self.Connect()
self.Listen()
def exit(self, i):
if not self.caspar == None:
self.caspar.close
sys.exit(i)
def Connect(self):
try:
self.caspar = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.caspar.connect(("127.0.0.1", 5250))
print("Connected to caspar")
except socket.error:
print("CasparCG not running, or incorrect settings.xml")
self.exit(0)
def execute(self, k=None): # k is videofile
movie = bytes("PLAY 1-20 {} \r\n".format(k), 'utf8')
self.caspar.send(movie)
def on_press(self, key):
if any([key in COMBO for COMBO in self.COMBINATIONS]):
self.current.add(key)
if any(all(k in self.current for k in COMBO) for COMBO in self.COMBINATIONS):
self.execute(key)
def on_release(self, key):
if any([key in COMBO for COMBO in self.COMBINATIONS]):
self.current.remove(key)
def Listen(self):
with keyboard.Listener(on_press=self.on_press, on_release=self.on_release) as listener:
listener.join()
我像这样在应用程序的主类中触发这个热键 QThread ......
class Main(QMainWindow, Ui_MainWindow):
def __init__(self):
QMainWindow.__init__(self)
self.setupUi(self) # from Ui_MainWindow class
def StartHotkeys(self):
hotkey_thread = HotKeys(self)
hotkey_thread.start()
和这样的应用程序......
if __name__ == "__main__":
import sys
app = QtWidgets.QApplication(sys.argv)
gui = Main()
gui.show()
sys.exit(app.exec_())
那么为什么 Main 会冻结?
解决方案
QThread
不是线程,它是线程处理程序,如果要在另一个线程中执行任务,则必须在run()
方法中执行,该方法是在另一个线程中执行的唯一部分。在您的情况下,Listen()
任务被阻塞并且您在构造函数中调用它,并且QThread
构造函数在 GUI 线程中运行,这就是您的 GUI 冻结的原因。解决方法是移动 Connect 和 Listen 的run()
方法:
class HotKeys(QThread):
def __init__(self, parent=None):
QThread.__init__(self, parent)
self.COMBINATIONS = [
{keyboard.KeyCode(char='0')},
{keyboard.KeyCode(char='1')},
{keyboard.KeyCode(char='2')},
{keyboard.KeyCode(char='3')},
]
self.caspar = None
self.current = set()
def run(self):
self.Connect()
self.Listen()
def exit(self, i):
if self.caspar:
self.caspar.close()
sys.exit(i)
def Connect(self):
try:
self.caspar = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.caspar.connect(("127.0.0.1", 10000))
print("Connected to caspar")
except socket.error:
print("CasparCG not running, or incorrect settings.xml")
self.exit(0)
def execute(self, k=None): # k is videofile
if self.caspar:
movie = bytes("PLAY 1-20 {} \r\n".format(k), 'utf8')
self.caspar.send(movie)
def on_press(self, key):
if any([key in COMBO for COMBO in self.COMBINATIONS]):
self.current.add(key)
if any(all(k in self.current for k in COMBO) for COMBO in self.COMBINATIONS):
self.execute(key)
def on_release(self, key):
if any([key in COMBO for COMBO in self.COMBINATIONS]):
self.current.remove(key)
def Listen(self):
with keyboard.Listener(on_press=self.on_press, on_release=self.on_release) as listener:
listener.join()
推荐阅读
- c++ - 包含 std::threads 的元素向量
- image - Docker compose elk stack 配置文件更新不起作用
- javascript - HTML/js 代码中的 JQuery 上下文菜单
- python - 如何从 cv2.imread 获取 PIL.Image 对象?“无法识别的图像模式”错误
- php - 在 null 上调用成员函数 rating() - laravel
- php - 与规范键组合后如何对数组进行排序是php中的名称和值的字母顺序
- java - Spring:数组属性的默认值
- google-chrome - 无法清除浏览器缓存
- java - 在休眠条件中使用 sum
- opencv - 如何使用 protobuf 序列化 cv::Mat 对象?