目錄

Detailed Description

博主栗子

關于全局線程池使用以及是否自動銷毀

關于最大線程的運行栗子

---

Detailed Description

QThreadPool類用于管理QThreads的集合。

QThreadPool管理以及重復利用每一個線程對象，來幫助減少創建線程時帶來的系統開銷。每一個Qt應用程序都有一個全局的QThreadPool對象，可以直接通過調用globalInstance()進行訪問。

要想使用QThreadPool里面的線程，要先繼承QRunnable并且重寫run()函數，然后創建一個對象并且通過使用QThreadPool::start()進行調用

class HelloWorldTask : public QRunnable{void run(){qDebug() << "Hello world from thread" << QThread::currentThread();}}HelloWorldTask *hello = new HelloWorldTask();// QThreadPool takes ownership and deletes 'hello' automaticallyQThreadPool::globalInstance()->start(hello);

默認情況下，QThreadPool自動刪除QRunnable。但可以通過使用QRunable::setAutoDelete()去改變自動刪除這個功能。

QThreadPool支持執行相同的QRunnable類，這種騷操作可以在QRunnable::run()中調用tryStart(this)。當自動刪除被激活的時候，QRunnable將在最后一個線程運行函數調用并且結束后，被調用（自動刪除）。當autoDelete被激活的時候用一個相同的QRunnable調用多次start()，會創造線程的競爭條件，官方不推薦這么做。

在一定時間內沒有使用的線程將會死亡，這個默認死亡的時間是30s。但可以通過使用setExpiryTimeout()函數來改變這個到期的值。通過設置一個與時間之前的值（比如現在是9點半，設置成9點）那么這個到期的機制將會被終止。

調用maxThreadCount()能查詢到可以使用的最大線程的個數，想改變他的話可以通過調用setMaxThreadCount()進行設置。默認的maxThreadCount()的數量是QThread::idealThreadCount()。activeThreaCount()返回目前正在工作的線程的數量。

reserveThread()函數保留了一個線程用于線程池外部使用。通過調用releaseThread()進行使用，這個線程是不會到期的，可以重復使用。可以通過使用這些函數去臨時的增加或減少活動的線程的數量，并且還不對系統的時間開銷還不高。

【注意：QThreadPool是低級的線程管理類，Qt Concurrent module是高級管理類，他是QThreadPool的代替選擇】

?

博主栗子

關于全局線程池使用以及是否自動銷毀

程序運行截圖如下：

源碼如下：

worker.h

#ifndef WORKER_H #define WORKER_H#include <QRunnable>class Worker : public QRunnable { public:explicit Worker();~Worker();void run(); };#endif // WORKER_H

worker.cpp

#include "worker.h" #include <QDebug> #include <QThread>Worker::Worker() {}Worker::~Worker() {qDebug()<<"go home, dog bye"; }void Worker::run() {qDebug()<<"Hello world from thread "<<QThread::currentThreadId(); }

mainc.pp

#include "worker.h" #include <QApplication> #include <QThreadPool>int main(int argc, char *argv[]) {QApplication a(argc, argv);Worker *worker=new Worker;QThreadPool::globalInstance()->start(worker);return a.exec(); }

可以看到他自動調用了析構函數，他在內部對他進行delete（對于C++程序員來說，這有點爽啊）

?

關于最大線程的運行栗子

運行截圖如下：

代碼如下：

worker.h

#ifndef WORKER_H #define WORKER_H#include <QRunnable>class Worker : public QRunnable { public:explicit Worker();~Worker();void run(); };#endif // WORKER_H

worker.cpp

#include "worker.h" #include <QDebug> #include <QThread>Worker::Worker() {//this->setAutoDelete(false); }Worker::~Worker() {qDebug()<<"go home, dog bye"; }void Worker::run() {QThread::msleep(1000);qDebug()<<"Hello world from thread "<<QThread::currentThreadId(); }

main.cpp

#include "worker.h" #include <QApplication> #include <QThreadPool>int main(int argc, char *argv[]) {QApplication a(argc, argv);Worker *worker[100];for(int i=0;i<100;i++){worker[i]=new Worker;}QThreadPool::globalInstance()->setMaxThreadCount(2);for(int i=0;i<100;i++){QThreadPool::globalInstance()->start(worker[i]);}return a.exec(); }

?

總結

以上是生活随笔為你收集整理的Qt文档阅读笔记-QThreadPool的解释及使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。