PyQt5 - Сабақ 009. moveToThread көмегімен QThread пайдалану

moveToThread, QObject, QThread, PyQt5, Qt

Форумдағы сұрақтардың біріне сүйене отырып, мен PyQt5 жүйесінде QThread пайдалану мысалын жаздым, сондай-ақ, QObject класының мұраланған объектісін басқа ағынға жылжыту үшін moveToThread әдісін пайдалану.

Бұл мысалда мәтінді, сондай-ақ мәтіннің түсін сигнал арқылы негізгі графикалық интерфейске қайтаратын кейбір алгоритм орындалады. Бұл деректер QTextBrowser бағдарламасына түс параметрімен қосылады.

Бағдарлама келесідей болады

Кіріспе

Qt ішінде QThread пайдаланудың екі негізгі тәсілі бар:

1. QThread мұрагері болатын жаңа класс жасаңыз және іске қосу әдісін қайта анықтаңыз.
2. QObject мұрағатын жаңа класс жасаңыз, кейбір кодты орындайтын іске қосу әдісін жазыңыз және moveToThread әдісін пайдаланып осы класс данасын басқа ағынға жіберіңіз.

Бірінші әдіс тек ағын сыныбында арнайы функционалдылықты жасау үшін ағын сыныбын қайта анықтау қажет болған жағдайда ғана ұсынылады. Егер басқа ағында кейбір кодты орындау қажет болса, онда бұл үшін moveToThread әдісі арқылы басқа ағынға тасымалданатын бөлек класс жасау керек.

Сондай-ақ, GUI нысандарын басқа ағындарға жібере алмайтыныңызды бірден атап өткім келеді. Qt бағдарламаларында ағындардың екі түрі бар:

• Негізгі бағыт. Графикалық ағын
• Жұмыс процестері. Жұмыс процестері

Барлық GUI нысандары тек GUI ағынында жасалуы және іске қосылуы керек, ал басқа әртүрлі алгоритмдер жұмысшы ағындарында жұмыс істей алады.

құжаттамаға сілтеме

> Жоғарыда айтылғандай, іске қосу кезінде әрбір бағдарламаның бір ағыны болады. Бұл ағын «негізгі ағын» деп аталады (сонымен қатар Qt қолданбаларында «GUI ағыны» ретінде белгілі). Qt GUI осы ағында жұмыс істеуі керек. Барлық виджеттер және QPixmap сияқты бірнеше қатысты сыныптар қосымша ағындарда іске қосылмайды. Қосымша жіп әдетте «жұмысшы жіп» деп аталады, себебі ол негізгі ағыннан өңдеуді түсіру үшін қолданылады.

Яғни, егер сіз үшін басқа жіпте бірдеңе жұмыс істесе де, бұл ерте ме, кеш пе өзін сезінетін апат болады. Ал сіздің бағдарламаңыз жұмысын тоқтатады. Басқа GUI нысандарын басқа ағындарға ешқашан жібермеңіз.

Бағдарлама

Енді бағдарлама кодымызды қарастырайық. Әрекеттер алгоритмі келесідей болатынын ескеріңіз

1. Біз QObject мұрағатын және басқа ағындағы кодты орындау үшін іске қосу әдісі бар класс жазамыз
2. Терезе конструкторында ағын нысанын жасаңыз
3. Терезе конструкторында басқа ағынға берілетін нысанды жасаңыз
4. Объектіні басқа ағынға ауыстырыңыз
5. Сигналдарды және ұяшықтарды қосыңыз
6. Жіпті іске қосыңыз

Егер сізде жеткілікті тәжірибе болмаса, барлық нысанды және ағынды инициализациялауды осы ретпен орындаған жөн.
Дегенмен, сіз бұл мақаланы оқымайсыз.
4 және 5-қадамдарды ауыстырсаңыз, алдымен сигналдар мен ұяшықтарды қосасыз, содан кейін нысанды сигнал/слот қосылымын үзетін басқа ағынға тасымалдайсыз. Қолданба терезесі жұмысын тоқтатады. Немесе қолданба жай ғана істен шығуы мүмкін.

import sys
import time

from PyQt5 import QtCore, QtWidgets
from PyQt5.QtGui import QColor


class Ui_Form(object):
    def setupUi(self, Form):
        Form.setObjectName("Form")
        Form.resize(453, 408)
        self.verticalLayout = QtWidgets.QVBoxLayout(Form)
        self.verticalLayout.setObjectName("verticalLayout")
        self.verticalLayout_2 = QtWidgets.QVBoxLayout()
        self.verticalLayout_2.setObjectName("verticalLayout_2")
        self.textBrowser = QtWidgets.QTextBrowser(Form)
        self.textBrowser.setObjectName("textBrowser")
        self.verticalLayout_2.addWidget(self.textBrowser)
        self.verticalLayout.addLayout(self.verticalLayout_2)
        self.horizontalLayout = QtWidgets.QHBoxLayout()
        self.horizontalLayout.setObjectName("horizontalLayout")
        spacerItem = QtWidgets.QSpacerItem(40, 20, QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Minimum)
        self.horizontalLayout.addItem(spacerItem)
        self.pushButton = QtWidgets.QPushButton(Form)
        self.pushButton.setObjectName("pushButton")
        self.horizontalLayout.addWidget(self.pushButton)
        spacerItem1 = QtWidgets.QSpacerItem(40, 20, QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Minimum)
        self.horizontalLayout.addItem(spacerItem1)
        self.verticalLayout.addLayout(self.horizontalLayout)

        self.retranslateUi(Form)
        QtCore.QMetaObject.connectSlotsByName(Form)

    def retranslateUi(self, Form):
        _translate = QtCore.QCoreApplication.translate
        Form.setWindowTitle(_translate("Form", "Example"))
        self.pushButton.setText(_translate("Form", "Input"))


# Object, which will be moved to another thread
class BrowserHandler(QtCore.QObject):
    running = False
    newTextAndColor = QtCore.pyqtSignal(str, object)

    # method which will execute algorithm in another thread
    def run(self):
        while True:
            # send signal with new text and color from aonther thread
            self.newTextAndColor.emit(
                '{} - thread 2 variant 1.\n'.format(str(time.strftime("%Y-%m-%d-%H.%M.%S", time.localtime()))),
                QColor(0, 0, 255)
            )
            QtCore.QThread.msleep(1000)

            # send signal with new text and color from aonther thread
            self.newTextAndColor.emit(
                '{} - thread 2 variant 2.\n'.format(str(time.strftime("%Y-%m-%d-%H.%M.%S", time.localtime()))),
                QColor(255, 0, 0)
            )
            QtCore.QThread.msleep(1000)


class MyWindow(QtWidgets.QWidget):

    def __init__(self, parent=None):
        super().__init__()
        self.ui = Ui_Form()
        self.ui.setupUi(self)
        # use button to invoke slot with another text and color
        self.ui.pushButton.clicked.connect(self.addAnotherTextAndColor)

        # create thread
        self.thread = QtCore.QThread()
        # create object which will be moved to another thread
        self.browserHandler = BrowserHandler()
        # move object to another thread
        self.browserHandler.moveToThread(self.thread)
        # after that, we can connect signals from this object to slot in GUI thread
        self.browserHandler.newTextAndColor.connect(self.addNewTextAndColor)
        # connect started signal to run method of object in another thread
        self.thread.started.connect(self.browserHandler.run)
        # start thread
        self.thread.start()

    @QtCore.pyqtSlot(str, object)
    def addNewTextAndColor(self, string, color):
        self.ui.textBrowser.setTextColor(color)
        self.ui.textBrowser.append(string)

    def addAnotherTextAndColor(self):
        self.ui.textBrowser.setTextColor(QColor(0, 255, 0))
        self.ui.textBrowser.append('{} - thread 2 variant 3.\n'.format(str(time.strftime("%Y-%m-%d-%H.%M.%S", time.localtime()))))


if __name__ == '__main__':
    app = QtWidgets.QApplication(sys.argv)
    window = MyWindow()
    window.show()
    sys.exit(app.exec())