c
18 ноября 2019 г. 5:21

PyQt5 QThread периодическая проверка доступности соединения MySql в отдельном потоке

QThread

Здравствуйте форумчане.
Собственно решил побаловаться с потоками в PyQt5. Придумал небольшую учебную задачку для себя по данной теме.
Форма авторизации для MySql. Всё стандартно: user - password в QLineEdit, кнопки "connect", "disconnect" и QLabel сообщающая о статусе соединения. Форма должна проверять возможность соединения с сервером 1 раз в 3 секунды. Для этого я в метод run() класса QThread поместил соединение с БД.

#!/usr/bin/python3
# -*- coding:utf-8 -*-

import sys
import UI_MainForm
from PyQt5.QtWidgets import *
from PyQt5.QtGui import *
from PyQt5.QtCore import *
from PyQt5.QtSql import *


class MyThread(QThread):
    mysignal = pyqtSignal(str)

    def __init__(self, _user=None, _passwd=None, parent=None):
        self.user = _user
        self.passwd = _passwd
        QThread.__init__(self, parent)

    def run(self):
        while True:
            self.sleep(3)
            db = QSqlDatabase.addDatabase('QMYSQL')
            db.setHostName('localhost')
            db.setDatabaseName('testbase')
            db.setUserName(self.user)
            db.setPassword(self.passwd)
            ok = db.open()
            if ok:
                self.mysignal.emit('ok')
                print('Debug: Connection: Ok')
                db.close()
            else:
                self.mysignal.emit('failed')
                print('Debug: Connection: Failed ' + db.lastError().text())


class MainForm(QMainWindow, UI_MainForm.Ui_MainWindow):
    def __init__(self):
        QMainWindow.__init__(self)
        self.setupUi(self)

        self.mythread = MyThread()

        self.pushButton_quit.clicked.connect(qApp.quit)
        self.pushButton_connect.clicked.connect(self.connect_db)
        self.pushButton_disconnect.clicked.connect(self.disconnect_db)
        self.pushButton_connect.clicked.connect(self.start_thread)
        self.mythread.mysignal.connect(self.change_label_conn_status, Qt.QueuedConnection)

    def connect_db(self):
        db = QSqlDatabase.addDatabase('QMYSQL')
        db.setHostName('localhost')
        db.setDatabaseName('testbase')
        db.setUserName(self.lineEdit_user.text())
        db.setPassword(self.lineEdit_passwd.text())
        ok = db.open()
        if ok:
            self.label_connection_status.setText('Connection status: Ok')
            QMessageBox.information(self, 'Information', 'Successful database connection')
        else:
            self.label_connection_status.setText('Connection status: Failed')
            QMessageBox.critical(self, 'ERROR!', 'No database connection!')

    def disconnect_db(self):
        self.pushButton_connect.setEnabled(True)
        self.lineEdit_user.setEnabled(True)
        self.lineEdit_passwd.setEnabled(True)
        self.lineEdit_user.clear()
        self.lineEdit_passwd.clear()
        self.lineEdit_user.setFocus()

    def change_label_conn_status(self, s):
        self.label_connection_status.setText('Connection status: ' + s)    #текст не меняется

    def start_thread(self):
        self.pushButton_connect.setEnabled(False)
        self.lineEdit_user.setEnabled(False)
        self.lineEdit_passwd.setEnabled(False)
        self.mythread = MyThread(self.lineEdit_user.text(), self.lineEdit_passwd.text())
        self.mythread.start()


if __name__ == '__main__':
    app = QApplication(sys.argv)
    win = MainForm()
    win.show()
    sys.exit(app.exec_())

Собственно проблемы:
1. При дауне MySql, label_connection_status не изменяется на "failed", хотя в консоль метод run() гадит print('Debug: Connection: Failed ' + db.lastError().text()), как и было задумано. Почему?
2. Два потока (в конструкторе и в методе start_thread) - бред. Как избавиться от этого бреда? Как сделать правильно?
3. Может быть можно как-то иначе реализовать проверку доступности MySql для соединения?

Заранее благодарю.

Рекомендуем хостинг TIMEWEB
Рекомендуем хостинг TIMEWEB
Стабильный хостинг, на котором располагается социальная сеть EVILEG. Для проектов на Django рекомендуем VDS хостинг.
15
c

Вроде бы "пофиксил", но буду рад любым замечаниям по этому говнокоду)))

#!/usr/bin/python3
# -*- coding:utf-8 -*-

import sys
import UI_MainForm
from PyQt5.QtWidgets import *
from PyQt5.QtGui import *
from PyQt5.QtCore import *
from PyQt5.QtSql import *


class MyThread(QThread):
    mysignal = pyqtSignal(str)

    def __init__(self, _user=None, _passwd=None, parent=None):
        self.user = _user
        self.passwd = _passwd
        QThread.__init__(self, parent)

    def run(self):
        while True:
            self.sleep(3)
            db = QSqlDatabase.addDatabase('QMYSQL')
            db.setHostName('localhost')
            db.setDatabaseName('testbase')
            db.setUserName(self.user)
            db.setPassword(self.passwd)
            ok = db.open()
            if ok:
                self.mysignal.emit('Ok')
                print('Debug: Connection: Ok')
                db.close()
            else:
                self.mysignal.emit('Failed')
                print('Debug: Connection: Failed ' + db.lastError().text())


class MainForm(QMainWindow, UI_MainForm.Ui_MainWindow):
    def __init__(self):
        QMainWindow.__init__(self)
        self.setupUi(self)

        self.pushButton_quit.clicked.connect(qApp.quit)
        self.pushButton_connect.clicked.connect(self.connect_db)
        self.pushButton_disconnect.clicked.connect(self.disconnect_db)
        self.pushButton_connect.clicked.connect(self.start_thread)

    def connect_db(self):
        db = QSqlDatabase.addDatabase('QMYSQL')
        db.setHostName('localhost')
        db.setDatabaseName('testbase')
        db.setUserName(self.lineEdit_user.text())
        db.setPassword(self.lineEdit_passwd.text())
        ok = db.open()
        if ok:
            self.label_connection_status.setText('Connection status: Ok')
            QMessageBox.information(self, 'Information', 'Successful database connection')
        else:
            self.label_connection_status.setText('Connection status: Failed')
            QMessageBox.critical(self, 'ERROR!', 'No database connection!')

    def disconnect_db(self):
        self.pushButton_connect.setEnabled(True)
        self.lineEdit_user.setEnabled(True)
        self.lineEdit_passwd.setEnabled(True)
        self.lineEdit_user.clear()
        self.lineEdit_passwd.clear()
        self.lineEdit_user.setFocus()

    def change_label_conn_status(self, s):
        self.label_connection_status.setText('Connection status: ' + s)

    def start_thread(self):
        self.pushButton_connect.setEnabled(False)
        self.lineEdit_user.setEnabled(False)
        self.lineEdit_passwd.setEnabled(False)
        self.mythread = MyThread(self.lineEdit_user.text(), self.lineEdit_passwd.text())
        self.mythread.mysignal.connect(self.change_label_conn_status, Qt.QueuedConnection)
        self.mythread.start()


if __name__ == '__main__':
    app = QApplication(sys.argv)
    win = MainForm()
    win.show()
    sys.exit(app.exec_())
B
  • 19 ноября 2019 г. 4:33

Я не знаю правильно ли я делаю, но я сигнал для потока не создаю,
я в поток передаю ссылку на то куда надо результат выводить/изменить, у меня в основном текстовое поле и я туда передаю кучу информации из потока в разных цветах и т.д.
Я в поток много чего передаю, даже ссылку на соединение UDP, созданное в основном приложении и работает отлично, т.е. из потока проверяет и шлет что то и т.д.
Следует отметить у меня в основном поток один, кроме основной формы, когда два и более и если пересекаются я делаю флаги занятости ресурса к которому обращаются сразу несколько потоков, к примеру список, по очереди пускаю туда складывать данные потоков, привязываю очередность к времени вызова.

Где бы на примерах посмотреть как правильно потоками рулить???
Примеры какие то везде примитивные.
А то сам что то фантазирую...

c

Я штудирую небезизвестную книгу Прохорёнка и Дронова.
Будьте добры скинуть один-два примера с передачей ссылок в поток. Очень интересно. Заранее благодарю.

B
  • 19 ноября 2019 г. 4:57

у меня эта книга то же есть про потоки там мизер совершенно, примеры сегодня накидаю вечером, попробуйте в вашем примере в конструкторе потока принять ссылку на label, и в потоке все Print отправляйте в нее. При создании потока передайте ему созданную label, без всяких сигналов.

label - это GUI элемент в данном случае? Если так, то я бы не стал раскидывать GUI элементы в разные потоки. Дело в том, что в документации на Qt, сказано, что GUI элементы работают только в GUI-потоке и не работают в других потоках. Цитирую

As mentioned, each program has one thread when it is started. This thread is called the "main thread" (also known as the "GUI thread" in Qt applications). The Qt GUI must run in this thread. All widgets and several related classes, for example QPixmap, don't work in secondary threads. A secondary thread is commonly referred to as a "worker thread" because it is used to offload processing work from the main thread.

То, что иногда GUI элементы работают в других потоках - это скорее "счастливая случайность", которая рано или поздно перестанет работать. При наличии код-ревью такой код никогда не должен проходить в продакшн. Нет. Не так. Такой код никогда не должен проходить в продакшн ни при каких условиях.

B
  • 19 ноября 2019 г. 6:24

Вот плохо что у дронова не приводится таких выдержек..
Ну все вроде правильно написанно, все виджеты в основном потоке у меня и создаются,
я лишь передаю ссылку во вторичный поток что бы тот имел возможность изменять параметры виждета в основном потоке, а не создаю его (виджет) во вторичном потоке.

The Qt GUI must run in this thread. All widgets and several related classes, for example QPixmap, don't work in secondary threads. (Все виджеты и несколько связанных классов, например, QPixmap, не работают во вторичных потоках.)
Они деествительно не создаются даже, не то что не работают, я пробовал во вторичном потоке создать виджет с полями ввода и т.д., у меня ничего не получилось, мудохался день. И я сейчас с вашей помощью я знаю почему.
Т.е. все виджеты создаются только в основном потоке, и если мне вдруг стукнуло в голову что то добавить, я должен перегрузить основной поток с изменениями,
а не создавать вторичный и т.д.

У меня текстовое поле textBrowser работает в основном потоке вместе с формой (с кучей кнопок и т.д.). В основной форме/потоке я создаю соединения с XML-PRC сервером, передаю/принимаю ему некоторую информацию, и все состояния и подтверждения передаются в textBrowser основного потока.

Далее я создаю соединение/клиента UDP в основном потоке, и передаю его ссылку и ссылку на textBrowser с некоторыми другими переменными(флагами) во вторичный поток. И этот поток самостоятельно крутиться в режиме демона и передает состояние работы в текстовой форме по ссылке в textBrowser основного потока и я меняю по ссылке параметры выводимого текста. Т.е. textBrowser не работает во вторичном потоке, во вторичном потоке у него только ссылка на textBrowser. А еще у меня может работать третий поток пингующий IP + potr и то же принимающий ссылку на textBrowser основного потока и он туда шлет информацию о состоянии работы.

Или я не так понял?

Смотрите, думаю, что главная ваша ошибка состоит в том, что вы передаёте ссылку на textBrowser в другой поток. Когда вы выполняете передачу GUI объекта в другой поток, то вы рушите очередь событий, которая работает в основном потоке. Думаю, что поэтому GUI виджеты не следует передавать в другие потоки.

Вы можете передать в другой поток какой-то класс, наследованный от QObject, например ваш XML-PRC сервер. А всю дальнейшую коммуникацию настроить через сигналы слоты. То есть, если что-то выполнилось в сервере, то с помощью сигнала высылаете информацию об этом в форму, где есть принимающий слот, и уже в этом слоте делайте что хотите с QLabel.

То есть не держите ссылку в другом потоке. Тем более, что вы не пояснили, какой именно механизм вы используете для передачи ссылки в другой поток. Для меня это утверждение ничего не означает в данном случае, поскольку у Qt есть несколько механизмов создания потоков, а при передачи ссылки может измениться право владения объектом в потоке, что как раз и порушит работу GUI системы.

B
  • 19 ноября 2019 г. 7:01

Мехонизм передачи простой, имя textBrowser в конструктор потока, все...
я сразу закинул и все, в сторону сигналов не смотрел, т.к.
в примерах по потокам говорилось в основном о проблемах доступа к общим ресурсам по ссылкам, т.е. если важна
очередность некая то надо организовывать..

Вообще этот textBrowser мне важен только для отладки наладчику, отключу пока сигналы не прикручу, включу лог для потока.

Но конечно по сигналам если мне красиво надо разными цветами, шрифтами это еще тот велосипед наверное....

Мехонизм передачи простой, имя textBrowser в конструктор потока, все...

Код лучше покажите, а то на словах всё всегда хорошо

Но конечно по сигналам если мне красиво надо разными цветами, шрифтами это еще тот велосипед наверное....

А зачем тогда вообще Qt использовать, если не пользоваться сигналами? Кроссплатформенность только? Вы себя очень ограничите, если не пользоваться сигналами и слотами, это его главное преимущество.

B
  • 19 ноября 2019 г. 7:17

Кода много лишнего, я лишнее выкину вечером

Ну тогда создайте, пожалуйста, потом новую тему на форуме с тем кодом, а то мы с вами в оффтоп ушли, здесь немного не о том было обсуждение.

пробежав глазами по топику, что хочу сказать(в питоне не сильно силен) - создание потока через метод run() давненько считается не корректным. более правильная работа с потоками считается когда создается обьект класа и переносится в другой поток
*.h

#include <QThread>
#include <worker.h> //клас который хотим поместить в поток

class Base : public QObject
{
    Q_OBJECT
public:
    explicit Base(QObject *parent=nullptr);
    ~Base();
public slots:

private:
    Worker *work;
    QThread *thr_work;
};

*.cpp:

#include "base.h"
Base::Base(QObject *parent) : QObject(parent)
{
    work=new Warker;
    thr_work=new QThread(this);
    work->moveToThread(thr_work);

    thr_work->start();
    connect(work,&Worker::signal,this,&Base::slot);
    connect(this,&Base::destroyed,thr_work,&QThread::quit);
}

А в самом классе Worker делаете все что вам нужно, например по сигрналу старта потока

B
  • 20 ноября 2019 г. 4:23

В питоне либо метод отдельно запускаем в потоке, либо наследуемся от Thread и там обязательно run переопределяем, да и в Java тоже самое run

В питоне тоже должен быть метод moveToThread у класса QThread, его и нужно использовать.

Java сюда не притягивайте за уши, это абсолютно другая платформа и другой язык.

Переопределение метода run у класса QThread при использовании Qt фреймворка уже давно считается некорректным, и сами разработчики Qt придерживаются этого же мнения и не рекомендуют наследование от QThread с переопределением метода run для обычного запуска какого-нибудь алгоритма в отдельном потоке.

Переопределение метода run должно выполняться в том случае, если вы хотите изменить поведение класса QThread, то есть создать свой кастомизированный класс потока, а для выполнения алгоритма в отдельном потоке следует использовать метод moveToThread. В противном случае всегда вылезают какие-нибудь грабли.

B
  • 20 ноября 2019 г. 4:46

спасибо принял, поищу примеры

Комментарии

Только авторизованные пользователи могут публиковать комментарии.
Пожалуйста, авторизуйтесь или зарегистрируйтесь
Donate

Здравствуйте, уважаемые пользователи EVILEG !!!

Если сайт вам помог, то поддержите разработку сайта финансово, пожалуйста.

Вы можете сделать это следующими способами:

Спасибо, Евгений Легоцкой

СБ
5 декабря 2019 г. 8:01
Сергей Бедерин

C++ - Тест 001. Первая программа и типы данных

  • Результат:60баллов,
  • Очки рейтинга-1
АС
4 декабря 2019 г. 6:39
Артур Салмин

C++ - Тест 005. Структуры и Классы

  • Результат:33баллов,
  • Очки рейтинга-10
СТ
2 декабря 2019 г. 16:05
Сергей Тимченко

Qt - Тест 001. Сигналы и слоты

  • Результат:68баллов,
  • Очки рейтинга-1
Последние комментарии
6 декабря 2019 г. 12:47
Евгений Легоцкой

я подумал насчёт debug/release, но мне показалось - это сильно очевидным )))) Насчёт cmake согласен - он лучше
r
6 декабря 2019 г. 12:46
romankoshelev

С cmake разобрался. Всетаки писать на нем сильно проще. С размером dll тоже разобрался. windeployqt надо давать флаг --release (тогда библиотеки в 20 раз меньше)
6 декабря 2019 г. 12:40
Евгений Легоцкой

Конечно, хорошо бы это дело и на cmake сделать, но если честно, в задачах у меня такого нет, а делать специально только это сейчас времени тоже не хватает. увы. А что касается гигабайта Qt…
r
6 декабря 2019 г. 11:37
romankoshelev

А что сделать чтоб qt не тащило весь свой гигабайт в инсталлер?
Сейчас обсуждают на форуме
6 декабря 2019 г. 7:10
qml_puthon_user

Доброго времени суток. Пытаюсь сделать отображение с веб-камеры в графическом интерфейсе написанном на qml. Код программы: #системные библиотекиimport cv2import numpy as npimport…
5 декабря 2019 г. 16:12
Евгений Легоцкой

Это уже кастомная стилизация. Придётся отключать обрамление и самостоятельно реализовывать ресайз окна, его перемещение, стиль и т.д. Вот статья, как отключить обрамление окна - QML …
5 декабря 2019 г. 4:27
qml_puthon_user

Вот код, вдруг, кому поможет. Код основной формы: import QtQuick 2.12import QtQuick.Controls 2.12import QtQuick.Layouts 1.3import "./Components/Panels" as PanelsApplicationWindow{…
5 декабря 2019 г. 2:50
Евгений Легоцкой

Создавайте новые темы, чтобы не было всё в куче.
4 декабря 2019 г. 22:07
qml_puthon_user

Спасибо за помощь! :) Я попытаю надежды в ожидании QtQuick3D от Riverbank'a. :)
EVILEG
О нас
Услуги
© EVILEG 2015-2019
Рекомендует хостинг TIMEWEB