日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > c/c++ >内容正文

c/c++

QTcreator 多线程(生产者消费者)

發布時間:2025/4/5 c/c++ 23 豆豆
生活随笔 收集整理的這篇文章主要介紹了 QTcreator 多线程(生产者消费者) 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

qt應用的多線程實例簡單實現,語法超級簡單,用兩種方法實現同步和互斥。一種是Semaphore信號量,另一種是mutex鎖和condition條件變量。下面開始。

第一種,QSemaphore信號量方式:

通過Qt Creator創建一個控制臺項目,項目創建完以后只有一個main.cpp文件和一個.pro配置文件,在main.cpp添加如下內容

#include <QSemaphore> #include <QThread> #include <QApplication>const qint32 DataSize=10; const qint32 BufferSize=4;//倉庫 int buffer[BufferSize]; //控制生產者線程信號量:寫入的數據緩沖區 QSemaphore freeSpace(BufferSize); //控制消費者線程信號量:讀取的數據緩沖區 QSemaphore usedSpace(0);//生產者線程類 class threadProducer:public QThread { public:void run(){for(int i=0;i<DataSize;++i){//倉庫有空閑位置,生產一個數據//空閑位置少一個,控制生產的信號量加一freeSpace.acquire();buffer[i%4]=i+1;qDebug("producer::%d",buffer[i%4]);//可消費的數據多一個,控制消費者信號量+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;//生產者線程類 class threadProducer:public QThread { public:void run(){for (int i=0; i<DataSize; ++i){mutex.lock();//如果倉庫滿了,不生產,等待銷費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(); }

?

總結

以上是生活随笔為你收集整理的QTcreator 多线程(生产者消费者)的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。