Qt線程的簡單使用（四）——QSemaphore的使用

參考資料：示例來源    http://www.cnblogs.com/venow/archive/2012/10/15/2724943.html

Qt 幫助手冊 QSemaphore

 

QSemaphore提供了一定數量的信號量。

一個 semaphore信號量是一種泛化的mutex。一個mutex只能被鎖住一次，但是semaphore被獲取多次。信號量通常被用於保護一定數量的同種資源。

Semaphore提供兩種基本的操作，acquire() and release():

Acquire(n)嘗試去n個資源。如果獲取不到足夠的資源，這個會一直鎖住直到可以獲取足夠的資源。

Release(n)釋放n個資源。

除了以上的方法，還有tryAcquire()函數，如果得不到足夠的資源會立即返回，available()函數，返回在任意時刻可用的資源數目。

以下是一個生產者/消費者的例子，可以理解QSemaphore的具體使用

#include <QtCore/QCoreApplication>
#include <QSemaphore>
#include <QThread>
#include <iostream>
#include <QTime>

const int DataSize = 100;
const int BufferSize = 10;
char buffer[BufferSize];
QSemaphore freeSpace (BufferSize);
QSemaphore usedSpace(0);
//1.BufferSize = 1 ,DataSize = 100,生產一個，消費一個。
//2.BufferSize = 100,DataSize = 100;先是大量生產。



//生產者
class Producer:public QThread
{
protected:
    void run()
    {
        qsrand(QTime(0,0,0).secsTo(QTime::currentTime()));
        qsrand(NULL);
        for (int i = 0;i < DataSize;++i)
        {
            freeSpace.acquire();
            std::cerr<<"P";
            usedSpace.release();
        }
    }
};
//消費者
class Consumer:public QThread
{
protected:
    void run()
    {
        for (int i = 0;i < DataSize;++i)
        {
            usedSpace.acquire();
            std::cerr<<"C";
            freeSpace.release();
        }
    }
};

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

    Producer producer;
    Consumer consumer;
    producer.start();
    consumer.start();
    producer.wait();

    consumer.wait();

    return a.exec();
}