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一起用。
