Qt 線程同步實(shí)例介紹是本文介紹的內(nèi)容，在Qt中使用線程，沒(méi)有Mfc中那么繁瑣，它提供了QThread線程類，提供了創(chuàng)建一個(gè)新的方法。線程通過(guò)重載QThread::run()函數(shù)來(lái)完成其操作的，這一點(diǎn)與Java中的線程類相似。

實(shí)現(xiàn)一個(gè)簡(jiǎn)單的繼承自QThread的用戶線程類，代碼如下。

class Thread : public QThread   
{  
public:  
    Thread();  
    void stop();  
protected:  
    virtual void run();  
private:  
    bool m_stop;  
};  
Thread::Thread()  
{  
    m_stop = false;  
}  
void Thread::stop()  
{  
    m_stop = true;  
}  
void Thread::run()  
{  
    while (!m_stop)  
    {  
        sleep(1);  
        qDebug("vic.MINg!");  
    }  
    qDebug("end!");  
} 

在以上的示例中可以看出，線程的編寫并不難！

啟動(dòng)線程的時(shí)候可以，調(diào)用函數(shù)QThread::start()，開始Thread線程對(duì)象。

停止線程的時(shí)候可以，調(diào)用函數(shù)QThread::terminate()，但是terminate()函數(shù)并不會(huì)立刻終止線程，該線程何時(shí)終止取決于操作系統(tǒng)的調(diào)度策略。需要注意的是，terminate()函數(shù)過(guò)于毒辣，它可能在線程執(zhí)行的任意一步終止執(zhí)行，從而產(chǎn)生不可預(yù)知的后果(如修改某個(gè)重要數(shù)據(jù)時(shí))，另外，它也沒(méi)有給線程任何清理現(xiàn)場(chǎng)的機(jī)會(huì)(如釋放內(nèi)存和鎖等)。

因此，停止線程可以，如上代碼所示，手寫函數(shù)stop()，使其線程柔和的退出。

線程停止后，應(yīng)調(diào)用QThread::wait()函數(shù)，它使的線程阻塞等待直到退出或超時(shí)。

貌似在Unix或Linux下編譯多線程應(yīng)用程序還必須在.pro文件中加入如下一行,它告訴qmake使用Qt庫(kù)中的線程版本。Windows上，Qt庫(kù)默認(rèn)就是線程的。

CONFIG += thread

介紹完了線程的創(chuàng)建，接下來(lái)走入正題了，多線程應(yīng)用程序的一個(gè)最普通的需求就是同步幾個(gè)線程。Qt提供了以下幾個(gè)類來(lái)完成這一點(diǎn)：QMutex、QMutexLocker、QSemphore、QWaitCondition。

當(dāng)然可能還包含QReadWriteLocker、QReadLocker、QWriteLocker，但線程同步是應(yīng)用很少，這里只做簡(jiǎn)單的講解！

QMutex、QMutexLocker

QMutex類提供了一個(gè)保護(hù)一段臨界區(qū)代碼的方法，他每次只允許一個(gè)線程訪問(wèn)這段臨界區(qū)代碼。QMutex::lock()函數(shù)用來(lái)鎖住互斥量，如果互斥量處于解鎖狀態(tài)，當(dāng)前線程就會(huì)立即抓住并鎖定它；否則當(dāng)前線程就會(huì)被阻塞，直到持有這個(gè)互斥量的線程對(duì)其解鎖。線程調(diào)用lock()函數(shù)后就會(huì)持有這個(gè)互斥量直到調(diào)用unlock()操作為止。QMutex還提供了一個(gè)tryLock()函數(shù)，如果互斥量已被鎖定，就立即返回。

現(xiàn)在使用QMutex保護(hù)上面的線程類的m_stop布爾變量，雖然沒(méi)啥用，但這里的目的只是為了演示下QMutex的用法~~

//thread.h頭文件，添加互斥量對(duì)象  
private:  
    ...  
    QMutex mutex;  
};  
void Thread::run()  
{  
    forever {  
        mutex.lock();  
        if (m_stop) {  
            m_stop = false;  
            mutex.unlock();  
            break;  
        }  
        mutex.unlock();  
        qDebug("vic.MINg!");  
    }  
    qDebug("end!");  
}  
void Thread::stop()  
{  
    mutex.lock();  
    m_stop = true;  
    mutex.unlock();  
} 

在這里QMutex能夠完全完成互斥操作，但是有些情況下QMutex類是無(wú)法某些特定的互斥操作的，下面舉個(gè)例子：

#p#

這里我們把void stop()函數(shù)，重新定義下，讓他以布爾形式返回，實(shí)際也沒(méi)有啥用...只為示例的演示效果~~

bool Thread::stop()  
{  
    m_stop = true;  
    return m_stop;  
} 

現(xiàn)在問(wèn)題出來(lái)了，如果要在stop()函數(shù)中使用mutex進(jìn)行互斥操作，但unlock()操作寫在那里？unlock()操作卻不得不再return之后，從而導(dǎo)致unlock()操作永遠(yuǎn)也無(wú)法執(zhí)行...

Qt提供了QMutexLocker類何以簡(jiǎn)化互斥量的處理，它在構(gòu)造函數(shù)中接受一個(gè)QMutex對(duì)象作為參數(shù)并將其鎖定，在析構(gòu)函數(shù)中解鎖這個(gè)互斥量。

這樣可以像下面這樣重新編寫stop()函數(shù)：

bool Thread::stop()  
{  
    QMutexLocker locker(&mutex);  
    m_stop = true;  
    return m_stop;  
} 

QReadWriteLocker、QReadLocker、QWriteLocker

下面是一段對(duì)QReadWriteLocker類的對(duì)象進(jìn)行，讀寫鎖的操作，比較簡(jiǎn)單，這里也不多做講解了，自己看吧 :)

MyData data;  
QReadWriteLock lock;  
void ReaderThread::run()  
{  
    ...  
    lock.lockForRead();  
    access_data_without_modifying_it(&data);  
    lock.unlock();  
    ...  
}  
void WriterThread::run()  
{  
    ...  
    lock.lockForWrite();  
    modify_data(&data);  
    lock.unlock();  
    ...  
} 

QSemphore

Qt中的信號(hào)量是由QSemaphore類提供的，信號(hào)量可以理解為互斥量功能的擴(kuò)展，互斥量只能鎖定一次而信號(hào)量可以獲取多次，它可以用來(lái)保護(hù)一定數(shù)量的同種資源。

acquire(n)函數(shù)用于獲取n個(gè)資源，當(dāng)沒(méi)有足夠的資源時(shí)調(diào)用者將被阻塞直到有足夠的可用資源。release(n)函數(shù)用于釋放n個(gè)資源。

QSemaphore類還提供了一個(gè)tryAcquire(n)函數(shù)，在沒(méi)有足夠的資源是該函數(shù)會(huì)立即返回。

一個(gè)典型的信號(hào)量應(yīng)用程序是在兩個(gè)線程間傳遞一定數(shù)量的數(shù)據(jù)(DataSize)，而這兩個(gè)線程使用一定大小(BufferSize)的共享循環(huán)緩存。

const int DataSize = 100000;  
const int BufferSize = 4096;  
char buffer[BufferSize]; 

生產(chǎn)者線程向緩存中寫入數(shù)據(jù)，直到它到達(dá)終點(diǎn)，然后在起點(diǎn)重新開始，覆蓋已經(jīng)存在的數(shù)據(jù)。消費(fèi)者線程讀取前者產(chǎn)生的數(shù)據(jù)。

生產(chǎn)者、消費(fèi)者實(shí)例中對(duì)同步的需求有兩處，如果生產(chǎn)者過(guò)快的產(chǎn)生數(shù)據(jù)，將會(huì)覆蓋消費(fèi)者還沒(méi)有讀取的數(shù)據(jù)，如果消費(fèi)者過(guò)快的讀取數(shù)據(jù)，將越過(guò)生產(chǎn)者并且讀取到一些垃圾數(shù)據(jù)。

解決這個(gè)問(wèn)題的一個(gè)有效的方法是使用兩個(gè)信號(hào)量：

QSemaphore freeSpace(BufferSize);  
QSemaphore usedSpace(0); 

freeSpace信號(hào)量控制生產(chǎn)者可以填充數(shù)據(jù)的緩存部分。usedSpace信號(hào)量控制消費(fèi)者可以讀取的區(qū)域。這兩個(gè)信號(hào)量是互補(bǔ)的。其中freeSpace信號(hào)量被初始化為BufferSize(4096)，表示程序一開始有BufferSize個(gè)緩沖區(qū)單元可被填充，而信號(hào)量usedSpace被初始化為0，表示程序一開始緩沖區(qū)中沒(méi)有數(shù)據(jù)可供讀取。

#p#

對(duì)于這個(gè)實(shí)例，每個(gè)字節(jié)就看作一個(gè)資源，實(shí)際應(yīng)用中常會(huì)在更大的單位上進(jìn)行操作，從而減小使用信號(hào)量帶來(lái)的開銷。

void Producer::run()  
{  
    for (int i = 0; i < DataSize; ++i) {  
        freeSpace.acquire();  
        buffer[i % BufferSize] = "MING"[uint(rand()) % 4];  
        usedSpace.release();  
    }  
} 

在生產(chǎn)者中，我們從獲取一個(gè)“自由的”字節(jié)開始。如果緩存被消費(fèi)者還沒(méi)有讀取的數(shù)據(jù)填滿，acquire()的調(diào)用就會(huì)阻塞，直到消費(fèi)者已經(jīng)開始消耗這些數(shù)據(jù)為止。一旦我們已經(jīng)獲取了這個(gè)字節(jié)，我們就用一些隨機(jī)數(shù)據(jù)("M"、"I"、"N"或"G")填充它并且把這個(gè)字節(jié)釋放為“使用的”,所以它可以被消費(fèi)者線程使用。

void Consumer::run()  
{  
    for (int i = 0; i < DataSize; ++i) {  
        usedSpace.acquire();  
        cerr << buffer[i % BufferSize];  
        freeSpace.release();  
    }  
    cerr << endl;  
} 

在消費(fèi)者中，我們從獲取一個(gè)“使用的”字節(jié)開始。如果緩存中沒(méi)有包含任何可讀的數(shù)據(jù)，acquire()調(diào)用將會(huì)阻塞，直到生產(chǎn)者已經(jīng)產(chǎn)生一些數(shù)據(jù)。一旦我們已經(jīng)獲取了這個(gè)字節(jié)，我們就打印它并且把這個(gè)字節(jié)釋放為“自由的”，使它可以被生產(chǎn)者使用來(lái)再次填充數(shù)據(jù)。

int main()  
{  
    Producer producer;  
    Consumer consumer;  
    producer.start();  
    consumer.start();  
    producer.wait();  
    consumer.wait();  
    return 0;  
} 

main()函數(shù)的功能比較簡(jiǎn)單，負(fù)責(zé)啟動(dòng)生產(chǎn)者和消費(fèi)者線程，然后等待其各自執(zhí)行完畢后自動(dòng)退出。

QWaitCondition

對(duì)生產(chǎn)者和消費(fèi)者問(wèn)題的另一個(gè)解決方法是使用QWaitCondition,它允許線程在一定條件下喚醒其他線程。其中wakeOne()函數(shù)在條件滿足時(shí)隨機(jī)喚醒一個(gè)等待線程，而wakeAll()函數(shù)則在條件滿足時(shí)喚醒所有等待線程。
下面重寫生產(chǎn)者和消費(fèi)者實(shí)例，以QMutex為等待條件，QWaitCondition允許一個(gè)線程在一定條件下喚醒其他線程。

const int DataSize = 100000;  
const int BufferSize = 4096;  
char buffer[BufferSize];  
QWaitCondition bufferIsNotFull;  
QWaitCondition bufferIsNotEmpty;  
QMutex mutex;  
int usedSpace = 0; 

在緩存之外，我們聲明了兩個(gè)QWaitCondition、一個(gè)QMutex和一個(gè)存儲(chǔ)了在緩存中有多少個(gè)“使用的”字節(jié)的變量。

void Producer::run()  
{  
    for (int i = 0; i < DataSize; ++i) {  
        mutex.lock();  
        if (usedSpace == BufferSize)  
            bufferIsNotFull.wait(&mutex);  
        buffer[i % BufferSize] = "MING"[uint(rand()) % 4];  
        ++usedSpace;  
        bufferIsNotEmpty.wakeAll();  
        mutex.unlock();  
    }  
} 

在生產(chǎn)者中，我們從檢查緩存是否充滿開始。如果是充滿的，我們等待“緩存不是充滿的”條件。當(dāng)這個(gè)條件滿足時(shí)，我們向緩存寫入一個(gè)字節(jié)，增加usedSpace，并且在喚醒任何等待這個(gè)“緩存不是空白的”條件變?yōu)檎娴?strong>線程。

for循環(huán)中的所有語(yǔ)句需要使用互斥量加以保護(hù)，以保護(hù)其操作的原子性。

bool wait ( QMutex * mutex, unsigned long time = ULONG_MAX ); 

這個(gè)函數(shù)做下說(shuō)明，該函數(shù)將互斥量解鎖并在此等待，它有兩個(gè)參數(shù)，第一個(gè)參數(shù)為一個(gè)鎖定的互斥量，第二個(gè)參數(shù)為等待時(shí)間。如果作為第一個(gè)參數(shù)的互斥量在調(diào)用是不是鎖定的或出現(xiàn)遞歸鎖定的情況，wait()函數(shù)將立即返回。

調(diào)用wait()操作的線程使得作為參數(shù)的互斥量在調(diào)用前變?yōu)殒i定狀態(tài)，然后自身被阻塞變成為等待狀態(tài)直到滿足以下條件：

其他線程調(diào)用了wakeOne()或者wakeAll()函數(shù)，這種情況下將返回"true"值。

第二個(gè)參數(shù)time超時(shí)(以毫秒記時(shí))，該參數(shù)默認(rèn)情況是ULONG_MAX，表示永不超時(shí)，這種情況下將返回"false"值。

wait()函數(shù)返回前會(huì)將互斥量參數(shù)重新設(shè)置為鎖定狀態(tài)，從而保證從鎖定狀態(tài)到等待狀態(tài)的原則性轉(zhuǎn)換。

void Consumer::run()  
{  
    forever {  
        mutex.lock();  
        if (usedSpace == 0)  
            bufferIsNotEmpty.wait(&mutex);  
        cerr << buffer[i % BufferSize];  
        --usedSpace;  
        bufferIsNotFull.wakeAll();  
        mutex.unlock();  
    }  
    cerr << endl;  
} 

消費(fèi)者做的和生產(chǎn)者正好相反，他等待“緩存不是空白的”條件并喚醒任何等待“緩存不是充滿的”的條件的線程。

main()函數(shù)與上面的基本相同，這個(gè)不再多說(shuō)。

在QThread類的靜態(tài)函數(shù)currentThread()，可以返回當(dāng)前線程的線程ID。在X11環(huán)境下，這個(gè)ID是一個(gè)unsigned long類型的值。

小結(jié)：關(guān)于 Qt 線程同步實(shí)例介紹的內(nèi)容介紹完了，希望本文對(duì)你有所幫助。