c++如何实现一个阻塞队列 c++生产者消费者模型【实例】

什么是阻塞队列

阻塞队列是一种线程安全的队列，当队列为空时，消费者线程调用 pop() 会自动等待，直到有新元素入队；当队列为满时（如有容量限制），生产者线程调用 push() 也会等待，直到有空位。这种“自动等待+唤醒”机制，天然适配生产者-消费者模型。

核心实现要点

要用 C++ 实现一个可靠的阻塞队列，需结合以下三要素：

• std::queue 或 std::deque 作为底层容器（推荐 deque，支持高效首尾操作）
• std::mutex 保护共享数据，防止多线程并发访问冲突
• std::condition_variable 实现线程挂起与唤醒：一个用于“非空”通知（消费者等数据），一个用于“非满”通知（生产者等空间）——若无容量限制，可只用一个条件变量

无界阻塞队列示例（常用场景）

下面是一个简洁、可直接运行的无界阻塞队列实现（支持 move 语义，线程安全）：

#include 
#include 
#include 
#include 
template 
class BlockingQueue {
private:
std::queue queue;
mutable std::mutex mtx;
std::condition_variable notempty;
std::condition_variable notfull; // 可选，无界时仅作占位
public:
void push(T item) {
std::uniquelock lock(mtx);
queue_.push(std::move(item));
notempty.notify_one(); // 唤醒等待消费的线程
}
T pop() {
    std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(mtx_);
    not_empty_.wait(lock, [this] { return !queue_.empty(); });
    T item = std::move(queue_.front());
    queue_.pop();
    return item;
}

// 带超时的 pop（避免永久阻塞）
bool pop(T& item, std::chrono::milliseconds timeout) {
    std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(mtx_);
    if (not_empty_.wait_for(lock, timeout, [this] { return !queue_.empty(); })) {
        item = std::move(queue_.front());
        queue_.pop();
        return true;
    }
    return false;
}

bool empty() const {
    std::unique_lockzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(mtx_);
    return queue_.empty();
}
};
生产者-消费者完整实例
用上面的 BlockingQueue 启动多个生产者和消费者线程，模拟真实协作：
#include 
#include 
#include 
#include 
BlockingQueue bq;
void producer(int id, int count) {
for (int i = 0; i < count; ++i) {
int val = id * 100 + i;
bq.push(val);
std::cout << "[P" << id << "] pushed " << val << "\n";
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
}
void consumer(int id) {
while (true) {
int val;
if (bq.pop(val, std::chrono::milliseconds(500))) {
std::cout << "[C" << id << "] consumed " << val << "\n";
} else {
std::cout << "[C" << id << "] timeout, exiting...\n";
break;
}
}
}
int main() {
std::vector producers, consumers;
// 启动 2 个生产者，各发 3 个数
for (int i = 0; i zuojiankuohaophpcn 2; ++i) {
    producers.emplace_back(producer, i, 3);
}

// 启动 3 个消费者
for (int i = 0; i zuojiankuohaophpcn 3; ++i) {
    consumers.emplace_back(consumer, i);
}

for (auto& t : producers) t.join();
for (auto& t : consumers) t.join();

return 0;
}
编译运行时加 -std=c++17 -pthread。输出会交错显示生产和消费过程，体现线程间自然同步。
注意事项与优化建议
实际工程中还需考虑：

若需有界队列，构造时传入最大容量，在 push() 中检查并用 not_full_.wait() 阻塞
增加 stop() 接口配合 std::atomic_bool 实现优雅退出（避免消费者无限等待）
对频繁操作场景，可用 std::deque 替代 std::queue 获得更好缓存局部性
避免在锁内做耗时操作（如 I/O、复杂计算），保持临界区尽量短
 
		


# ai 
# c++ 
# ios 
# stream 
# 并发访问 
# int 
# 接口 
# 线程 
# 多线程 
# 并发 
# 无界 
# 是一个 
# 是一种 
# 也会 
# 多个 
# 如有 
# 要用 
# 可选 
# 可直接 
# 最大容量 
 




相关文章：
 ,南京靠谱的征婚网站？ 
C#如何序列化对象为XML XmlSerializer用法 
宝塔建站教程：一键部署配置流程与SEO优化实战指南 
如何用PHP快速搭建高效网站？分步指南 
 成都网站制作报价公司,成都工业用气开户费用？ 
详解jQuery停止动画——stop()方法的使用 
香港服务器如何优化才能显著提升网站加载速度？ 
 杭州银行网站设计制作流程,杭州银行怎么开通认证方式？ 
子杰智能建站系统｜零代码开发与AI生成SEO优化指南 
 制作企业网站建设方案,怎样建设一个公司网站？ 
 长春网站建设制作公司,长春的网络公司怎么样主要是能做网站的？ 
 开封网站制作公司,网络用语开封是什么意思？ 
高端云建站费用究竟需要多少预算？ 
建站之星ASP如何实现CMS高效搭建与安全管理？ 
 网站制作大概要多少钱一个,做一个平台网站大概多少钱？ 
常州自助建站工具推荐：低成本搭建与模板选择技巧 
 道歉网站制作流程,世纪佳缘致歉小吴事件，相亲网站身份信息伪造该如何稽查？ 
建站主机空间推荐  高性价比配置与快速部署方案解析 
 我的世界制作壁纸网站下载,手机怎么换我的世界壁纸？ 
 兔展官网 在线制作,怎样制作微信请帖？ 
c# 在ASP.NET Core中管理和取消后台任务 
 如何做静态网页,sublimetext3.0制作静态网页？ 
建站主机选哪种环境更利于SEO优化？ 
香港服务器租用费用高吗？如何避免常见误区？ 
 内网网站制作软件,内网的网站如何发布到外网？ 
如何撰写建站申请书？关键要点有哪些？ 
 深圳网站制作案例,网页的相关名词有哪些？ 
 网站制作费用多少钱,一个网站的运营，需要哪些费用？ 
建站之星如何修改网站生成路径？ 
如何快速启动建站代理加盟业务？ 
黑客如何利用漏洞与弱口令入侵网站服务器？ 
平台云上自主建站：模板化设计与智能工具打造高效网站 
 简易网站制作视频教程,使用记事本编写一个简单的网页html文件？ 
 湖州网站制作公司有哪些,浙江中蓝新能源公司官网？ 
如何高效完成独享虚拟主机建站？ 
如何在Golang中使用replace替换模块_指定本地或远程路径 
如何确认建站备案号应放置的具体位置？ 
Python路径拼接规范_跨平台处理说明【指导】 
 车管所网站制作流程,交警当场开简易程序处罚决定书，在交警网站查询不到怎么办？ 
如何在万网自助建站平台快速创建网站？ 
 西安大型网站制作公司,西安招聘网站最好的是哪个？ 
如何在万网自助建站中设置域名及备案？ 
 ppt在线制作免费网站推荐,有什么下载免费的ppt模板网站？ 
 制作销售网站教学视频,销售网站有哪些？ 
 中山网站推广排名,中山信息港登录入口？ 
 制作网站建设的公司有哪些,网站建设比较好的公司都有哪些？ 
 网站制作公司哪里好做,成都网站制作公司哪家做得比较好，更正规？ 
 可靠的网站设计制作软件,做网站设计需要什么样的电脑配置？ 
高端建站三要素：定制模板、企业官网与响应式设计优化 
如何在Windows环境下新建FTP站点并设置权限？