在多线程开发中,经常需要控制多个线程对共享资源的访问数量。例如限制同时下载文件的数量、控制数据库连接池的连接使用等等。这时候,Qt 提供的 QSemaphore(信号量)就非常派得上用场。


一、什么是 QSemaphore?

QSemaphore 是 Qt 中提供的一种线程同步工具。它通过内部维护一个资源计数器,允许多个线程同时访问共享资源,但访问数量受到限制

它与互斥锁(QMutex)的区别在于:

  • QMutex 是互斥的,每次只允许一个线程进入临界区。
  • QSemaphore 是限量的,可以允许多个线程同时访问资源,但不会超过指定的最大数量。

可以把 QSemaphore 想象成一个“通行证发放器”:资源有限,有票的线程才能进入,无票的线程就只能等着。


二、典型应用场景

  • 同时最多只允许 N 个线程运行某项任务(例如下载器中最多允许 3 个并发下载)
  • 限制线程池中可用线程的最大数
  • 实现生产者-消费者模式中的缓冲区容量限制
  • 控制数据库连接池的并发访问数量

总之,任何需要限制并发访问数量的场景,QSemaphore 都能派上用场。


三、常用方法说明

方法名说明
acquire(int n = 1)申请 n 个资源,不足则阻塞线程,直到资源可用
release(int n = 1)释放 n 个资源,通知其他等待的线程
tryAcquire(int n = 1)尝试申请 n 个资源,如果资源不足,立即返回 false
available()获取当前可用的资源数量

四、实战案例:限制同时运行线程数

目标说明

创建 10 个线程,每个线程执行一项任务。但系统最多只允许 3 个线程同时执行,其余线程必须等待已有线程完成任务后再开始执行。


C++ 代码示例(基于 Qt)

#include <QCoreApplication>
#include <QThread>
#include <QSemaphore>
#include <QDebug>// 最大并发线程数设为 3
const int MAX_CONCURRENT = 3;
QSemaphore semaphore(MAX_CONCURRENT);// 自定义线程类
class Worker : public QThread
{int id;public:Worker(int id) : id(id) {}void run() override {// 申请资源,如果不足会阻塞semaphore.acquire();qDebug() << "线程" << id << "开始执行任务...";// 模拟任务耗时QThread::sleep(2);qDebug() << "线程" << id << "任务完成!";// 释放资源semaphore.release();}
};int main(int argc, char *argv[])
{QCoreApplication a(argc, argv);QList<Worker*> workers;// 启动 10 个线程for (int i = 0; i < 10; ++i) {Worker* w = new Worker(i + 1);workers.append(w);w->start();}// 等待所有线程执行完成for (Worker* w : workers) {w->wait();delete w;}qDebug() << "所有任务执行完毕!";return 0;
}

程序输出(示例)

线程1开始执行任务...
线程2开始执行任务...
线程3开始执行任务...
线程1任务完成!
线程4开始执行任务...
线程2任务完成!
线程5开始执行任务...
...
所有任务执行完毕!

可以看到:每次最多只有 3 个线程在执行任务,正是通过 QSemaphore 实现的并发控制。


五、代码讲解

  1. QSemaphore semaphore(MAX_CONCURRENT);
    初始化信号量对象,设定最大可用资源为 3,表示同时最多有 3 个线程能进入临界区。

  2. semaphore.acquire();
    当前线程申请一个资源。如果当前资源不足(即已经有 3 个线程在运行),该线程会被阻塞。

  3. semaphore.release();
    当前线程完成任务后,释放一个资源,让其他等待中的线程可以继续执行。


六、拓展建议

如果你希望进一步深入,可以尝试以下拓展:

  • acquire() 替换为 tryAcquire(),实现非阻塞式资源申请逻辑
  • QThreadPoolQRunnable 结合使用,构建线程池限流机制
  • 配合 GUI,加入任务进度条,构建一个多任务调度界面
  • 使用更复杂的资源数量控制(例如一次申请多个资源)

七、总结

QSemaphore 是多线程控制中非常实用的一种同步机制,它能有效地控制线程对资源的并发访问数量。相比于 QMutex 的一对一互斥,QSemaphore 提供了更灵活的“多对多”资源控制能力。

在并发任务调度、限流、连接池管理等场景中,都是非常实用的解决方案。


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/bicheng/95603.shtml
繁体地址,请注明出处:http://hk.pswp.cn/bicheng/95603.shtml
英文地址,请注明出处:http://en.pswp.cn/bicheng/95603.shtml

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Spark mapGroups 函数详解与多种用法示例

mapGroups 是 Spark 中一个强大的分组操作函数&#xff0c;它允许你对每个分组应用自定义逻辑并返回一个结果。以下是多个使用简单样例数据的具体用法示例。基础示例数据假设我们有一个简单的学生成绩数据集&#xff1a;// 创建示例DataFrame val studentScores Seq(("Ma…

【图论】Graphs.jl 图数据的读写与生成器

文章目录图数据的读写Graphs.loadgraphGraphs.loadgraphsGraphs.savegraph保存单个图保存图字典Graphs.loadlg_multGraphs.savelgGraphs.savelg_mult图的生成器1. 随机图模型1.1 Erdős–Rnyi 模型1.2 巴拉巴西-阿尔伯特模型 (无标度网络)1.3 小世界网络模型1.4 随机块模型 (SB…

Go指针全解析:从基础到实战

基本概念与定义指针的定义指针是一种特殊的变量类型&#xff0c;它存储的不是实际数据值&#xff0c;而是另一个变量在计算机内存中的地址。在底层实现上&#xff0c;指针本质上是保存内存位置的无符号整数&#xff0c;它直接指向内存中的特定位置&#xff0c;允许程序直接操作…

Oracle 查询有哪些用户 提示用户名密码无效

要查询 Oracle 数据库中的所有用户&#xff0c;可以使用以下 SQL 查询语句。这个查询将返回数据库中所有用户的列表。 [] SELECT username FROM all_users ORDER BY username;如果你有足够的权限&#xff08;通常是 DBA 权限&#xff09;&#xff0c;你也可以使用 dba_users 视…

小白成长之路-develops -jenkins部署lnmp平台

文章目录一、准备工作1.1两台虚拟机1.2配置文件1.3免密登录二、实战1.构建主item2.测试nginx,php,mysql2.1新建测试项目2.2与正式项目绑定构建后的操作2.3测试2.4导入discuz项目总结一、准备工作 1.1两台虚拟机 服务器&#xff1a;192.168.144.24 客户端&#xff1a;192.168.…

【HarmonyOS 6】仿AI唤起屏幕边缘流光特效

【HarmonyOS 6】仿AI唤起屏幕边缘流光特效 一、前言 最近在做 HarmonyOS 6.0 的适配&#xff0c;发现 Beta1版本里多了个很实用的视效功能——自带背景的双边流光。 之前做屏幕边缘流光特效的时候&#xff0c;要么得自己写渐变动画拼效果&#xff0c;要么就得套好几个组件叠层&…

跟做springboot尚品甄选项目

springbootvue3 【尚硅谷Java项目《尚品甄选》 SpringBootSpringCloud萌新学会企业级java项目】003.后台系统-搭建前端环境&#xff08;工程创建&#xff09;_哔哩哔哩_bilibili E:\project\AllProJect\Shangpin Selection\项目材料素材\课件\尚品甄选项目课件 前端套用框架…

【Linux】创建线程

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 文章目录 一、为什么需要线程&#xff1f; 创建线程 示例&#xff1a;计算斐波恩夕法 一、为什么需要线程&#xff1f; 在多核处理器的计算机上&#xff0c;线程可…

HTML应用指南:利用POST请求获取全国九号电动车体验店服务店位置信息

九号公司(Ninebot)作为全球领先的智能短途出行解决方案提供商,始终秉持“智慧移动,愉悦生活”的品牌理念,致力于为个人用户打造安全、智能、时尚的城市出行体验。依托“智能硬件 + 数字服务 + 线下触点”三位一体的战略布局,九号公司已建立起覆盖全国、辐射全球的销售与服…

Kafka面试精讲 Day 4:Consumer消费者模型与消费组

【Kafka面试精讲 Day 4】Consumer消费者模型与消费组 在“Kafka面试精讲”系列的第四天&#xff0c;我们将深入探讨Kafka的核心组件之一——Consumer消费者模型与消费组&#xff08;Consumer Group&#xff09;。这是Kafka实现高吞吐、可扩展消息消费的关键机制&#xff0c;也…

使用 Uni-app 打包 外链地址APK 及 iOS 注意事项

本文详细介绍了如何使用 Uni-app 框架将项目打包为 Android APK 和 iOS 应用&#xff0c;重点讲解了 minSdkVersion、targetSdkVersion 和 abiFilters 的配置&#xff0c;以及 iOS 开发的注意事项。文章还包含了您提供的 WebView 示例代码&#xff0c;并提供了关键的注意事项&a…

异常处理小妙招——3.构造函数的安全第一原则:为什么不在构造函数中抛出异常?

文章目录灾难性的生日派对构造函数&#xff1a;对象的出生证明安全第一&#xff1a;严格的出生检查为什么要在构造函数中严格验证&#xff1f;1. 避免"僵尸对象"2. Fail-Fast&#xff08;快速失败&#xff09;原则现实世界的实践建议1. 使用工厂方法模式2. 使用Build…

iptables 和 ip route

文章目录iptables原理及常用命令表链链表链表总结iptables 常用命令及参数1. 规则管理命令 (Commands)2. 规则匹配参数 (Rule-Specification - Matches)3. 目标动作参数 (Target)命令示例配置流程示例ip route常用命令iptables和ip route的联系实用命令示例对比iptables原理及常…

RPC和HTTP的区别?

RPC和HTTP是两种不同的通信协议&#xff0c;它们在通信方式、性能效率以及灵活性可扩展性等方面存在区别。以下是具体分析&#xff1a; 通信方式 RPC&#xff1a;RPC是基于远程过程调用的二进制协议&#xff0c;它允许客户端像调用本地函数一样调用远程服务器上的函数或方法[2]…

贝叶斯分类(Bayes Classify)

一. 核心思想贝叶斯分类是一类基于贝叶斯定理&#xff08;Bayes Theorem&#xff09;和概率统计的分类算法&#xff0c;核心思想是 “通过已知的先验概率&#xff0c;结合数据的似然性&#xff0c;计算后验概率&#xff0c;最终将样本归为后验概率最高的类别”。它在机器学习、…

怎么熟悉业务,我是做前端的,但对业务了解没有渠道

作为前端开发者&#xff0c;想深入了解业务但“没有渠道”&#xff0c;这是非常普遍的痛点。很多前端同学只接到“切图实现页面”的任务&#xff0c;久而久之就成了“实现工具人”。但业务理解力&#xff0c;恰恰是区分“初级”和“高级”前端的核心分水岭。 好消息是&#xff…

如何批量在PDF文档最后一页盖章?

在面对上百份需要处理的 PDF 文档时&#xff0c;逐个打开文档盖章再进行保存&#xff0c;这些步骤不仅提高我们工作的繁琐&#xff0c;还容易导致处理位置错误或遗漏。那么怎么去将 PDF 文档末页实现批量自动打上电子印章&#xff1f;一般的方式没有办法来满足我们高效率办公的…

Keras/TensorFlow 中 `predict()` 函数详细说明

Keras/TensorFlow 中 predict() 函数详细说明 predict() 是 Keras/TensorFlow 中用于模型推理的核心方法&#xff0c;用于对输入数据生成预测输出。下面我将从多个维度全面介绍这个函数的用法和细节。 一、基础语法和参数 基本形式 predictions model.predict(x,batch_sizeNon…

题解:UVA1589 象棋 Xiangqi

看到代码别急着走&#xff0c;还要解释呢&#xff01;哈哈&#xff0c;知道这个题我是怎么来的吗&#xff1f;和爸爸下象棋20场输17场和2场QWQ于是乎我就想找到一个可以自动帮我下棋的程序&#xff0c;在洛谷上面搜索&#xff0c;就搜索到了这个题。很好奇UVA的为啥空间限制是0…

基于YOLOv11的脑卒中目标检测及其完整数据集——推动智能医疗发展的新机遇!

在当今科技迅速发展的时代&#xff0c;脑卒中作为一种严重威胁人类健康的疾病&#xff0c;其早期的检测和及时的干预显得尤为重要。为此&#xff0c;本项目推出基于YOLOv11的脑卒中目标检测系统&#xff0c;结合完整的数据集&#xff0c;不仅提高了检测的效率&#xff0c;更为医…