Qt之线程同步(生产者消费者模式 - QSemaphore)
简述
生产者将数据写入缓冲区,直到它到达缓冲区的末尾,此时,它将从开始位置重新启动,覆盖现有数据。消费者线程读取数据并将其写入标准错误。
Semaphore(信号量) 比 mutex(互斥量)有一个更高级的并发性。如果缓冲区的访问由一个 QMutex 把守,当生产者线程访问缓冲区时,消费者线程将无法访问。然而,有两个线程同一时间访问不同的缓冲区是没有害处的。
示例包括两个类:Producer 和 Consumer,均继承自 QThread。循环缓冲区用于这两个类之间的沟通,信号量用于保护全局变量。
另一种实现“生产者 - 消费者”模式的方案是使用 QWaitCondition 和 QMutex - Qt之线程同步(生产者消费者模式 - QWaitCondition)
- 简述
- 全局变量
- Producer
- Consumer
- main 函数
- 更多参考
全局变量
首先,一起来看循环缓冲区和相关的信号量:
const int DataSize = 100000;const int BufferSize = 8192;
char buffer[BufferSize];QSemaphore freeBytes(BufferSize);
QSemaphore usedBytes;
DataSize 是生产者将生成的数据数量,为了让示例尽可能地简单,把它定义为一个常数。BufferSize 是循环缓冲区的大小,小于 DataSize,这意味着在某一时刻生产者将达到缓冲区的末尾,会从开始位置重新启动。
要同步生产者和消费者,需要两个信号量。freeBytes 信号量用于控制缓冲区的 "free"
区域(生产者尚未填充数据,或消费者已经读取的区域)。usedBytes 信号量用于控制缓冲区的 "used"
区域(生产者已经填充数据,但消费者尚未读取的区域)。
总之,这些信号量确保生产者不会先于消费者超过 BufferSize 的大小,而消费者永远不会读取生产者尚未生成的数据。
freeBytes 信号量用 BufferSize 来初始化,因为最初整个缓冲区是空的。usedBytes 信号量初始化为 0(默认值,如果未指定)。
Producer
Producer 类的代码如下:
class Producer : public QThread
{
public:void run() Q_DECL_OVERRIDE{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();}}
};
生产者生成 DataSize 字节的数据。在往循环缓冲区写入一个字节之前,它必须使用 freeBytes 信号量来获得一个 "free"
字节。如果消费者没有与生产者保持着同样的速度,QSemaphore::acquire() 调用可能会阻塞。
最后,生产者使用 usedBytes 信号量释放一个字节。该 "free"
字节已成功转化为一个 "used"
字节,准备好供消费者读取。
Consumer
现在转向 Consumer 类:
class Consumer : public QThread
{Q_OBJECT
public:void run() Q_DECL_OVERRIDE{for (int i = 0; i < DataSize; ++i) {usedBytes.acquire();fprintf(stderr, "%c", buffer[i % BufferSize]);freeBytes.release();}fprintf(stderr, "\n");}signals:void stringConsumed(const QString &text);protected:bool finish;
};
代码非常类似于生产者,不同的是,获得 "used"
字节并释放一个 "free"
字节,而非相反。
main() 函数
在 main() 函数中,我们创建两个线程,并调用 QThread::wait(),以确保在退出之前,这两个线程有时间完成。
int main(int argc, char *argv[])
{QCoreApplication app(argc, argv);Producer producer;Consumer consumer;producer.start();consumer.start();producer.wait();consumer.wait();return 0;
}
当运行这个程序时,会发生什么呢?
最初,生产者是唯一一个可以做任何事情的线程,消费者阻塞并等待 usedBytes 信号量的释放(available() 初始数是 0)。一旦生产者把一个字节放入缓冲区,freeBytes.available() 就会变为 BufferSize - 1,并且 usedBytes.available() 变为 1。这时,可能发生两件事:要么消费者线程接管和读取字节,要么生产者开始生成第二个字节。
此示例中提出的“生产者 - 消费者”模式,适用于编写高并发多线程应用。在多处理器计算机中,程序可能比基于 mutex 的方案快达两倍之多,因为两个线程可以同一时间在缓冲区的不同部分处于激活状态。
要知道,这些好处并不总能实现,获取和释放一个 QSemaphore 是需要成本的。在实践中,可能需要把缓冲区分为块,并针对块操作而非单个字节。缓冲区的大小也是一个必须仔细选择的参数,需要基于实验。
Qt之线程同步(生产者消费者模式 - QSemaphore)相关推荐
- Java线程实现生产者—消费者模式
在这里插入代码片# Java 线程实现生产者-消费者模式 ##思路:实现类似消费者生产者线程之间通讯的功能,每创建一个工人,就让这个工人干活,干一段时间,工人自动消失,然后又去创建一个工人干活: 代码 ...
- Java线程实现生产者消费者模式
1 什么是生产者消费者模式 想一个现实生活中的例子,啤酒商---超市---消费者也就是我们,啤酒商生产了啤酒,然后将啤酒销售给了超市,我们消费之又会到超市将啤酒买回来自己喝,那么啤酒商和消费者之间是什 ...
- 13-多线程01 实现多线程 线程同步 生产者消费者
1.实现多线程 1.1简单了解多线程[理解] 是指从软件或者硬件上实现多个线程并发执行的技术. 具有多线程能力的计算机因有硬件支持而能够在同一时间执行多个线程,提升性能. 1.2并发和并行[理解] 并 ...
- 线程同步 生产者消费者 java_Java线程同步:生产者-消费者 模型(代码示例)
public class ThreadSyn { public static void main(String[] args) { new ThreadSyn(); } public ThreadSy ...
- Qt 实现的一个生产者消费者模式类
最近做公司项目遇到一个问题,加载20万的日志文件,解析后写入数据库中.做完后发现读文件.解析.写入数据依次搞下来,速度实在是太慢. 所以学习用多线程的来完成这个工作,考虑用生产者消费者模式来完成. 单 ...
- 线程同步-生产者消费者问题
在进行多线程编程时,难免还要碰到两个问题,那就线程间的互斥与同步: 线程同步是指线程之间所具有的一种制约关系,一个线程的执行依赖另一个线程的消息,当它没有得到另一个线程的消息时应等待,直到消息到达时才 ...
- 生产者消费者伪码_[线程同步]生产者消费者代码实现
生产者消费者问题是一个著名的线程同步问题,该问题描述如下: 有一个生产者在生产产品,这些产品将提供给若干个消费者去消费,为了使生产者和消费者能并发执行,在两者之间设置一个具有多个缓冲区的缓冲池,生产者 ...
- Qt之线程同步(生产者消费者模式 - QWaitCondition)
简述 生产者将数据写入缓冲区,直到它到达缓冲区的末尾,这时,它从开始位置重新启动,覆盖现有数据.消费者线程读取数据并将其写入标准错误. Wait condition(等待条件)比单独使用 mut ...
- 一文讲明生产者-消费者模式
核心是一个任务队列,生产者线程生产任务,并将任务添加到任务队列中,而消费者线程从任务队列中获取任务并执行.该模式有如下优点: 1 解耦 解耦的关键:组件之间的依赖关系和通信方式受限.生产者.消费者之间 ...
最新文章
- SDCC 2016 中国软件开发者大会盛大开幕
- C#微信公众号开发系列教程五(接收事件推送与消息排重)
- js实现图片上传预览及进度条
- 【linux高级程序设计】(第十三章)Linux Socket网络编程基础 2
- 信安教程第二版-第22章网站安全需求分析与安全保护工程
- 警惕“***性社工”现象
- Docker使用小结(四)发布镜像
- 锻造恒生O45:致广大而尽精微
- 基于ssm整合的web考勤管理系统
- word批量转PDF怎么转
- 《三国演义》分章节梗概
- 使用python下载网络上加密的ts格式视频,并用ffmpeg进行合成
- 深圳大学计算机专业保研率,深圳最好的公立大学(本科阶段)南方科技大学,2018级保研率应该会提高到30%...
- android 文字转语音(中文) TextSpeech
- CSDN大神多,在这里驻扎一下,沾沾神气
- 砖家:“IPV9” - 美国没有成功,中国搞成了
- python接口自动化-excel参数化二
- Windows7系统删除文件的相关问题【mfxp.com】
- 云队友丨跳槽?还是跳坑??
- 【洛谷】P1198 最大数
热门文章
- linux mysql 共享存储空间_Linux UDEV和为MySQL InnoDB共享表空间配置裸设备
- java 1.8 121,CentOS6.8(64位)安装JDK1.8.0_121
- Linux学习 - awk使用
- Mac插件分享——AE插件、PS插件、FCPX插件【持续更新中】
- java converter转换器_在SpringMVC中设置自定义类型转换器Converter
- php mysql 值是否丰在_php 查询数据库表 判断 某值是否存在
- 第十一届蓝桥杯青少组Python竞赛真题
- python小游戏之二
- 单片机涡轮流量传感器_迅尔仪表|同是涡轮流量计,为什么液体涡轮流量计不能测气体?...
- python3 获取当前日期_python3获取日期