2

我正在尝试创建一个将创建新线程的上传器，并且在每个线程中我都有一个 QNetworkAccessManager。所有的上传线程都有一个对共享列表的引用，并将通过使用开始和结束索引来拆分它。

上传器看起来像这样：

 class FileUploader : public QObject {
    Q_OBJECT

public:
    explicit FileUploader(QList<FileInfoWrapper> &fileList, const int start = 0, const int offset = 0, QObject *parent = 0);


    void uploadNext();

    QString containerName;

private:
    int start_, offset_, iterator_;
    QList<FileInfoWrapper> &fileList_;
    RestFileUploader *restFileUploader;

signals:
    void progressChangedAt(int row);
    void statusChangedAt(int row);
    void finished();

public slots:
    void init();

private slots:
    void setUploadProgress(qint64 tranfered);
    void handleRequestFinished(QNetworkReply* reply);
    void handleSslErros(QNetworkReply *reply, const QList<QSslError> &errors);
    void handleNetworkError(QNetworkReply::NetworkError error);

};

然后，在 run() 函数中，我创建了新的 RestFileUploader(this)（几乎是一个创建自己的新 QNetworkAccessManager(this) 并在其上放置请求的对象），以便在构造函数中没有创建任何内容（这将导致它最终进入主线程？）。run 函数创建一个请求给 QNetworkAccessManager，然后什么都不做，直到发出“finished(QNetworkReply)”的信号，然后我抓住下一个（依此类推，直到列表被单步执行）。

然后我在主应用程序中创建了两个新线程，当我使用 run() 启动它们时，它可以工作，只是两个线程上的 ID 相同。如果我改为调用“start()”，它会崩溃：QObject：无法为位于不同线程中的父级创建子级。(Parent是FileUploader(0x2580748)，parent的线程是QThread(0x4fb2b8)，当前线程是FileUploader(0x2580748)

但！就在我开始单步执行列表之前，我打印了 threadId，它们不再相同。

我做错了什么还是应该这样做：http: //labs.qt.nokia.com/2006/12/04/threading-without-the-headache/？

编辑：

我更改了它并重命名了 run 以启动并制作了这个包装器（并且我不再使用“this”调用 NetworkAccessManager 或 RestFileUploader）：

FileUploader *fileUploader = new FileUploader(fileList_, start, (offset == 0 ? (fileList_.count() - start) : offset));
QThread *fileUploaderThread = new QThread;
fileUploader->moveToThread(fileUploaderThread);

connect(fileUploader, SIGNAL(progressChangedAt(int)), model_, SLOT(reportProgressChanged(int)));
connect(fileUploader, SIGNAL(statusChangedAt(int)), model_, SLOT(reportStatusChanged(int)));

fileUploaderThread->start();
QMetaObject::invokeMethod(fileUploader, "init", Qt::QueuedConnection);

上传一个对象时有效，因为那时我只使用一个线程。但是，当我有更多要拆分的对象时，应用程序会因以下错误消息而残酷地崩溃：

ASSERT failure in QMutexLocker: "QMutex pointer is misaligned", file ..\..\include/QtCore/../../../../../../ndk_buildrepos/qt-desktop/src/corelib/thread/qmutex.h, line 100
Invalid parameter passed to C runtime function.
Invalid parameter passed to C runtime function.

请帮我

编辑：

文件上传器.cpp

#include "fileuploader.h"

FileUploader::FileUploader(QList<FileInfoWrapper> &fileList, const int start, const int offset, QObject *parent)
    : QObject(parent), start_(start), offset_(offset), iterator_(start - 1), fileList_(fileList) {
}

void FileUploader::init() {
    restFileUploader = new RestFileUploader();

    connect(restFileUploader, SIGNAL(uploadProgress(qint64)), this, SLOT(setUploadProgress(qint64)));
    connect(restFileUploader, SIGNAL(requestFinished(QNetworkReply*)), this, SLOT(handleRequestFinished(QNetworkReply*)));
    connect(restFileUploader, SIGNAL(sslErrors(QNetworkReply*,QList<QSslError>)), this, SLOT(handleSslErros(QNetworkReply*,QList<QSslError>)));
    connect(restFileUploader, SIGNAL(networkError(QNetworkReply::NetworkError)), this, SLOT(handleNetworkError(QNetworkReply::NetworkError)));

    containerName = "temp"

    qDebug() << "thread" << this->thread()->currentThreadId() << start_ << ":" << offset_;

    uploadNext();
}

void FileUploader::uploadNext() {
     qDebug() << "uploadNext" << this->thread()->currentThreadId();

    if((iterator_ + 1) < (start_ + offset_)) {
        iterator_++;

        restFileUploader->putBlob(containerName, fileList_.at(iterator_).fileName(), fileList_.at(iterator_).fileInfo().filePath());

    } else emit finished();
}

void FileUploader::setUploadProgress(qint64 tranfered) {

    fileList_[iterator_].setProgress(tranfered);

    emit progressChangedAt(iterator_);
}

void FileUploader::handleRequestFinished(QNetworkReply* reply) {

    qDebug() << "finished blob: " << iterator_ << " in thread " << this->thread()->currentThreadId();

    if(reply->error() > QNetworkReply::NoError) {
        qDebug() << reply->errorString();

        fileList_[iterator_].uploadFailed();

        emit progressChangedAt(iterator_);

    } else fileList_[iterator_].uploadFinished();

    emit statusChangedAt(iterator_);

    uploadNext();
}

void FileUploader::handleNetworkError(QNetworkReply::NetworkError error) {

    if(error > QNetworkReply::NoError) {
        fileList_[iterator_].uploadFailed();

        restFileUploader->cancelCurrentRequest();

        emit progressChangedAt(iterator_);
        emit statusChangedAt(iterator_);
    }
}

void FileUploader::handleSslErros(QNetworkReply *reply, const QList<QSslError> &errors) {

    if(reply->error() > QNetworkReply::NoError) {

        qDebug() << reply->errorString();

        fileList_[iterator_].uploadFailed();

        restFileUploader->cancelCurrentRequest();

        emit progressChangedAt(iterator_);
        emit statusChangedAt(iterator_);
    }
}

#include "restfileuploader.h"

void RestFileUploader::putBlob(const QString& container, const QString& blob, const QString& filePath) {
    QFile *uploadFile = new QFile(filePath, this); // <--- this maybe?
    uploadFile->open(QIODevice::ReadOnly); 

    QNetworkRequest request = this->createRestRequest("PUT", QString("%1/%2").arg(container, blob), uploadFile->size(), headers);

    reply_ = accessManager_->put(request, uploadFile);

    connect(reply_, SIGNAL(uploadProgress(qint64, qint64)), this, SLOT(reportUploadProgress(qint64, qint64)));
    connect(reply_, SIGNAL(error(QNetworkReply::NetworkError)), this, SLOT(reportNetworkError(QNetworkReply::NetworkError)));

    qDebug() << this->thread()->currentThreadId();
}

void RestFileUploader::cancelCurrentRequest() {
    reply_->abort();
}

RestFileUploader::~RestFileUploader() {
    qDebug() << "RestFileUploader deleted";

    reply_->deleteLater();
}

所以... 1 个线程要上传一件事 == 好的。两个线程上的 2 个对象也可以。当我尝试在两个线程上上传 3 个或更多对象时，一切都变得糟糕透顶。

此外，它是否与 UI 在我更改文件的同时读取文件信息有关？

编辑：由于某种原因，当我在 Visual Studio 中编译它时，我的应用程序现在可以在 4.8.0 中运行。它可能与版本 4.7.4 有关吗？

4

3 回答 3

4

QThread::start()是实际开始的thread（作为不同的thread）。 QThread::run()只是一个普通函数，所以如果你在没有start()先调用的情况下调用它，你就是在主线程中执行它。

有趣的是，您的派生类是在主线程中创建的，因此它“属于”主线程。我猜你正在把你的班级作为父母交给别的东西；这就是当您在调用后尝试执行此操作时生成错误消息的原因start()。你可以让这些对象没有父对象吗？

您将无法在另一个线程中创建 gui 对象，Qt 只是不允许它（还没有？）。但是可以创建其他对象，只是不能在不同的线程中给它们一个父对象。

于 2012-02-27T00:41:35.667 回答
3

您收到的错误

ASSERT failure in QMutexLocker: "QMutex pointer is misaligned"

如果传递给构造函数的 QMutex 对象未在 RAM 中的 2 字节边界上对齐（至少在 Qt 4.7.1 中），则在创建 QMutexLocker 对象时发生。

QMutexLocker 对象使用一个成员变量来表示互斥锁在内存中的位置及其状态（无论它是否被锁定）。状态由变量的最低有效位表示，而互斥指针的最低有效位假定为零。如果该位不为零，则抛出上面的 ASSERT 异常。

我能想到的 QMutex 指针未对齐的唯一原因是内存泄漏或损坏。检查是否销毁了所有分配的内存（尤其是在循环中）并检查所有类型转换（您可能已将较小类型的指针转​​换为较大类型的指针，从而损坏内存）和以空字符结尾的字符串（这将损坏内存）如果没有正确终止）。最后，验证您跨线程共享的所有内存的线程安全性。

于 2012-06-14T10:21:32.763 回答
0

这可能是因为在您的应用程序中创建了某些对象的顺序。我建议从 QObject 继承而不是 QThread，并将对象移动到工作线程（QObject::moveToThread()）。还将在 FileUploader 中初始化的任何代码移动到 FileUploader 中的单独插槽，例如 init()。当线程运行时（在工作线程上调用 start 之后）调用 init (QMetaObject::invokeMethod())。例如：

FileUploader : public QOject
{
...
public slots:
void init() { Foo *foo = new Foo(this); }
}

// main thread
QThread worker;
FileUploader *fup = new FileUploader();
fup->moveToThread(&worker);
worker.start();
QMetaObject::invokeMethod(fup, "init", Qt::QueuedConnection); 
//
于 2012-02-27T01:42:25.470 回答