消息队列测试代码

约定不等于承诺〃 2022-08-20 13:07 196阅读 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 条评论，196人围观）

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

相关阅读

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

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

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

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

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

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

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

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

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

相关消息队列

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

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

相关消息队列测试代码

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

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

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

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

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

相关线程消息队列代码

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

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

相关消息队列

消息队列是啥？我觉得大家都心知肚明，已经众所周知到不用解释的程度。不过，但凡学习、解释一样东西，都应该遵循 “它是什么？”、 “做什么用？”、 “为啥要用它”

╰半橙微兮°/ 2022年04月23日 08:42/ 0 赞/ 364 阅读

相关消息队列

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

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

相关消息队列

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

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