Как правильно остановить поток QThread?

Question

[pypyshka]

Добрый день.

Имеется программка, написана на Python 3.4.4 с использованием PyQt 4.11.4, которая парсит сайт каждые 10 минут. При запуске программы проверяется подключение к сайту check_connect(): если доступ есть, то status_connect = 1 и запускается поток. Каждые 10 минут также происходит проверка подключения к сайту. Проблема в том, что, если сайт через некоторое время станет недоступным и сработает функция get_docs(sc), то программа просто вылетит. Я так понял это происходит по той причине, что поток продолжает работать и нужно его остановить или завершить. Я пробовал в исключения TimeoutError и ConnectionError добавлять check_docs.exit(). Может быть причина совсем не в потоке. Посоветуйте, пожалуйста, что можно сделать в таком случае?

def check_connect():
    global status_connect
    try:
        UTM_connect = HTTPConnection("test.ru")
        UTM_connect.request("GET", "/")
        UTM_connect.close()
    except TimeoutError:
        status_connect = 0
    except ConnectionError:
        status_connect = 0       
    else:
        status_connect = 1

def get_docs(sc):
    check_connect()
    if status_connect == 1:
        '''
        парсинг сайта

        '''
       s.enter(600, 1, get_docs, (sc,))

class check_docs_cl(QtCore.QThread):
    def __init__(self, parent = None):
        QtCore.QThread.__init__(self, parent)
    
    def run(self):
        global s       
        s = sched.scheduler(time.time, time.sleep)
        s.enter(10, 1, get_docs, (s,))
        s.run()

class main_cl(QtGui.QMainWindow):
    def __init__(self):
        super().__init__()         
            uic.loadUi("main.ui", self)       

if __name__ == "__main__":
    app = QtGui.QApplication(sys.argv)
    main_window = main_cl()
    check_docs =  check_docs_cl()
    check_connect()
    if status_connect == 1:
        check_docs.start()
    sys.exit(app.exec_())

Answer 1

[Sergey6661313]

*учительским тоном:
Ежели check_docs выполняется один раз, и функции в нём работают исключительно с глобальными переменными, и содержит он всего лишь одну функцию, и вы запускаете в нём другой поток (sched.scheduler) нафига вам тогда вообще QThread??? да и вообще зачем в нутри get_docs пытаться перезапустить таймер который его вызвал? ведь ваш get_docs так и останется в стеке памяти а через ебалион циклов он просто выведет ошибка рекурсии, потому что будет бесконечно ожидать когда же комманды в цикле комманд (s.enter -> s.enter -> s.enter -> s.enter и т.д.) вдруг закончатся... И почему бы вам не написать нам вывод вашей ошибки в консоль?

*обычным голосом:
ладно теперь серьёзно - раз уж используете pyqt то используйте на всю катушку!:

class МойПервыйТаймерНаQt(QtCore.QObject):
    def __init__(self):
        super().__init__()
        self.basictimer = QtCore.QBasicTimer()
        self.basictimer.start(2000, self) # задержка в миллисекундах. 2000 для примера потому что 10 сек мне долго.

    def timerEvent(self, QTimerEvent):
        get_docs(self)  # вы конечно можете создать обьект sched.scheduler и передавать его, но зачем?


if __name__ == "__main__":
    app = QtGui.QApplication(sys.argv)
    main_window = main_cl()
    мой_первый_таймер_на_Qt = МойПервыйТаймерНаQt()
    sys.exit(app.exec_())

и уберите строчку "s.enter(600, 1, get_docs, (sc,))" из get_docs

Comments

[pypyshka]

Спасибо за ответ! Я использовал QThread, чтобы не зависал интерфейс программы. С помощью вашего совета, я попробовал вызвать функцию в потоке по таймеру:

def check_connect():
    global status_connect
    try:
        UTM_connect = HTTPConnection("test.ru")
        UTM_connect.request("GET", "/")
        UTM_connect.close()
    except ConnectionRefusedError:
        status_connect = 0
    except TimeoutError:
        status_connect = 0
    except ConnectionError:
        status_connect = 0       
    else:
        status_connect = 1

class check_docs_cl(QtCore.QThread):
    def __init__(self, parent = None):
        QtCore.QThread.__init__(self, parent)
    
    def run(self):
        check_connect()
        if status_connect == 1:
            '''парсинг сайта'''

class docsTimer(QtCore.QObject):
    def __init__(self):
        QtCore.QObject.__init__(self)
        self.basictimer = QtCore.QBasicTimer()
        self.basictimer.start(10000, self)

    def timerEvent(self, QTimerEvent):
        check_docs.start()

class main_cl(QtGui.QMainWindow):
    def __init__(self):
        super().__init__()         
            uic.loadUi("main.ui", self)       

if __name__ == "__main__":
    app = QtGui.QApplication(sys.argv)
    main_window = main_cl()
    check_docs = check_docs_cl()
    check_connect()
    if status_connect == 1:
        docs_timer = docsTimer()
    sys.exit(app.exec_())

Скажите, пожалуйста, правильна ли такая реализация?
По поводу ошибки: оказалось исключение ConnectionRefusedError, мне удалось его обработать, чтобы программа не крашилась, если сайт становился недоступным.

[Sergey6661313]

pypyshka: вот это уже выглядит гораздо лучше! вообще по поводу правильно или не правильно тут уж я не сильно помощник у меня только 2 года практики... но я бы лично посоветовал с целью минимизации кода перенести метод timerEvent прямо в class check_docs_cl. (благо QThread унаследован от QObject).
Не знаю почему, но python сообщество недолюбливает глобальные переменные. Поэтому если переменная status_connect нигде более не используется - поменять функцию check_connect на неё же, но возвращающую bool значение.

def check_connect():
    global status_connect
    try:
        UTM_connect = HTTPConnection("ya.ru")
        UTM_connect.request("GET", "/")
        UTM_connect.close()
    except Exception as e:
        print("сайт кажется не отвечает, ошибка: \"" + str(e.args[1]) + "\"") # давайте сделаем красиво :)
        return False
    else:
        return True


class check_docs_cl(QtCore.QThread):
    def __init__(self, parent=None):
        super().__init__(parent)
        self.basictimer = QtCore.QBasicTimer()
        self.basictimer.start(2000, self)

    def run(self):
        if check_connect():
            print("парсинг сайта")

    def timerEvent(self, QTimerEvent):
        self.start()


if __name__ == "__main__":
    app = QtGui.QApplication(sys.argv)
    main_window = main_cl()
    check_docs = check_docs_cl()
    check_docs.start()
    sys.exit(app.exec_())

И ещё интересно сколько в миллисекундах занимает парсинг... иногда имеет смысл делать так:
def run(self):
self.basictimer.stop()
if check_connect():
print("парсинг сайта")
self.basictimer.start(10000, self)

[Sergey6661313]

Sergey6661313: блин как редактировать свои сообщения? яж написал убрать global status_connect а сам так и оставил в своём примере :(((

[pypyshka]

Sergey6661313 спасибо за помощь! Редактировать сообщения, если не ошибаюсь, можно в течение часа после публикации.

[pypyshka]

Sergey6661313 хотя нет, просто нельзя редактировать =)