Почему могут зависать потоки?

Question

Дмитрий Донской @sentike

Программист, разработчик игр, студент

Почему могут зависать потоки?

Пишу многопоточное приложение на QT. Есть два основных потока: UI + Класс ( унаследован от QThread).
В классе создается QThreadPool на 32 потока с списком задач ( 1000+) - скачивание файлов из интернета, их распаковка и сохранение на диск. Код проверенный (раньше работал - до рефакторинга). Но в какой то момент в режиме отладки иногда потоки заканчиваются с результатом = 3, иногда во время работы Windows издает звук Alert'a (как всплывающее окно, но окна нету), а приложение зависает, точнее эти потоки. Без отладчика приложение просто молча падает.

QT 5.5

Вопрос задан более трёх лет назад
836 просмотров

2 комментария

Подписаться 2 Оценить 2 комментария

Дмитрий Донской @sentike Автор вопроса

Вроде как возникает проблема в классе отвечающем за скачку -- при ошибке: UnkownNetworkError

class TaskDownload 
	: public QObject
{
	Q_OBJECT

	QNetworkAccessManager NetworkAccessManager;
	QNetworkReply* Reply;
	QByteArray Content;
	qint64 Attemps;
	QUrl Url;

	void AttempDownload();
public:
	bool IsSuccessfully() const
	{
		return Attemps < 3 && Content.size() > 0;
	}

	QByteArray& GetContent()
	{
		return Content;
	}

	const QByteArray& GetContent() const
	{
		return Content;
	}

	TaskDownload(QUrl url);
	~TaskDownload();

signals:
	void ReadyRead();

	void DownloadFinished();
	void DownloadProgress(qint64, qint64);

	private slots:
	void onReadyRead();
	virtual void onDownloadFinished();
	void onDownloadError(QNetworkReply::NetworkError err);
	void onDownloadProgress(qint64, qint64);

};

#include "TaskDownload.h"


TaskDownload::TaskDownload(QUrl url)
	: Reply(nullptr),
	Attemps(1)
	, Url(url)
{
	AttempDownload();
}

TaskDownload::~TaskDownload()
{
}


void TaskDownload::AttempDownload()
{
	if (Attemps > 3)
	{
		//throw new std::exception(QString("Failed to download file: " + Url.toString()).toStdString().c_str());
		exit(100001);
	}

	QNetworkRequest request(Url);
	Reply = NetworkAccessManager.get(request);

	qInfo() << QString("Begin download, attemp: %1 \nurl: %2").arg(QString::number(Attemps), Url.toString());

	connect(Reply, SIGNAL(readyRead()),
		this, SLOT(onReadyRead()));

	connect(Reply, SIGNAL(downloadProgress(qint64, qint64)),
		this, SLOT(onDownloadProgress(qint64, qint64)));

	connect(Reply, SIGNAL(finished()),
		this, SLOT(onDownloadFinished()));

	connect(Reply, SIGNAL(error(QNetworkReply::NetworkError)),
		this, SLOT(onDownloadError(QNetworkReply::NetworkError)));

	this->Attemps++;
}


void TaskDownload::onReadyRead()
{
	// downloadTime.start();
	emit ReadyRead();
}

void TaskDownload::onDownloadError(QNetworkReply::NetworkError err)
{
	auto url = Url.toString().toStdString();
	qInfo() << "onDownloadError: " << Url.toString() << " | error: " << err;
	AttempDownload();
}

void TaskDownload::onDownloadFinished()
{
	qInfo() << "complete download: " << Url.toString();

	if (Reply->error() > 0)
	{
		qDebug() << "onDownloadError: " << Url.toString() << " | error: " << Reply->errorString();
		AttempDownload();
		return;
	}

	Content = Reply->readAll();
	Reply->deleteLater();

	emit DownloadFinished();
}

void TaskDownload::onDownloadProgress(qint64 cur, qint64 max)
{
	emit DownloadProgress(cur, max);
}

Написано более трёх лет назад