Проверка прав доступа к файлу в QThread с помощью диалогового окна Retry / Cancel (в потоке GUI) - PullRequest
Новая
       13

Проверка прав доступа к файлу в QThread с помощью диалогового окна Retry / Cancel (в потоке GUI)

1 голос
/ 13 июня 2019

У меня есть процесс, запущенный в QThread, который генерирует некоторые данные, которые я хочу сохранить в файл. Перед тем, как сделать это, я должен убедиться, что у меня есть соответствующие разрешения для записи в файл (это для Windows), и я действительно хотел бы использовать QtWidgets.QMessageBox с опциями «Retry» и «Cancel». Это легко сделать, например, с помощью (в моем случае типичная проблема заключается в том, что у пользователя открыт файл xlsx в Excel) 

reply = QtWidgets.QMessageBox.warning(
    self, "PermissionError",
    "Could not open file \"%s\". Try closing the file if it is open." % filename,
    QtWidgets.QMessageBox.StandardButton.Retry,
    QtWidgets.QMessageBox.StandardButton.Cancel
)

но это работает только в основном потоке (GUI), а не в отдельном QThread. Какой хороший способ сделать это из QThread?

Я провел несколько тестов с сигналом от QThread, отправленным в слот в потоке GUI, который открывает диалоговое окно. Но мне трудно передать обратно в QThread результат проверки разрешений, и логика быстро становится грязной.

1 Ответ

1 голос
/ 13 июня 2019

Исходя из того, что у меня есть подход к подклассификации QThread , не годится для этих случаев.

Простым решением является использование подхода worker (QThread) -thread , поскольку у работника может быть несколько задач, таких как выполнение сложных вычислений и сохранение файла.Таким образом, GUI может запустить первую задачу, затем работник, который живет в другом потоке, сделает запрос на подтверждение сигналами GUI, а затем GUI в соответствии с полученным результатом может вызвать другую задачу.

AnПримером вышеизложенного является следующий: 

from PySide2 import QtCore, QtGui, QtWidgets


class Worker(QtCore.QObject):
    requestSignal = QtCore.Signal(str)

    def __init__(self, parent=None):
        super(Worker, self).__init__(parent)
        self.data = None

    @QtCore.Slot()
    def process(self):
        print("start process")
        # emulate heavy task
        QtCore.QThread.sleep(5)
        self.data = "Foo"
        print("end process")
        self.requestSignal.emit("filename.xlsx")

    @QtCore.Slot(bool)
    def save_data(self, result):
        print(result)
        print(self.data)


class Widget(QtWidgets.QWidget):
    sendResult = QtCore.Signal(bool)

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

        self.m_button = QtWidgets.QPushButton(
            "Press me", clicked=self.start_process
        )
        lay = QtWidgets.QVBoxLayout(self)
        lay.addWidget(self.m_button)

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

        self.m_worker = Worker()
        self.m_worker.moveToThread(self.m_thread)
        self.m_worker.requestSignal.connect(self.on_request)
        self.sendResult.connect(self.m_worker.save_data)

    @QtCore.Slot()
    def start_process(self):
        # launch process
        QtCore.QTimer.singleShot(0, self.m_worker.process)
        self.m_button.setDisabled(True)

    @QtCore.Slot(str)
    def on_request(self, filename):
        reply = QtWidgets.QMessageBox.warning(
            self,
            "PermissionError",
            'Could not open file "%s". Try closing the file if it is open.'
            % filename,
            QtWidgets.QMessageBox.Retry,
            QtWidgets.QMessageBox.Cancel,
        )
        result = reply == QtWidgets.QMessageBox.Retry
        print(result)
        self.sendResult.emit(result)
        self.m_button.setDisabled(False)

    def closeEvent(self, event):
        super(Widget, self).closeEvent(event)
        self.m_thread.quit()
        self.m_thread.wait()


if __name__ == "__main__":
    import sys

    app = QtWidgets.QApplication(sys.argv)

    w = Widget()
    w.show()
    sys.exit(app.exec_())
...