使用QNetworkAccessManager時無法啓動QThread

Question

我目前正在試圖製作一個軟件，可從Google Drive下載大量文件。下載目前不是問題。

不過，我在啓動500多個同時下載時遇到問題。我使用本教程的稍微修改版本：https://wiki.qt.io/Download_Data_from_URL。

這裏是.h文件：

class FileDownloader : public QObject 
{ 
    Q_OBJECT 
public: 
    explicit FileDownloader(QUrl url, QObject *parent = 0, int number = 0); 
    QByteArray downloadedData() const; 
    void launchNewDownload(QUrl url); 
    QByteArray m_DownloadedData; 
    QNetworkReply* reply; 

    static QNetworkAccessManager *m_WebCtrl; 

signals: 
    void downloaded(); 

private slots: 
    void fileDownloaded(QNetworkReply* pReply); 
}; 

這裏是.cpp文件：

QNetworkAccessManager* FileDownloader::m_WebCtrl = nullptr; 

FileDownloader::FileDownloader(QUrl url, QObject *parent) : 
    QObject(parent) 
{ 
    if (m_WebCtrl == nullptr) { 
     m_WebCtrl = new QNetworkAccessManager(this); 
    } 
    connect(m_WebCtrl, SIGNAL (finished(QNetworkReply*)),this, SLOT (fileDownloaded(QNetworkReply*))); 

    launchNewDownload(url); 
} 

void FileDownloader::launchNewDownload(QUrl url) { 
    QNetworkRequest request(url); 
    this->reply = m_WebCtrl->get(request); 
} 

void FileDownloader::fileDownloaded(QNetworkReply* pReply) { 
    m_DownloadedData = pReply->readAll(); 

    //emit a signal 
    pReply->deleteLater(); 
    emit downloaded(); 
} 

QByteArray FileDownloader::downloadedData() const { 
    return m_DownloadedData; 
} 

的問題是 「的QThread ::開始：無法創建線程（）」 時，達到了第500次下載。我試圖限制同時運行的下載數量 - 但我總是遇到同樣的問題。此外，我試圖在完成任務時刪除每個下載器 - 它沒有別的事情比崩潰的程序;）

我認爲它來自一個唯一的過程允許的線程數，但我不能解決它！

有沒有人有一個想法，可以幫助我？

謝謝！

Answer 1

QNetworkAccessManager::finished無論何時待處理的網絡應答完成，信號被記錄爲。

這意味着如果使用QNetworkAccessManager一次運行多個請求（並且這是perfectly normal usage）。 finished信號將爲每個請求發射一次。由於您的FileDownloader對象之間共享了QNetworkAccessManager實例，因此您撥打的每個get電話都會發出finished信號。因此，只要第一個FileDownloader完成下載，所有FileDownloader對象都會得到finished信號。

除了使用QNetworkAccessManager::finished之外，您可以使用QNetworkReply::finished來避免混合信號。下面是一個示例實現：

#include <QtNetwork> 
#include <QtWidgets> 

class FileDownloader : public QObject 
{ 
    Q_OBJECT 
    //using constructor injection instead of a static QNetworkAccessManager pointer 
    //This allows to share the same QNetworkAccessManager 
    //object with other classes utilizing network access 
    QNetworkAccessManager* m_nam; 
    QNetworkReply* m_reply; 
    QByteArray m_downloadedData; 

public: 
    explicit FileDownloader(QUrl imageUrl, QNetworkAccessManager* nam, 
          QObject* parent= nullptr) 
     :QObject(parent), m_nam(nam) 
    { 
     QNetworkRequest request(imageUrl); 
     m_reply = m_nam->get(request); 
     connect(m_reply, &QNetworkReply::finished, this, &FileDownloader::fileDownloaded); 
    } 
    ~FileDownloader() = default; 

    QByteArray downloadedData()const{return m_downloadedData;} 

signals: 
    void downloaded(); 
private slots: 
    void fileDownloaded(){ 
     m_downloadedData= m_reply->readAll(); 
     m_reply->deleteLater(); 
     emit downloaded(); 
    } 
}; 

//sample usage 
int main(int argc, char* argv[]){ 
    QApplication a(argc, argv); 

    QNetworkAccessManager nam; 
    FileDownloader fileDownloader(QUrl("http://i.imgur.com/Rt8fqpt.png"), &nam); 
    QLabel label; 
    label.setAlignment(Qt::AlignCenter); 
    label.setText("Downloading. . ."); 
    label.setMinimumSize(640, 480); 
    label.show(); 
    QObject::connect(&fileDownloader, &FileDownloader::downloaded, [&]{ 
     QPixmap pixmap; 
     pixmap.loadFromData(fileDownloader.downloadedData()); 
     label.setPixmap(pixmap); 
    }); 

    return a.exec(); 
} 

#include "main.moc" 

---

^{如果您使用此方法下載大文件時，請考慮一下this question。}

Answer 2

一個解決方案可能是使用QThreadPool。您只需爲它提供任務（QRunnable），它就會爲您處理線程數和任務隊列。

但在你的情況下，這並不完美，因爲你將限制同時下載的數量與QThreadPool創建的線程數量（通常是你擁有的CPU核心數量）。

爲了克服這個問題，你必須自己處理QThread，而不是使用QThreadPool。您將創建少量線程（請參閱QThread::idealThreadCount()）並在每個QThread上運行多個FileDownloader。