消息队列测试代码

约定不等于承诺〃 2022-08-20 13:07 156阅读 0赞

#include "Queue.h"
    #include <iostream>
    
    void produce(Queue<int>& q) {
      for (int i = 0; i< 10000; ++i) {
        std::cout << "Pushing " << i << "\n";
        q.push(i);
      }
    }
    
    void consume(Queue<int>& q, unsigned int id) {
      for (int i = 0; i< 2500; ++i) {
        auto item = q.pop();
        std::cout << "Consumer " << id << " popped " << item << "\n";
      }
    }
    
    #include <thread>
    int main()
    {
      Queue<int> q;
    
      using namespace std::placeholders;
    
      // producer thread
      std::thread prod1(std::bind(produce, std::ref(q)));
    
      // consumer threads
      std::thread consumer1(std::bind(&consume, std::ref(q), 1));
      std::thread consumer2(std::bind(&consume, std::ref(q), 2));
      std::thread consumer3(std::bind(&consume, std::ref(q), 3));
      std::thread consumer4(std::bind(&consume, std::ref(q), 4));
    
      prod1.join();
      consumer1.join();
      consumer2.join();
      consumer3.join();
      consumer4.join();
    
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，156人围观）

还没有评论，来说两句吧...

相关阅读

相关【消息队列开发】实现DataBaseManagerTests（测试单元）

文章目录 * ?前言 * ?准备工作 * ?书写测试代码 * ⭕总结 ?前言今天我们来对前面所开发的数据库操作的功能进行测...

ゝ一世哀愁。/ 2024年04月17日 10:53/ 0 赞/ 47 阅读

相关消息队列测试场景和redis测试场景

![在这里插入图片描述][d6e5eeb06c5646a481469fe90906c0cf.jpeg_pic_center] -------------------- 一

r囧r小猫/ 2024年03月22日 14:55/ 0 赞/ 41 阅读

相关 Redis实现消息队列-代码实现2

Redis实现消息队列-代码实现一、前言二、代码项目结构图： ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10

系统管理员/ 2023年10月10日 12:52/ 0 赞/ 16 阅读

相关消息队列

1. 消息队列在项目中的使用背景：在分布式系统中是如何处理高并发的。由于在高并发的环境下，来不及同步处理用户发送的请求，则会导致请求发生阻塞。比如说，大量的ins

﹏ヽ暗。殇╰゛Y/ 2022年12月15日 03:23/ 0 赞/ 227 阅读

相关消息队列测试代码

include "Queue.h" include <iostream> void produce(Queue<int>& q) {

约定不等于承诺〃/ 2022年08月20日 13:07/ 0 赞/ 157 阅读

相关 redis作为消息队列实现代码

这里只是简单实现下redis消息队列，主要了解下这个思路要把消息队列最好，还需考虑可靠消费、可靠发布、持久化、路由匹配、队列监控、负载均衡。。。大都用专业的消息队列

ゞ浴缸里的玫瑰/ 2022年07月19日 00:17/ 0 赞/ 101 阅读

相关线程消息队列代码

blog原文地址：[https://www.cnblogs.com/lijingcheng/p/4454876.html][https_www.cnblogs.com_liji

Dear 丶/ 2022年05月12日 09:20/ 0 赞/ 139 阅读

相关消息队列

消息队列介绍维基百科上的描述：在计算机科学中，消息队列（Message queue）是一种进程间通信或同一进程的不同线程间的通信方式，软件的贮列用来处理一系列的输入，通

红太狼/ 2022年01月26日 10:51/ 0 赞/ 299 阅读

相关消息队列

为什么写这篇文章? 博主有两位朋友分别是小A和小B: 1. 小A，工作于传统软件行业(某社保局的软件外包公司)，每天工作内容就是和产品聊聊需求，改改业务逻辑。再不然就

小咪咪/ 2021年12月20日 06:51/ 0 赞/ 391 阅读

相关消息队列

消息队列前言什么是消息队列为什么要使用消息队列通过异步处理提高系统性能降低系统耦合性利用消息队

谁践踏了优雅/ 2021年11月05日 04:04/ 0 赞/ 455 阅读