【CPP】单生产者单消费者无锁队列使用记录

2024-08-25 01:28
文章标签 使用 记录 队列 生产者 消费者 cpp 无锁

本文主要是介绍【CPP】单生产者单消费者无锁队列使用记录，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

无锁队列地址：https://github.com/cameron314/readerwriterqueue

该仓库提供三种队列：

  • 无锁队列
  • 带阻塞与超时的无锁队列
  • 无锁环形缓存
    以下通过三个官方例子与简要说明进行阐述。

1. 无锁队列

1.1 打印输出函数

#include <readerwriterqueue.h>
#include <iostream>template <class T>
void PrintQueue(moodycamel::ReaderWriterQueue<T>& queue, const char* description = nullptr) {std::cout << "------------------------------------------------ " << std::endl;std::cout << "description  : " << description << std::endl;std::cout << "max_capacity : " << queue.max_capacity() << std::endl;std::cout << "size_approx  : " << queue.size_approx() << std::endl;std::cout << "peek address : " << queue.peek() << std::endl;T    element;bool succeeded;while (queue.size_approx() > 0) {succeeded = queue.try_dequeue(element);if (succeeded) {std::cout << element << " ";}}std::cout << std::endl;
}

1.2 查看基本信息

{// 默认构造moodycamel::ReaderWriterQueue<int> q;  // max_capacity: 15PrintQueue(q, "default");// 有参构造，查看最大容量moodycamel::ReaderWriterQueue<int> q3(3);  // max_capacity: 3PrintQueue(q3, "3");// 有参构造，查看最大容量moodycamel::ReaderWriterQueue<int> q5(5);  // max_capacity: 7PrintQueue(q5, "5");
}

输出：

------------------------------------------------ 
description  : default
max_capacity : 15
size_approx  : 0
peek address : 0------------------------------------------------ 
description  : 3
max_capacity : 3
size_approx  : 0
peek address : 0------------------------------------------------ 
description  : 5
max_capacity : 7
size_approx  : 0
peek address : 0

注意
如果给定的容量大小为2^n -1，则容量为指定值；否则，容量为大于给定值且最小的2^n-1

1.3 插入元素

1.3.1 enqueue/emplace

{moodycamel::ReaderWriterQueue<int> q(3);PrintQueue(q, "init");for (int index = 0; index < 5; index++) {// q.enqueue(index);q.emplace(index);}PrintQueue(q, "enqueue/emplace");  // 0 1 2 3 4 5 6 7
}

输出：

------------------------------------------------ 
description  : init
max_capacity : 3
size_approx  : 0
peek address : 0------------------------------------------------ 
description  : enqueue/emplace
max_capacity : 10
size_approx  : 5
peek address : 0x7e5ca0
0 1 2 3 4

注意
函数enqueue/emplace在队列满后，会分配新的空间以存放插入元素。队列的容量会发生变化。这里仅验证了二次分配的规律：

指定大小容量大小二次分配容量大小
3310
5722
91546

二次分配的容量为首次分配容量的三倍减一，即3n-1

1.3.2 try_enqueue/try_emplace

{moodycamel::ReaderWriterQueue<int> q(5);for (int index = 0; index < 10; index++) {// q.try_emplace(index);if (!q.try_enqueue(index)) {std::cout << "Insert element is failed, element: " << index << std::endl;}}PrintQueue(q, "try_enqueue/try_emplace");  // 0 1 2 3 4 5 6
}

输出

Insert element is failed, element: 7
Insert element is failed, element: 8
Insert element is failed, element: 9
------------------------------------------------ 
description  : try_enqueue/try_emplace
max_capacity : 7
size_approx  : 7
peek address : 0x725ca0
0 1 2 3 4 5 6

注意
函数try_enqueue/try_emplace在队列满时，不会分配新的空间以存储插入元素。插入元素被丢弃。

1.4 完整代码

#include <readerwriterqueue.h>#include <iostream>template <class T>
void PrintQueue(moodycamel::ReaderWriterQueue<T>& queue, const char* description = nullptr) {std::cout << "------------------------------------------------ " << std::endl;std::cout << "description  : " << description << std::endl;std::cout << "max_capacity : " << queue.max_capacity() << std::endl;std::cout << "size_approx  : " << queue.size_approx() << std::endl;std::cout << "peek address : " << queue.peek() << std::endl;T    element;bool succeeded;while (queue.size_approx() > 0) {succeeded = queue.try_dequeue(element);if (succeeded) {std::cout << element << " ";}}std::cout << std::endl;
}int main() {{// 默认构造moodycamel::ReaderWriterQueue<int> q;  // max_capacity: 15PrintQueue(q, "default");// 有参构造，查看最大容量moodycamel::ReaderWriterQueue<int> q3(3);  // max_capacity: 3PrintQueue(q3, "3");// 有参构造，查看最大容量moodycamel::ReaderWriterQueue<int> q5(5);  // max_capacity: 7PrintQueue(q5, "5");}{moodycamel::ReaderWriterQueue<int> q(5);for (int index = 0; index < 10; index++) {// q.try_emplace(index);if (!q.try_enqueue(index)) {std::cout << "Insert element is failed, element: " << index << std::endl;}}PrintQueue(q, "try_enqueue/try_emplace");  // 0 1 2 3 4 5 6}{moodycamel::ReaderWriterQueue<int> q(3);PrintQueue(q, "init");for (int index = 0; index < 5; index++) {// q.enqueue(index);q.emplace(index);}PrintQueue(q, "enqueue/emplace");  // 0 1 2 3 4 5 6 7}return EXIT_SUCCESS;
}

2. 带阻塞与超时的无锁队列

基本使用与无所队列相同，提供了额外的阻塞函数。

#include <readerwriterqueue.h>#include <iostream>template <class T>
void PrintQueue(moodycamel::BlockingReaderWriterQueue<T>& queue, const char* description = nullptr) {std::cout << "------------------------------------------------ " << std::endl;std::cout << "description  : " << description << std::endl;std::cout << "max_capacity : " << queue.max_capacity() << std::endl;std::cout << "size_approx  : " << queue.size_approx() << std::endl;std::cout << "peek address : " << queue.peek() << std::endl;T    element;bool succeeded;while (queue.size_approx() > 0) {succeeded = queue.try_dequeue(element);if (succeeded) {std::cout << element << " ";}}std::cout << std::endl;
}int main() {{moodycamel::BlockingReaderWriterQueue<int> q;  // max_capacity: 15PrintQueue(q, "default");moodycamel::BlockingReaderWriterQueue<int> q3(3);  // max_capacity: 3PrintQueue(q3, "3");moodycamel::BlockingReaderWriterQueue<int> q5(5);  // max_capacity: 7PrintQueue(q5, "5");}{moodycamel::BlockingReaderWriterQueue<int> q(5);for (int index = 0; index < 8; index++) {// q.enqueue(index);q.emplace(index);}PrintQueue(q, "enqueue/emplace");  // 0 1 2 3 4 5 6 7}{moodycamel::BlockingReaderWriterQueue<int> q(5);for (int index = 0; index < 8; index++) {// q.try_emplace(index);if (!q.try_enqueue(index)) {std::cout << "Insert element is failed, element: " << index << std::endl;}}PrintQueue(q, "try_enqueue/try_emplace");  // 0 1 2 3 4 5 6}{moodycamel::BlockingReaderWriterQueue<int> q(5);for (int index = 0; index < 8; index++) {q.emplace(index);}int element1;q.wait_dequeue(element1);  // 如果队列为空，函数会阻塞到队列非空int  element2;if (q.wait_dequeue_timed(element2, 5)) {  // 如果队列为空，函数会阻塞到超时结束，然后返回falsestd::cout << "element2: " << element2 << std::endl;}PrintQueue(q, "wait_dequeue/wait_dequeue_timed");}return EXIT_SUCCESS;
}

3. 无锁环形缓存

#include <readerwritercircularbuffer.h>#include <iostream>template <class T>
void PrintQueue(moodycamel::BlockingReaderWriterCircularBuffer<T>& queue, const char* description = nullptr) {std::cout << "------------------------------------------------ " << std::endl;std::cout << "description  : " << description << std::endl;std::cout << "max_capacity : " << queue.max_capacity() << std::endl;std::cout << "size_approx  : " << queue.size_approx() << std::endl;T    element;bool succeeded;while (queue.size_approx() > 0) {succeeded = queue.try_dequeue(element);if (succeeded) {std::cout << element << " ";}}std::cout << std::endl;
}int main() {{moodycamel::BlockingReaderWriterCircularBuffer<int> q3(3);  // max_capacity: 3PrintQueue(q3, "3");moodycamel::BlockingReaderWriterCircularBuffer<int> q5(5);  // max_capacity: 5PrintQueue(q5, "5");// 容量为指定位置}{moodycamel::BlockingReaderWriterCircularBuffer<int> q(5);for (int index = 0; index < 8; index++) {if (!q.try_enqueue(index)) {  // 如果插入元素时，队列已满，则丢弃std::cout << "Insert element is failed, element: " << index << std::endl;}}PrintQueue(q, "try_enqueue");  // 0 1 2 3 4}{moodycamel::BlockingReaderWriterCircularBuffer<int> q(5);for (int index = 0; index < 8; index++) {if (!q.wait_enqueue_timed(index, 5)) {  // 队列已满且在指定的超时时间内未获得存储空间，则插入失败，元素被丢弃std::cout << "Insert element is failed, element: " << index << std::endl;}}PrintQueue(q, "wait_enqueue_timed");  // 0 1 2 3 4}{moodycamel::BlockingReaderWriterCircularBuffer<int> q(5);for (int index = 0; index < 8; index++) {q.try_enqueue(index);}int element1;q.wait_dequeue(element1);std::cout << "wait_dequeue->element1: " << element1 << std::endl;int  element2;if (q.wait_dequeue_timed(element2, std::chrono::milliseconds(1))) {std::cout << "element2: " << element2 << std::endl;}PrintQueue(q, "wait_dequeue/wait_dequeue_timed");  // 2 3 4}return EXIT_SUCCESS;
}

这篇关于【CPP】单生产者单消费者无锁队列使用记录的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1104162。

相关文章

Java使用Curator进行ZooKeeper操作的详细教程

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3
阅读更多...
springboot security使用jwt认证方式

springboot security使用jwt认证方式

《springbootsecurity使用jwt认证方式》：本文主要介绍springbootsecurity使用jwt认证方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录前言代码示例依赖定义mapper定义用户信息的实体beansecurity相关的类提供登录接口测试提供一
阅读更多...
go中空接口的具体使用

go中空接口的具体使用

《go中空接口的具体使用》空接口是一种特殊的接口类型,它不包含任何方法,本文主要介绍了go中空接口的具体使用,具有一定的参考价值,感兴趣的可以了解一下... 目录接口-空接口1. 什么是空接口？2. 如何使用空接口？第一，第二，第三，3. 空接口几个要注意的坑坑1：坑2：坑3：接口-空接口1. 什么是空接
阅读更多...
springboot security快速使用示例详解

springboot security快速使用示例详解

《springbootsecurity快速使用示例详解》：本文主要介绍springbootsecurity快速使用示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录创www.chinasem.cn建spring boot项目生成脚手架配置依赖接口示例代码项目结构启用s
阅读更多...
Python如何使用__slots__实现节省内存和性能优化

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景：内存吃得满满的类__slots__：你的内存管理小助手举个大概的例子：看看效果如何？1.
阅读更多...
java中使用POI生成Excel并导出过程

java中使用POI生成Excel并导出过程

《java中使用POI生成Excel并导出过程》：本文主要介绍java中使用POI生成Excel并导出过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录需求说明及实现方式需求完成通用代码版本1版本2结果展示type参数为atype参数为b总结注：本文章中代码均为
阅读更多...
Spring Boot3虚拟线程的使用步骤详解

Spring Boot3虚拟线程的使用步骤详解

《SpringBoot3虚拟线程的使用步骤详解》虚拟线程是Java19中引入的一个新特性,旨在通过简化线程管理来提升应用程序的并发性能,：本文主要介绍SpringBoot3虚拟线程的使用步骤,... 目录问题根源分析解决方案验证验证实验实验1：未启用keep-alive实验2：启用keep-alive扩展建
阅读更多...
MySQL INSERT语句实现当记录不存在时插入的几种方法

MySQL INSERT语句实现当记录不存在时插入的几种方法

《MySQLINSERT语句实现当记录不存在时插入的几种方法》MySQL的INSERT语句是用于向数据库表中插入新记录的关键命令,下面：本文主要介绍MySQLINSERT语句实现当记录不存在时... 目录使用 INSERT IGNORE使用 ON DUPLICATE KEY UPDATE使用 REPLACE
阅读更多...
Python 中的异步与同步深度解析(实践记录)

Python 中的异步与同步深度解析(实践记录)

《Python中的异步与同步深度解析(实践记录)》在Python编程世界里,异步和同步的概念是理解程序执行流程和性能优化的关键,这篇文章将带你深入了解它们的差异,以及阻塞和非阻塞的特性,同时通过实际... 目录python中的异步与同步：深度解析与实践异步与同步的定义异步同步阻塞与非阻塞的概念阻塞非阻塞同步
阅读更多...
Python Dash框架在数据可视化仪表板中的应用与实践记录

Python Dash框架在数据可视化仪表板中的应用与实践记录

《PythonDash框架在数据可视化仪表板中的应用与实践记录》Python的PlotlyDash库提供了一种简便且强大的方式来构建和展示互动式数据仪表板,本篇文章将深入探讨如何使用Dash设计一... 目录python Dash框架在数据可视化仪表板中的应用与实践1. 什么是Plotly Dash？1.1
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2