Как повторить использование Qthread с отзывчивым индикатором прогресса - PullRequest
Новая
       46

Как повторить использование Qthread с отзывчивым индикатором прогресса

1 голос
/ 20 октября 2019

При использовании python pyqt я создал Qprogressbar с обновлением числа, используя Q thread. Код, показанный ниже, в первый раз успешен, однако при следующем запуске он завершится с ошибкой.

Это для Python PyQt5 в системе Python 3.5. И я попытался сбросить индикатор выполнения на 0, но он не показался правильным

Это функция вызова после того, как я нажимаю кнопку загрузки файла, кнопка загрузки файла и индикатор выполнения находятся в QtWidgets.Qmainwindows 

loading_event_name = QtWidgets.QFileDialog.getOpenFileNames(self, 'CSV File', 'C:\\', '*.csv')
self.loading_progress_bar.reset()
self.loading_thread = QThread()
self.loading_worker = Load_Task_Thread()

self.loading_worker.moveToThread(self.loading_thread)
self.loading_thread.started.connect(self.loading_worker.run)
self.loading_thread.start()
self.loading_worker.Load_taskFinished.connect(self.Load_onFinished)
self.loading_worker.Loading_progressChanged.connect(self.loading_progress_bar.setValue, Qt.QueuedConnection)'''

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

class Load_Task_Thread(QThread):
  Load_taskFinished = pyqtSignal()
  Loading_progressChanged = pyqtSignal(int)
  def run(self):
    progress = 0
    for file_name_num in range(len(loading_event[0])):
       progress = 90 * file_name_num/len(loading_event_name[0])
       self.Loading_progressChanged.emit(progress)
       1+1.....
    self.Loading_progressChanged.emit(100)
    self.Load_taskFinished.emit()

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

1 Ответ

1 голос
/ 20 октября 2019

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

  • Вы создали QThread (Load_Task_Thread) и переместили его в другой QThread, которыйне является необходимым, поскольку достаточно, чтобы Load_Task_Thread был QObject.

  • Нет необходимости создавать QThread при каждом запуске процесса, поскольку достаточно QObject, который живет в потоке.

Учитывая вышеизложенное, я реализовал следующий пример: 

from functools import partial

from PyQt5 import QtCore, QtGui, QtWidgets


class Load_Task_Worker(QtCore.QObject):
    started = QtCore.pyqtSignal()
    finished = QtCore.pyqtSignal()
    progressChanged = QtCore.pyqtSignal(int)

    @QtCore.pyqtSlot(list)
    def run(self, filenames):
        total = len(filenames)
        self.started.emit()
        self.progressChanged.emit(0)
        for i, filename in enumerate(filenames, 1):
            # start process
            # ...
            # end process
            progress = 100 * i // total
            self.progressChanged.emit(progress)
        self.finished.emit()


class Widget(QtWidgets.QWidget):
    def __init__(self, parent=None):
        super().__init__(parent)

        self.button = QtWidgets.QPushButton("Start Task")
        self.loading_progress_bar = QtWidgets.QProgressBar()

        lay = QtWidgets.QVBoxLayout(self)
        lay.addWidget(self.button)
        lay.addWidget(self.loading_progress_bar)

        thread = QtCore.QThread(self)
        thread.start()

        self.worker = Load_Task_Worker()
        self.worker.moveToThread(thread)

        self.button.clicked.connect(self.onClicked)
        self.worker.progressChanged.connect(self.loading_progress_bar.setValue)
        self.worker.finished.connect(self.onFinished)

    @QtCore.pyqtSlot()
    def onFinished(self):
        self.button.setEnabled(True)

    @QtCore.pyqtSlot()
    def onClicked(self):
        filenames, _ = QtWidgets.QFileDialog.getOpenFileNames(
            self, "CSV File", "C:\\", "*.csv"
        )
        if filenames:
            self.button.setEnabled(False)
            self.loading_progress_bar.reset()
            wrapper = partial(self.worker.run, filenames)
            QtCore.QTimer.singleShot(0, wrapper)
        else:
            print("not selected files")


if __name__ == "__main__":
    import sys

    app = QtWidgets.QApplication(sys.argv)
    w = Widget()
    w.show()
    sys.exit(app.exec_())
...