qt應(yīng)用的多線程實(shí)例簡(jiǎn)單實(shí)現(xiàn)，語法超級(jí)簡(jiǎn)單，用兩種方法實(shí)現(xiàn)同步和互斥。一種是Semaphore信號(hào)量，另一種是mutex鎖和condition條件變量。下面開始。

第一種，QSemaphore信號(hào)量方式：

通過Qt Creator創(chuàng)建一個(gè)控制臺(tái)項(xiàng)目，項(xiàng)目創(chuàng)建完以后只有一個(gè)main.cpp文件和一個(gè).pro配置文件，在main.cpp添加如下內(nèi)容

#include <QSemaphore> #include <QThread> #include <QApplication>const qint32 DataSize=10; const qint32 BufferSize=4;//倉庫 int buffer[BufferSize]; //控制生產(chǎn)者線程信號(hào)量：寫入的數(shù)據(jù)緩沖區(qū) QSemaphore freeSpace(BufferSize); //控制消費(fèi)者線程信號(hào)量：讀取的數(shù)據(jù)緩沖區(qū) QSemaphore usedSpace(0);//生產(chǎn)者線程類 class threadProducer:public QThread { public:void run(){for(int i=0;i<DataSize;++i){//倉庫有空閑位置，生產(chǎn)一個(gè)數(shù)據(jù)//空閑位置少一個(gè)，控制生產(chǎn)的信號(hào)量加一freeSpace.acquire();buffer[i%4]=i+1;qDebug("producer::%d",buffer[i%4]);//可消費(fèi)的數(shù)據(jù)多一個(gè)，控制消費(fèi)者信號(hào)量+1usedSpace.release();sleep(1);}} }; class threadConsumer:public QThread { public:void run(){for(int i=0;i<DataSize;++i){usedSpace.acquire();qDebug("consumer:%d",buffer[i%4]);freeSpace.release();sleep(2);}} };int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);threadConsumer consumer;threadProducer producer;producer.start();consumer.start();producer.wait();consumer.wait();return a.exec(); }

第二種，QWaitCondition和QMutex方式

#include <QCoreApplication> #include <QThread> #include <QWaitCondition> #include <QMutex>const qint32 DataSize=10; const qint32 BufferSize=4;int buffer[BufferSize]; QWaitCondition bufferIsNotFull; QWaitCondition bufferIsNotEmpty; QMutex mutex; int usedSpace=0;//生產(chǎn)者線程類 class threadProducer:public QThread { public:void run(){for (int i=0; i<DataSize; ++i){mutex.lock();//如果倉庫滿了，不生產(chǎn)，等待銷費(fèi)while (usedSpace==BufferSize){bufferIsNotFull.wait(&mutex);}buffer[i%4]=i+1;qDebug("producer:%d",buffer[i%4]);++usedSpace;bufferIsNotEmpty.wakeAll();mutex.unlock();}} };class threadConsumer:public QThread { public:void run(){for(int i=0;i<DataSize;++i){mutex.lock();while (usedSpace==0){bufferIsNotEmpty.wait(&mutex);}qDebug("consumer:%d",buffer[i%4]);--usedSpace;bufferIsNotFull.wakeAll();mutex.unlock();}} };int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);threadConsumer consumer;threadProducer producer;producer.start();consumer.start();producer.wait();consumer.wait();return a.exec(); }

?

總結(jié)

以上是生活随笔為你收集整理的QTcreator 多线程（生产者消费者）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。