非阻塞工作者 - 中断文件复制

Question

我正在处理非常大的文件,大小超过数百GB.用户需要能够在磁盘之间移动这些文件,并且是在没有默认文件管理器的受限系统上.用户可能会意识到他们犯了错误并取消了操作,据我所知,用户必须等待当前的复制或重命名操作才能完成.这可能让他们感到沮丧,因为他们等待了几分钟,只是看到他们的许多GB文件仍然被复制.在复制的情况下,我可以删除第二个文件,但在重命名的情况下,我用来移动文件,我必须反向重复操作以撤消它,这是不可接受的.

有没有办法中断我在QFile文档中没有看到的copy()和rename(),或者我需要将自己的类放在一起来处理复制和重命名？

Answer 1

我不认为文件大小对重命名需要多长时间有任何影响.

对于副本 - Qt没有内置任何内容,您必须自己实现它.这里的关键是你必须找到一些方法来连续轮询复制取消.这意味着您无法锁定主线程以便能够处理事件.

是否需要额外的线程以保持主线程响应,或决定使用主线程 - 在这两种情况下,您都需要实现"碎片"复制 - 使用缓冲区一次一个块,直到文件为复制或复制被取消.您需要它才能处理用户事件并跟踪复制进度.

我建议你实现一个QObject派生的副本帮助工作者类,它跟踪文件名,总大小,缓冲区大小,进度和清除取消.然后,您是否将在主线程或专用线程中使用它是一个选择问题.

编辑:发现它,但你最好仔细检查它,因为它是作为一个例子完成并没有经过彻底测试:

class CopyHelper : public QObject {
    Q_OBJECT
    Q_PROPERTY(qreal progress READ progress WRITE setProgress NOTIFY progressChanged)
public:
    CopyHelper(QString sPath, QString dPath, quint64 bSize = 1024 * 1024) :
        isCancelled(false), bufferSize(bSize), prog(0.0), source(sPath), destination(dPath), position(0) { }
    ~CopyHelper() { free(buff); }

    qreal progress() const { return prog; }
    void setProgress(qreal p) {
        if (p != prog) {
            prog = p;
            emit progressChanged();
        }
    }

public slots:
    void begin() {
        if (!source.open(QIODevice::ReadOnly)) {
            qDebug() << "could not open source, aborting";
            emit done();
            return;
        }
        fileSize = source.size();
        if (!destination.open(QIODevice::WriteOnly)) {
            qDebug() << "could not open destination, aborting";
            // maybe check for overwriting and ask to proceed
            emit done();
            return;
        }
        if (!destination.resize(fileSize)) {
            qDebug() << "could not resize, aborting";
            emit done();
            return;
        }
        buff = (char*)malloc(bufferSize);
        if (!buff) {
            qDebug() << "could not allocate buffer, aborting";
            emit done();
            return;
        }
        QMetaObject::invokeMethod(this, "step", Qt::QueuedConnection);
        //timer.start();
    }
    void step() {
        if (!isCancelled) {
            if (position < fileSize) {
                quint64 chunk = fileSize - position;
                quint64 l = chunk > bufferSize ? bufferSize : chunk;
                source.read(buff, l);
                destination.write(buff, l);
                position += l;
                source.seek(position);
                destination.seek(position);
                setProgress((qreal)position / fileSize);
                //std::this_thread::sleep_for(std::chrono::milliseconds(100)); // for testing
                QMetaObject::invokeMethod(this, "step", Qt::QueuedConnection);
            } else {
                //qDebug() << timer.elapsed();
                emit done();
                return;
            }
        } else {
            if (!destination.remove()) qDebug() << "delete failed";
            emit done();
        }
    }
    void cancel() { isCancelled = true; }

signals:
    void progressChanged();
    void done();

private:
    bool isCancelled;
    quint64 bufferSize;
    qreal prog;
    QFile source, destination;
    quint64 fileSize, position;
    char * buff;
    //QElapsedTimer timer;
};

该done()信号用于deleteLater()复制助手/关闭复制对话框等.您可以启用已用时间并使用它来实现经过时间属性和估计时间.暂停是另一个可能实现的功能.使用QMetaObject::invokeMethod()允许事件循环定期处理用户事件,以便您可以取消和更新从0到1的进度.您也可以轻松调整它以移动文件.