一、目的

  現(xiàn)在所有的高性能服務(wù)器程序，幾乎都會使用到線程池技術(shù)，從而更好且有效的榨干服務(wù)器性能。而創(chuàng)建并銷毀線程的過程勢必會消耗內(nèi)存。而在日常開發(fā)中內(nèi)存資源是及其寶貴的，所以QT 多線程之線程池QThreadPool就有很大用處了。它可以用來管理線程的優(yōu)先順序，防止創(chuàng)建過多的線程，起到很好的管理作用。

二、最優(yōu)線程數(shù)

  線程的創(chuàng)建和銷毀是有性能開銷的，當(dāng)我們有少量業(yè)務(wù)需要處理時，我們可以放到線程中完成，甚至可以多開幾個線程并行處理。
那么，問題來了，如果需要海量的數(shù)據(jù)處理，難道無休止的開線程下去嗎？

首先，要明白CPU的性能是有限的，每個線程好比一個處理時間片，多個線程之間切換處理，CPU線程上下文來回切換，這個也是需要消耗時間的。所以，物極必反，當(dāng)線程數(shù)量到達(dá)一個點(diǎn)后，可能消耗在線程切換的時間，會大于實(shí)際線程處理業(yè)務(wù)的時間，這個可以想象的到。

那么很容易明白：線程數(shù)并不是越多越好，而是某個范圍或者某個經(jīng)驗(yàn)值。

一般來講，我們可以認(rèn)為，最佳性能線程數(shù)==CPU邏輯核心數(shù)量，比如CPU是4核8線程，那么開8個線程可以達(dá)到性能最佳。
一般電腦是開啟超線程的，也就是4核可以模擬出8個邏輯核，故稱4核8線程。
QThreadPool線程池默認(rèn)最大線程數(shù)，也是CPU邏輯Core的數(shù)量。
嚴(yán)格意義來講，最佳線程數(shù)還與處理業(yè)務(wù)類型有關(guān)，如業(yè)務(wù)屬于IO密集型、CPU密集型，根據(jù)經(jīng)驗(yàn)推斷：

• IO密集型，頻繁讀取磁盤上的數(shù)據(jù)，或者需要通過網(wǎng)絡(luò)遠(yuǎn)程調(diào)用接口。線程數(shù)經(jīng)驗(yàn)值是：2N，其中N代表CPU邏輯Core數(shù)；
• CPU密集型，非常復(fù)雜的調(diào)用，循環(huán)次數(shù)很多，或者遞歸調(diào)用層次很深等。線程數(shù)經(jīng)驗(yàn)值是：N + 1，其中N代表CPU邏輯Core數(shù)。

三、線程池的原理

最佳性能線程數(shù)可以認(rèn)為等于CPU邏輯核心數(shù)量N，所以我們設(shè)計程序，為了得到更好的性能，需要實(shí)現(xiàn)如下的需求：

• 限制創(chuàng)建最大線程數(shù)量<=N；
• 盡可能復(fù)用線程，避免頻繁創(chuàng)建和銷毀線程資源，降低無謂消耗；
• 線程在空閑時，應(yīng)該休息，避免占用CPU資源；
• 線程在有業(yè)務(wù)需要處理時，需要激活；
• 當(dāng)業(yè)務(wù)來了，這N個線程如何分配；

上述問題，高度封裝的QThreadPool線程池可以解決。

線程池的優(yōu)點(diǎn)：

• 創(chuàng)建和銷毀線程需要和OS交互，少量線程影響不大，但是線程數(shù)量太大，勢必會影響性能，使用線程池可以這種開銷；
• 線程池維護(hù)一定數(shù)量的線程，使用時，將指定函數(shù)傳遞給線程池，線程池會在線程中執(zhí)行任務(wù)；
• 線程池，屬于對象池，對象池都是為了復(fù)用，以避免頻繁申請和釋放對象所造成的性能損失。
• 線程池創(chuàng)建好后，池內(nèi)默認(rèn)一個線程也沒有，當(dāng)通過相關(guān)函數(shù)加入任務(wù)后，線程池根據(jù)任務(wù)數(shù)量會自動創(chuàng)建線程，任務(wù)會合理分配到各個線程上執(zhí)行，但是線程總數(shù)量不會超過設(shè)定的最大值。
• 若任務(wù)處理完畢，則池內(nèi)所有線程進(jìn)入掛起狀態(tài)，不占用CPU時間片，待任務(wù)再次到來，便會激活部分或全部線程，處理任務(wù)。
• 若任務(wù)過多，當(dāng)前沒有空閑的線程，則新增任務(wù)會被放置到緩存隊(duì)列中，等待線程空閑后，再進(jìn)行處理，這樣，每個任務(wù)與線程可以有一個合理的分配，相當(dāng)于實(shí)現(xiàn)了業(yè)務(wù)處理的負(fù)載均衡。故而可以以最好的性能來處理業(yè)務(wù)。

四、QThreadPool線程池

下面是QThreadPool的常用函數(shù)：

int activeThreadCount() const //當(dāng)前的活動線程數(shù)量
 
void clear()//清除所有當(dāng)前排隊(duì)但未開始運(yùn)行的任務(wù)
 
int expiryTimeout() const//線程長時間未使用將會自動退出節(jié)約資源，此函數(shù)返回等待時間
 
int maxThreadCount() const//線程池可維護(hù)的最大線程數(shù)量
 
void releaseThread()//釋放被保留的線程
 
void reserveThread()//保留線程，此線程將不會占用最大線程數(shù)量，從而可能會引起當(dāng)前活動線程數(shù)量大于最大線程數(shù)量的情況
 
void setExpiryTimeout(int expiryTimeout)//設(shè)置線程回收的等待時間
 
void setMaxThreadCount(int maxThreadCount)//設(shè)置最大線程數(shù)量
 
void setStackSize(uint stackSize)//此屬性包含線程池工作線程的堆棧大小。
 
uint stackSize() const//堆大小
 
void start(QRunnable *runnable, int priority = 0)//加入一個運(yùn)算到隊(duì)列，注意start不一定立刻啟動，只是插入到隊(duì)列，排到了才會開始運(yùn)行。需要傳入QRunnable ，后續(xù)介紹
 
bool tryStart(QRunnable *runnable)//嘗試啟動一個
 
bool tryTake(QRunnable *runnable)//刪除隊(duì)列中的一個QRunnable，若當(dāng)前QRunnable 未啟動則返回成功，正在運(yùn)行則返回失敗
 
bool waitForDone(int?<i>msecs</i>?=?-1)//等待所有線程運(yùn)行結(jié)束并退出，參數(shù)為等待時間-1表示一直等待到最后一個線程退出

QRunnable類：所有runable對象的基類。
QRunnable類是一個接口, 用于表示需要執(zhí)行的任務(wù)或代碼段, 具體任務(wù)在run() 函數(shù)內(nèi)部實(shí)現(xiàn)?？梢允褂肣ThreadPool在各個獨(dú)立的線程中執(zhí)行代碼。如果autoDelete() 返回true (默認(rèn)值), QThreadPool將自動刪除QRunnable 。使用setAutoDelete() 可更改是否自動刪除。
QThreadPool 是創(chuàng)建線程池函數(shù)，QRunnable是線程池的線程具體執(zhí)行操作函數(shù)，兩者要搭配使用。

五、QThreadPool簡單示例

執(zhí)行效果如下：

#include <QCoreApplication>
#include <QThreadPool>
#include <QDebug>

class Task1 : public QRunnable
{
public:
    Task1()
    { }
    virtual ~Task1() override
    {
        qDebug() << "~Task1()";
    }

    virtual void run() override
    {
        qDebug() << "do Task1 work:" << QThread::currentThreadId();
    }
};

class Task2 : public QRunnable
{
public:
    Task2()
    { }
    virtual ~Task2() override
    {
        qDebug() << "~Task2()";
    }

    virtual void run() override
    {
        qDebug() << "do Task2 work:" << QThread::currentThreadId();
    }
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    Task1* task1 = new Task1();
    Task2* task2 = new Task2();

    QThreadPool threadPool;
    threadPool.start(task1);
    threadPool.start(task2);
    threadPool.waitForDone();

    return a.exec();
}

注意：
線程池使用時傳入繼承于的QRunnable類對象（并啟動該線程對象），并且線程池會自主釋放在其中的線程（提高程序性能），還能實(shí)現(xiàn)并發(fā)，提高效率；不過不能使用信號槽進(jìn)行通信，需要使用QMetaObject::invokeMethod進(jìn)行通信。

到此這篇關(guān)于Qt線程池QThreadPool的使用詳解的文章就介紹到這了,更多相關(guān)Qt線程池QThreadPool內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論