526互联

Python PyQt5 开启线程避免界面卡死闪退

发布时间 2023-06-21 14:35:02作者: Himmelbleu

Python PyQt5 的界面是主线程执行的，如果主线程执行了耗时操作，会导致主线程阻塞使得界面卡死闪退。所以，对于一个耗时操作需要开启一个线程执行。

首先导入几个包：

from PyQt5 import QtCore
from PyQt5.QtCore import *

创建一个线程类：

class ListDevicesThread(QtCore.QThread):
    signal = pyqtSignal(dict, name='list_devices')

    def run(self):
        while True:
            devices_list = apis.list_devices()
            self.signal.emit(devices_list)
            time.sleep(5)

这个线程每隔 5 秒执行一次获取数据的操作。并通过 emit 把数据发送到主界面中。所以，主界面要获取这个值就需要通过回调函数接收：

class Window(QWidget, Ui_Form):
    def __init__(self):
        super().__init__()
        self.setupUi(self)

        # 获取设备列表
        self.list_shadow_thread = ListDevicesThread()
        self.list_shadow_thread.signal.connect(self.after_list_devices)
        self.list_shadow_thread.start()
  1. 创建 ListDevicesThread 线程对象，将对象设置到类成员变量中（如果不设置，或者设置重复的线程变量名，要么让线程无法执行，要么主界面卡死，不能运行程序）。
  2. self.list_shadow_thread.signal.connect(self.after_list_devices) 这个代码的意思是，得到线程对象的信号对象，连接到主界面的 after_list_devices 函数，这个函数就是回调函数，可以接收到 emit 函数发送过来的数据，数据类型在线程中定义（可以是 str、dict 等合法的 py 类型）。
  3. 第三步就是开启线程并执行。

在线程获取到一次数据之后，执行下面的回调函数，回调函数收到数据 data，可以进行一些不需要耗时的操作，如果之后还有耗时的操作建议一次性在线程执行完成再到这个回调函数中来：

def after_list_devices(self, data):
        row = 0
        self.tableWidget.setRowCount(data['page']['count'])
        for item in data['devices']:
            self.setTableItem(row, 0, item['device_id'])
            self.setTableItem(row, 1, item['device_name'])
            self.setTableItem(row, 2, item['product_name'])
            self.setTableItem(row, 3, item['status'])
            self.setTableItem(row, 4, item['description'])
            row += 1

到目前为止，上面都是线程执行完成之后获取数据发送给主线程（主界面），是 线程->主线程 的过程。有时候，主线程的一些输入框里面的值需要发送给线程，让线程得到输入框内的值再执行下一步操作。这个是 主线程->线程->主线程 的过程。

首先，在线程中创建一个设置值的函数，如 set_xxx 这样的格式：

class QueryDeviceThread(QtCore.QThread):
    signal = pyqtSignal(dict, name='query_device')
    device_id = ''

    def set_device_id(self, device_id):
        self.device_id = device_id

    def run(self):
        device = apis.query_device(self.device_id)
        self.signal.emit(device)

device_id 是线程的类成员变量，通过 set_device_id 函数给 device_id 设置新的值。在 run 函数执行的时候，获取到 device_id 值，这个值要在主界面开启线程之前设置好。

点击界面的按钮之后触发下面的函数，在开启线程之前，且线程对象创建之后，设置线程的类成员变量。

def query_device(self):
    self.query_device_thread = QueryDeviceThread()
    self.query_device_thread.set_device_id(self.input_query_device_id.text())
    self.query_device_thread.signal.connect(self.after_query_device)
    self.query_device_thread.start()