QNetworkAccessManager & QThreads

[BloodyTux]

Доброго времени суток!

Мне необходимо сделать многопоточное приложение, отправляющее http запросы. Естественно логично было бы использовать QNetworkAccessManager, но вот незадача:  когда запускаю в одном потоке, работает стабильно, при большем количестве - вылетают ошибки связанные с QMutex::lock(). Код:

Код:

/ ************** main.cpp **************** /


#include <QtCore/QCoreApplication>
#include <QDebug>
#include "threadhttpdownload.h"

#define USAGE QT_TRANSLATE_NOOP("threadDownload::main", "usage: %s <link> <file name>")

int main(int argc, char *argv[])
{
    if (argc < 2)
    {
        qDebug(USAGE, argv[0]);
        return 0;
    }

    QCoreApplication a(argc, argv);

    for (int i = 0; i < 5; i++) {
        ThreadHttpDownload *th = new ThreadHttpDownload(0,argv[1]);
        th->start();
        qDebug() << "tread " << i << " started";

    }

    return a.exec();
}



/ ************** threadhttpdownload.h **************** /



#ifndef THREADHTTPDOWNLOAD_H
#define THREADHTTPDOWNLOAD_H

#include <QThread>
#include <QNetworkAccessManager>
#include <QNetworkReply>
#include <QFile>
#include <QDebug>

class ThreadHttpDownload : public QThread
{
    Q_OBJECT

    public:
        ThreadHttpDownload(QObject *parent,QString link);

        void run();

    private:

        QString link;

    private slots:
        void replyFinished(QNetworkReply*);
};

#endif // THREADHTTPDOWNLOAD_H



/ ************** threadhttpdownload.h **************** /



#include "threadhttpdownload.h"

ThreadHttpDownload::ThreadHttpDownload(QObject *parent,QString _link)
        :QThread(parent)
{
     link = _link;

}

void ThreadHttpDownload::run()
{
   // qDebug() << currentThreadId();

    QNetworkAccessManager manager;

    connect(&manager, SIGNAL(finished(QNetworkReply*)),
             this, SLOT(replyFinished(QNetworkReply*)), Qt::DirectConnection);

    manager.get(QNetworkRequest(QUrl(link)));

    exec();
}


void ThreadHttpDownload::replyFinished(QNetworkReply *reply)
{
    // qDebug() << currentThreadId();

    if (reply->error())
    {
        qDebug() << "error download" << reply->errorString();
    }else
    {
        reply->readAll();
        qDebug() << "download complete";
    }
}

Варианты вывода :

tread  0  started
tread  1  started
tread  2  started
tread  3  started
tread  4  started
QMutex::lock: mutex lock failure: Недопустимый аргумент
download complete
download complete
download complete
download complete
download complete

tread  0  started
tread  1  started
tread  2  started
tread  3  started
tread  4  started
Ошибка сегментирования

replyFinished(QNetworkReply *reply) выполняется в рабочем потоке - проверял. Не могу понять, в чем дело... Да, проблема возникает и на linux и на win. QTcpSocket конечно работает, но как-то не хочется иметь дело с примитивами.

[GNU Dimarik]

Я вообще не понял в чем проблема... Давайте сюда код с мютексами.

[BloodyTux]

Все, спасибо. Решил проблему.

[ufna]

А в чем была проблема?

[AlekseyK]

Все, спасибо. Решил проблему.

Обычно люди помещают решение и код, если проблема решена, чтобы тем, кто идёт следом было полегче.

[BloodyTux]

Дело в том, что решение, так сказать, радикальное. Решил отказаться от Qt для разработки данного проекта.

[Авварон]

Мда... Вообще стоило сначала почитать про thread-safety и reentrant:)

[Sahab]

на сокетах Беркли решил написать?))

[AlekseyK]

Мда... Вообще стоило сначала почитать про thread-safety и reentrant:)

Я вот почитал - мне не помогло, у меня схожая проблема: http://www.prog.org.ru/topic_15421_0.html

[ufna]

Я сделал у себя немного по-другому, главное отличие касается run() функции, т.к. там есть "непонятки" с потоком-родителем и т.п.

привожу код, я его использую для многопоточной загрузки файлов на сервак по частям. Это урезанная версия для выкладки, поэтому может сходу не работать, но суть по коду ясна где что добавить/изменить для ваших целей.

подрихтовал и опубликовал здесь: http://ufna.ru/2010/10/27/qt-qnetworkaccessmanager-multithread

[AlekseyK]

Честно говоря не понял, что нужно изменить: у меня по принципу код похожий. Но ошибка вываливается, только, если закрыть программу во время загрузки страницы. Если позже - ошибка не возникает. Может QByteArray долго передаётся - не знаю (не понятно):

Код

C++ (Qt)
141: emit pageContentReady(pageContent, pageAddress);

[ufna]

он падает в любой момент при закрытии лично у меня

ошибка скорее всего в том, что менеджеру кто-то после этого шлет сигналы, а его уже нет. Суровое удаление через delete тут рисованно.

я бы на твоем месте сделал просто manager->setParent(this); после того как заслал его в this поток.

[AlekseyK]

Да, успешно, работает, спасибо. Теперь проверить нет ли утечек памяти.

[ufna]

"По идее" - быть не должно, поток-родитель подтереть должен. На практике - класс умирает вместе с приложением, висеть ничего не остается, потому в любом случае не критично.

[AlekseyK]

По идее - да, пробежался valgrind-ом на всякий случай - в этом компоненте их нет. Огромное спасибо!!!