Class multiDeleteThread

utils/multiDeleteThread.py:23–69

class multiDeleteThread(QThread):
    delete_process_signal = pyqtSignal(int)
    delete_complete_signal = pyqtSignal()

    def __init__(self, fileList, dirList, share_thread_arr, direct_delete=False):
        super(multiDeleteThread, self).__init__()
        self.fileList = fileList
        self.dirList = dirList
        self.share_thread_arr = share_thread_arr
        self.direct_delete = direct_delete

    def _delete_path(self, file_path):
        if is_protected_file(file_path):
            logging.info("Skip protected file: %s", file_path)
            return
        try:
            if self.direct_delete:
                if os.path.isdir(file_path):
                    shutil.rmtree(file_path)
                else:
                    os.remove(file_path)
            else:
                send2trash(file_path)
        except Exception:
            logging.exception("Failed to delete path: %s", file_path)

    def _emit_progress(self):
        qmut.lock()
        try:
            self.share_thread_arr[0] += 1
            self.delete_process_signal.emit(self.share_thread_arr[0])
        finally:
            qmut.unlock()

    def run(self):
        try:
            for file_path in self.fileList:
                self._delete_path(file_path)
                self._emit_progress()

            for file_path in self.dirList:
                self._delete_path(file_path)
                self._emit_progress()

            logging.info("Delete thread finished")
        finally:
            self.delete_complete_signal.emit()