当前位置: 首页 > news >正文

C++ 缓存再排序,解决多线程处理后的乱序问题,不知道思路对不对[挠下巴]

C++ 缓存再排序,解决多线程处理后的乱序问题,不知道思路对不对[挠下巴]

使用map默认会根据key排序的原理作缓存,队列满了依次推出,抛弃掉过时的数据

#include <functional>
#include <iostream>
#include <map>
#include <random>
#include <set>
#include <tuple>
#include <vector>template <typename V> class SortQueue {
private:std::function<void(const int, V &)> callback;std::map<int, V> m;int max_size;int last;public:SortQueue(int max) : max_size(max), last(0) {}~SortQueue() {}void setCallback(std::function<void(const int, V &)> callback) {this->callback = callback;}void push(int k, V &v) {if (k < last)return;m.emplace(std::make_pair(k, std::move(v)));if (m.size() > max_size) {auto it = m.begin();if (callback) {callback(it->first, it->second);last = it->first;}m.erase(it);}}
};std::vector<int> r(int start, int end, int size) {std::set<int> generated_nums; // 存储已生成的随机数std::vector<int> nums;std::random_device rd;std::mt19937 gen(rd());std::uniform_int_distribution<int> dis(start, end);while (generated_nums.size() < size) { // 生成10个不重复的随机数int random_num = dis(gen);if (generated_nums.find(random_num) == generated_nums.end()) {generated_nums.insert(random_num);nums.push_back(random_num);}}return std::move(nums);
}void p(std::vector<int> &arr) {std::string result;for (int i = 0; i < arr.size(); ++i) {result += std::to_string(arr[i]) + " ";if ((i + 1) % 10 == 0) {result += "\n";}}std::cout << "拼接后的字符串: \n" << result << std::endl;
}int main(int argc, char *argv[]) {std::vector<int> nums;int start = 1;int end = 0;int size = 10;for (int i = 0; i < 5; i++) {start = i * size + 1;end = i * size + 10;std::vector<int> temp = r(start, end, size);nums.insert(nums.end(), temp.begin(), temp.end());}// std::vector<int> nums = r(1, 50, 50);p(nums);SortQueue<int> sq(5);sq.setCallback([](const int k, int &v) { std::cout << "K: " << k << std::endl; });for (int num : nums) {sq.push(num, num);}return 0;
}

相关文章:

C++ 缓存再排序,解决多线程处理后的乱序问题,不知道思路对不对[挠下巴]

C 缓存再排序&#xff0c;解决多线程处理后的乱序问题&#xff0c;不知道思路对不对[挠下巴] 使用map默认会根据key排序的原理作缓存&#xff0c;队列满了依次推出&#xff0c;抛弃掉过时的数据 #include <functional> #include <iostream> #include <map> #…...

华为数通HCIA-地址分类及子网划分

ip地址&#xff08;逻辑地址&#xff09; 作用&#xff1a;唯一标识一张网卡 特点&#xff1a;设备天生没有&#xff0c;需要人为配置&#xff0c;可以随时修改 格式&#xff1a;点分十进制 大小&#xff1a;32bit 组成&#xff1a;网络位主机位 网络位&#xff1a;用于标…...

Linux第七章之gdb与makefile使用

一、Linux调试器-gdb使用 1.1背景 程序的发布方式有两种&#xff0c;debug模式和release模式Linux gcc/g出来的二进制程序&#xff0c;默认是release模式要使用gdb调试&#xff0c;必须在源代码生成二进制程序的时候, 加上-g 选项&#xff3b;重要&#xff3d; 1.2开始使用 …...

Mycat-Balance使用指南

MyCAT Balance是一个Java NIO的高性能负载均衡器&#xff0c;可以替代普通的硬件的交换机或其LVS类似的复杂机制&#xff0c;实现MyCAT集群的负载均衡。 MyCAT Balance的配置文件在conf目录下&#xff0c;frontend-conf.为前端配置&#xff0c;包括绑定的端口等&#xff0c;js…...

玩转顺序表——【数据结构】

在C语言学习中&#xff0c;我们经常会遇见增删查改等一系列操作&#xff0c;而这些操作全都与线性表关联&#xff0c;没有线性表将会对这些操作完成的十分艰难&#xff01;那今天就让我们来了解一下顺序表如何增删查改&#xff01;&#xff01;&#xff01; 目录 1.线性表 2…...

SSE(Server-Sent Events,服务器推送事件)和sockets(套接字)通信区别

SSE&#xff08;Server-Sent Events&#xff0c;服务器推送事件&#xff09;和sockets&#xff08;套接字&#xff09;都是用于实现实时通信的技术&#xff0c;但它们具有不同的特点和应用场景。 SSE 的优点&#xff1a; 简单易用&#xff1a;SSE 是基于HTTP协议的一种实时通…...

【设计模式——学习笔记】23种设计模式——代理模式Proxy(原理讲解+应用场景介绍+案例介绍+Java代码实现)

介绍 基础介绍 代理模式为一个对象提供一个代理对象&#xff0c;以控制对这个对象的访问。即通过代理对象访问目标对象&#xff0c;这样做的好处是&#xff1a;可以在不修改目标对象代码的基础上&#xff0c;增强额外的功能操作&#xff0c;即扩展目标对象的功能被代理的对象…...

大学英语四新视野 课后习题+答案翻译 Unit1~Unit8

Unit 1 Text A: Words in use 2022年6月16日 20:57 1 As the gender barriers crumbled, the number of women working as lawyers, doctors, or bankers began to increase significantly from the mid-20th century. 随着性别障碍的消除&#xff0c;从20世纪中期开始&am…...

Java入门指南:Java语言优势及其特点

目录 1. Java语言简介及发展概述 2. Java语言的优势 2.1 可移植性 2.2 面向对象 2.3 安全性 2.4 大量类库 3. Java语言与C/C的区别 4. 初识Java程序入口之main方法 5. 注释、标识符、关键字 5.1 注释 5.2 标识符 5.3 关键字 1. Java语言简介及发展概述 Java是一种面…...

Jenkins 节点该如何管理?

Jenkins 拥有分布式构建(在 Jenkins 的配置中叫做节点)&#xff0c;分布式构建能够让同一套代码在不同的环境(如&#xff1a;Windows 和 Linux 系统)中编译、测试等 Jenkins 的任务可以分布在不同的节点上运行 节点上需要配置 Java 运行时环境&#xff0c;JDK 版本大于 1.5 节…...

hugging face下载数据集

开始直接执行这个&#xff0c;下载下来的图片打不开 git clone https://huggingface.co/datasets/diffusers/dog-example 解决办法&#xff1a; 安装git lfs 1. curl -s https://packagecloud.io/install/repositories/github/git-lfs/script.deb.sh | sudo bash 2. sudo apt…...

解决Django报错 : No module named ‘MySQLdb‘

Django的版本是2.0&#xff0c;Python的版本号是3.6.4 在models.py创建好了模型类之后使用命令&#xff1a;python manage.py makemigrations 进行迁移&#xff0c;但是突然报错&#xff1a;ImportError:No module named MySQLdb 查询了相关资料发现python2.x版本是支持mysql…...

【Docker】Docker的优势、与虚拟机技术的区别、三个重要概念和架构及工作原理详细讲解

前言 Docker 是一个开源的应用容器引擎&#xff0c;让开发者可以打包他们的应用以及依赖包到一个可移植的容器中,然后发布到任何流行的Linux或Windows操作系统的机器上,也可以实现虚拟化,容器是完全使用沙箱机制,相互之间不会有任何接口。 作者简介&#xff1a; 辭七七&#xf…...

【论文笔记】RCM-Fusion: Radar-Camera Multi-Level Fusion for 3D Object Detection

原文链接&#xff1a;https://arxiv.org/abs/2307.10249 1. 引言 目前的一些雷达-相机融合3D目标检测方法进行实例级的融合&#xff0c;从相机图像生成3D提案&#xff0c;并与雷达点云相关联以修正提案。但这种方法没有在最初阶段使用雷达&#xff0c;依赖于相机3D检测器&…...

STM32-风速传感器(ADC)

目录 0 说明 1 传感器介绍 2 代码说明 2.1 ADC.c 2.2 adc.h 2.3 main.c 0 说明 本篇文章主要是说明怎么使用STM32单片机读取风速传感器采集到的数据&#xff0c;读取方式是ADC&#xff0c;并且附带着STM32所需要的全部代码&#xff0c;所使用的风速传感器如下图所示。 附&am…...

【conda】配置国内镜像源

【conda】配置国内镜像源 1、官方2、国内常用镜像3、配置查看当前conda配置设置搜索是显示通道地址 4、清除缓存5、恢复默认全部删除指定删除 1、官方 https://docs.conda.io/projects/conda/en/latest/configuration.html 2、国内常用镜像 https://developer.aliyun.com/mi…...

python森林生物量(蓄积量)数据处理到随机森林估算全流程

python森林生物量&#xff08;蓄积量&#xff09;估算全流程 一.哨兵2号获取/处理/提取数据1.1 影像处理与下载采用云概率影像去云采用6S模型对1C级产品进行大气校正geemap下载数据到本地NDVI 1.2 各种参数计算&#xff08;生物物理变量、植被指数等&#xff09;LAI&#xff1a…...

使用Freemarker模版导出xls文件使用excel打开提示文件损坏

本文是通过一步步的还原事件的发生并解决的一个过程记录&#xff0c;如果想知道如何解决的可以直接跳转文章末尾结论部分 提示一下&#xff0c;关注一下 Table 标签中的 ss:ExpandedRowCount 属性 解决的问题 在项目中使用freemarker的xml模板导出xls格式的Excel文件时&#xf…...

初识Linux

今天简单了解了关于操作系统的发展史&#xff0c;学习了在Linux中如何远程连接云服务器的指令&#xff0c;以及在Linux中创建多个用户的指令。 1. ssh root 服务器远程地址 作用是用来连接XShell与云服务器&#xff0c;输入该指令后会自动生成输入密码的窗口&#xff0c;如…...

python——案例六:清空列表用clear()方法实现

案例六&#xff1a;清空列表用clear()方法实现LIST[0,1,2,3,4,5] print(清空前&#xff1a;,LIST) LIST.clear() print(清空后&#xff1a;,LIST)...

OLAP引擎全景图鉴:从架构原理到场景适配,深度解析Impala/Druid/Presto/Kylin/ClickHouse的选型之道

1. OLAP技术全景解析&#xff1a;从基础概念到架构分类 当你打开手机查看每日步数统计&#xff0c;或是浏览电商平台的年度消费报告时&#xff0c;背后支撑这些数据分析的正是OLAP技术。OLAP&#xff08;在线分析处理&#xff09;就像一位不知疲倦的数据分析师&#xff0c;能够…...

Midjourney提示词黑箱破解(仅限本期开放):基于CLIP-ViT-L/14特征空间逆向推演的6维可控性建模

更多请点击&#xff1a; https://intelliparadigm.com 第一章&#xff1a;Midjourney提示词黑箱破解的底层逻辑与认知跃迁 Midjourney 的提示词&#xff08;Prompt&#xff09;并非自然语言自由表达&#xff0c;而是一套隐式编码的**语义协议栈**——它在扩散模型隐空间中触发…...

Wand-Enhancer:三步解锁WeMod Pro功能的终极免费方案

Wand-Enhancer&#xff1a;三步解锁WeMod Pro功能的终极免费方案 【免费下载链接】Wand-Enhancer Advanced UX and interoperability extension for Wand (WeMod) app 项目地址: https://gitcode.com/gh_mirrors/we/Wand-Enhancer 还在为WeMod专业版的订阅费用而烦恼吗&…...

为Hermes Agent配置自定义Provider指向Taotoken聚合服务的操作方法

&#x1f680; 告别海外账号与网络限制&#xff01;稳定直连全球优质大模型&#xff0c;限时半价接入中。 &#x1f449; 点击领取海量免费额度 为Hermes Agent配置自定义Provider指向Taotoken聚合服务的操作方法 Hermes Agent 是一个功能强大的AI代理框架&#xff0c;它支持通…...

千川素材月烧3万外包费?用易元AI自建素材工厂,省70%成本跑量更猛

做千川投放的商家都深有体会&#xff1a;限制账户放量的从来不是预算&#xff0c;而是素材成本高、产能慢、优质有效素材稀缺。当下千川商家都陷入同一个困境&#xff1a;不做素材没法投放&#xff0c;大批量做素材又烧钱。一款产品要多卖点测试&#xff0c;投放计划需要持续补…...

Huxley框架PDF生成利器:基于HTML模板的优雅解决方案

1. 项目概述&#xff1a;一个为Huxley框架量身定制的PDF生成利器如果你正在使用Huxley框架开发应用&#xff0c;并且遇到了需要生成PDF报告、发票、合同或者任何形式文档的需求&#xff0c;那么你很可能已经体会过那种“万事俱备&#xff0c;只欠PDF”的纠结。市面上的PDF生成库…...

2026年高口碑GNSS变形监测一体机推荐:提升水库安全解决方案

随着基础设施监测需求的上升&#xff0c;单北斗形变监测一体机逐渐成为各大工程的首选。利用GNSS桥梁形变监测技术、这些设备能够实时监控水库和大坝重要结构的安全情况。单北斗GNSS应用在数据传输和处理上&#xff0c;展现出高效性与可靠性。用户在选择时应关注不同型号的价格…...

别熬大夜改 PPT 了!Paperxie AI PPT,一键搞定毕业论文答辩

paperxie-免费查重复率aigc检测/开题报告/毕业论文/智能排版/文献综述/AI PPThttps://www.paperxie.cn/ppt/createhttps://www.paperxie.cn/ppt/create 论文终稿刚定稿&#xff0c;答辩 PPT 的空白页面就开始让人焦虑。打开 PowerPoint&#xff0c;对着 “新建幻灯片” 发愣&am…...

5分钟彻底解决Mac NTFS读写难题:开源工具Nigate完全指南

5分钟彻底解决Mac NTFS读写难题&#xff1a;开源工具Nigate完全指南 【免费下载链接】Free-NTFS-for-Mac Nigate: An open-source NTFS utility for Mac. It supports all Mac models (Intel and Apple Silicon), providing full read-write access, mounting, and management …...

【信息科学与工程学】【通信工程】第四十四篇 城域网络设计10 城域网中涉及的数学物理、数学化学及数学地理01

城域网中涉及的数学、数学物理、数学化学及数学地理方法,并按照您要求的表格格式进行呈现。 编号 领域 类型 城域网领域 子领域 城域网架构 城域网中的数学/数学物理/数学化学方法/算法/现象 现象描述/算法/函数逐步推理思考的数学方程式(完整的参数列表、常数、变量、…...