Qt多線程同步總結


1、QMutex

 
QMutex mutex;
 
void func()
{
mutex.lock();
........
mutex.unlock();
}
 
在復雜函數或者異常處理中,對mutex進行lock()和unlock()操作將會很復雜,進入點要lock(),在所有跳出點都要unlock(),想想都蛋疼!忘記unlock()將是很苦逼的事情,所以Qt引進了QMutexLocker來避免lock()和unlock()操作。
 
QMutex mutex;
 
void complexFunc()
{
QMutexLocker locker(&mutex);//在函數需要的地方建立QMutexLocker對象,並把mutex指針傳進來就好了,后面什么事情也不用做了,等到退出函數后,這個QMutexLocker對象局部變量會自己銷毀,銷毀了就解鎖了。方便吧。當然,你也可以調用locker.unlock()給mutex解鎖,然后再調用locker.relock()再鎖住mutex。也可以調用locker.mutex()獲取建立locker時引入的那個mutex的指針。是不是很方便?
..........
        ............
}
 
3、QReadWriteLock
這個允許多個進程同時讀,但是只有一個寫。而且寫讀不能同時進行。
 
QReadWriteLock lock;
 
void write()
{
lock.lockForWrite();//為寫而鎖
..........
lock.unlock();//解鎖
}
 
void read()
{
lock.lockForRead();//為讀而鎖
..............
lock.unlock();//解鎖
}
 
 
這個有點類似於QMutex和QMutexLocker。也是為了避免那些復雜的lockForRead()/lockForWrite()和unlock()操作,要是程序流程復雜起來實在是很讓人小心謹慎到蛋疼。但是聯手QReadLocker和QWriteLocker后就不一樣了。
QReadWriteLock lock;
 
void write()
{
QReadLocker locker(&lock);
..........
}
 
void read()
{
QWriteLocker locker(&lock);
..............
}
 
 
QReadLocker和QWriteLocker的成員函數都一模一樣,退出函數的時局部變量locker會自動銷毀,講lock自動解鎖。也可以調用locker.unlock()給lock解鎖,然后再調用locker.relock()再鎖住lock。也可以調用locker.readWriteLock()獲取建立locker時引入的那個lock的指針。
 
5、QSemaphore
 
它的成員函數是
QSemaphore ( int n = 0 )//建立對象時可以給它n個資源
~QSemaphore ()
void acquire ( int n = 1 )// 這個操作一次減少n個資源,如果現有資源不到n個就會阻塞
int available () const   //返回當前可用的QSemaphore資源個數
void release ( int n = 1 )//這個操作一次增加n個資源
bool tryAcquire ( int n = 1 )//類似於acquire,但是申請不到n個資源時不會阻塞會立即返回
bool tryAcquire ( int n, int timeout )
 
下面舉生產者-消費者例子說明
 
 const int DataSize = 100000;//要生產的數據個數
 const int BufferSize = 8192;//用於盛數據的緩存大小
 char buffer[BufferSize];
 
//要定義兩個信號量,一個用於表示自由空間,一個用於表示已用空間
 QSemaphore freeBytes(BufferSize);//自由空間初始化大小當然等於緩存大小啦
 QSemaphore usedBytes;
 
class Producer : public QThread
 {
 public:
     void run();
 };
 
 void Producer::run()
 {
     qsrand(QTime(0,0,0).secsTo(QTime::currentTime()));
     for (int i = 0; i < DataSize; ++i) {
         freeBytes.acquire();//申請一個自由空間,沒有就阻塞
         buffer[i % BufferSize] = "ACGT"[(int)qrand() % 4];
         usedBytes.release();//已用空間增加一個,有貨啦!
     }
 }
 
 
class Consumer : public QThread
 {
 public:
     void run();
 };
 
 void Consumer::run()
 {
     for (int i = 0; i < DataSize; ++i) {
         usedBytes.acquire();
         fprintf(stderr, "%c", buffer[i % BufferSize]);
         freeBytes.release();
     }
     fprintf(stderr, "\n");
 }
 
int main(int argc, char *argv[])
 {
     QCoreApplication app(argc, argv);
     Producer producer;
     Consumer consumer;
     producer.start();
     consumer.start();
     producer.wait();
     consumer.wait();
     return 0;
 }
 
 
QWaitCondition最大的好處,我覺得,是能在一個線程中喚醒一個或多個其它線程,當然前提是,其它線程在等待某個QWaitCondition,否則不起作用,你喚醒也沒用。QWaitCondition必須與QMutex或者QReadwriteLock一起用。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM