Как убить бегущий поток - PullRequest
Новая
       8

Как убить бегущий поток

0 голосов
/ 02 июля 2018

У меня есть диалог, показывающий ход работающего потока: 

from PyQt5.QtWidgets import *
from PyQt5.uic import loadUi
from PyQt5.QtCore import *

class LoaderProgress(QDialog):
    def __init__(self, parent=None):
        super(LoaderProgress, self).__init__(parent)
        loadUi("CliReportsUI/loaderprogress.ui", self)
        self.pbLoader.setValue(0)
        self.btn_cancel.clicked.connect(self.killthread)

    def watchthread(self,worker):
        self.thread = worker(self)
        self.thread.totsignal.connect(self.pbLoader.setMaximum)
        self.thread.cntsignal.connect(self.updateprogress)
        self.thread.finished.connect(self.close)

    def settitle(self,title):
        self.setWindowTitle(title)

    def startthread(self):
        self.thread.start()

    def updateprogress(self,n):
        self.pbLoader.setValue(n)

    def killthread(self):
        print('How do I do this')

Метод в другом классе запускает поток следующим образом: 

    dlg = LoaderProgress(self)
    dlg.watchthread(FileLoader)
    dlg.settitle("Loading The Master File...")
    dlg.show()
    dlg.startthread()

Тогда есть рабочий класс: 

class FileLoader(QThread):
    totsignal = pyqtSignal(int)
    cntsignal = pyqtSignal(int)

    def __init__(self,parent=None):
        super(FileLoader, self).__init__(parent)
        self.threadactive = True
        self.total = 100

    def run(self):
        self.totsignal.emit(self.total)
        i = 1
        while(i < self.total and self.threadactive):
            print(time.time)
            if(time.time() % 1==0):
                i+=1
                self.cntsignal.emit(i)

В диалоге загрузчика у меня есть кнопка, которая отменяет процесс (btn_cancel), но я не знаю, как убить работающий поток, если нажата кнопка отмены. Спасибо за любую помощь.

1 Ответ

0 голосов
/ 02 июля 2018

Вам необходимо реализовать метод stop(), который изменяет флаг threadactive на False и ожидает термин с wait()

class FileLoader(QThread):
    totsignal = pyqtSignal(int)
    cntsignal = pyqtSignal(int)

    def __init__(self,parent=None):
        super(FileLoader, self).__init__(parent)
        self.threadactive = True
        self.total = 100

    def run(self):
        self.totsignal.emit(self.total)
        i = 1
        while(i < self.total and self.threadactive):
            print(time.time())
            if(time.time() % 1==0):
                i+=1
                self.cntsignal.emit(i)

    def stop(self):
        self.threadactive = False
        self.wait()

И затем вы вызываете это в killthread методе: 

def killthread(self):
    self.thread.stop()
    print('How do I do this')
...