Qt条件变量QWaitCondition使用教程

suoniao 2021-01-20
需要:0索币

条件变量允许一个线程通知其他的线程它们所等待的某个条件已经满足了,可以继续运行了。一个或多个线程可以在同一个条件变量上等待。当条件满足时,我们可以调用wakeOne()从所有等待在该条件变量上的线程中随机的唤醒一个线程继续运行,也可以使用wakeAll()方法同时唤醒所有等待在该条件变量上的线程。

另外,QWaitCondition和QSemaphore一样,要和QMutex配合使用,因为要访问到共享资源。

下面,我们使用常见的生产者-消费者问题来演示一下条件变量的使用。

新建一个Qt控制台程序,再新建两个线程类Producer和Consumer,继承自QThread类。

我们先在main.cpp中,声明我们要用到的全局变量。代码如下:

  1. #include <QCoreApplication>
  2. #include <QWaitCondition>
  3. #include <QMutex>
  4. #include <QQueue>
  5. QQueue<int> buffer;
  6. QMutex mutex;
  7. QWaitCondition fullCond;
  8. QWaitCondition emptyCond;
  9. int main(int argc, char *argv[])
  10. {
  11. QCoreApplication a(argc, argv);
  12. return a.exec();
  13. }

其中,buffer就是我们的缓冲区,mutex是保护缓存区的互斥锁,条件变量fullCond是用来等待缓冲区变满(有数据),条件变量emptyCond是用来等待缓冲区变为空。

下面来实现我们的消费者和生产者线程:

生产者代码如下:

  1. void Producer::run()
  2. {
  3. while(true)
  4. {
  5. mutex.lock();
  6. while(buffer.size() >= 10)
  7. {
  8. emptyCond.wait(&mutex);
  9. }
  10. int num = rand();
  11. buffer.enqueue(num);
  12. qDebug() << "enqueue: " << num;
  13. mutex.unlock();
  14. fullCond.wakeAll();
  15. }
  16. }

此处,我们假定缓冲区最多存储10个元素。所以,我们先判断缓冲区是否已满,如果已满,则等待其变为空,否则,产生一个随机数放入队列中,最后通知消费者线程,可以进行消费。

消费者代码如下:

  1. void Consumer::run()
  2. {
  3. while(true)
  4. {
  5. mutex.lock();
  6. while(buffer.size() <= 0)
  7. {
  8. fullCond.wait(&mutex);
  9. }
  10. qDebug() << "dequeue: " << buffer.dequeue();
  11. mutex.unlock();
  12. emptyCond.wakeAll();
  13. }
  14. }

对于消费者来说,要先判断缓冲区是否有数据可消费,如果没有,则等待其生产者生产出新的数据,如果有,则消费一个数据,最后,通知生产者继续生产。

运行结果如下:



可以看出,几乎是生产者生产一个数据,消费者就消费一个。如果想看到累积的效果,可以使用线程睡眠来实现,大家可以自行测试

回帖
  • 消灭零回复
广告位招租 100元/月 广告位招租 100元/月
相关主题
QT程序闪退错误捕获教程利用DbgHelp 错误调试技术 0
使用CMAKE 配置TagLIb QT5 编译使用TagLib 0
QT实现Excel文件转CSV文件利用QAxObject库 0
QT实现Excel转PDF利用QAxObject库 0
Qt利用QAxWidget读取excel文件 0
Qt条件变量QWaitCondition使用教程 0
Qtcreator cannot open output file debug/suoniao.exe:Permission denied 0
Qt的对象树模型 Qt内存泄漏的原因分析 0
Qt有关QdateTime方法详解 0
Qt基础教程值QByteArray字节容器的使用详解 0
Qt读取打印机设备列表QPrinterInfo类实现 0
Qt利用QFile和QTextStream实现文件的读和写 0
Qt利用map映射读取超大文件 0
Qt高频率读取串口或者写入串口导致运行程序内存占用不断提升 0
QT实现HTTP协议 出现failed to load resource : net :: ERR_CONNECTION_RESET 0
C++相关视频教程合辑 0
C++界面库 Qt嵌入式开发从入门到精通 1604 0
c++就业班13期完整教程 2339 0
就业班C++培训完整版教程移动打车项目安全传输平台项目2504 0
C语言和C++就业班15期培训教程2502 0
相关主题
索鸟快传2.1.0版本发布 0
golang网络数据读取timeout的处理 – 以SetReadDeadline为例 0
索鸟网广告位招租 0
golang利用通道chan实现一个通用的TCP连接池 0
frpc和frps的交互流程详解了解了frp是如何进行TCP代理的 0
golang实现内存池 go语言字节池byte pool实现代码 0
golang网络编程之基于TCP协议实现长连接 golang心跳检测 0
国产光刻机产业链最新核心材料ArF 193nm光刻胶通过用户认证 0
javascript数组相关函数length属性、delete关键字、pop()栈方法、shift() 0
Qt为我们提供了几个可以用于线程Sleep的函数msleep和usleep 0
QT程序闪退错误捕获教程利用DbgHelp 错误调试技术 0
简单快速修改Qtcreator项目工程的名称 0
golang 的interface接口类型断言 0
golang类型断言type的使用 0
golang依赖包管理 mod使用教程 0
golang表单验证库validator 0
如何使用Go语言实现一个简单的异步任务框架呢?生产者消费者模型 0
内网穿透反向代理工具frp实现TCP协议代理源码分析 0
内网穿透反向代理库frp的实现原理分析一 0
什么是socks5?socks5 是一个简单的代理协议 0