多线程;顺序容器;智能指针

news2024/11/17 21:40:44

多线程的创建创建线程比较简单,C++提供头文件thread,使用std的thread实例化一个线程对象创建。

std::thread 在 #include 头文件中声明,因此使用 std::thread 时需要包含 #include 头文件。

#include <iostream>
#include <thread>
#include <stdlib.h> //sleep
 
using namespace std;
 
void t1()  //普通的函数,用来执行线程
{
    for (int i = 0; i < 10; ++i)
    {
        cout << "t1111\n";
        sleep(1);
    }
}
void t2()
{
    for (int i = 0; i < 20; ++i)
    {
        cout << "t22222\n";
        sleep(1);
    }
}
int main()
{
    thread th1(t1);  //实例化一个线程对象th1,使用函数t1构造,然后该线程就开始执行了(t1())
    thread th2(t2);
 
    th1.join(); // 必须将线程join或者detach 等待子线程结束主进程才可以退出
    th2.join(); 
 
    cout << "here is main\n\n";
 
    return 0;
}

LIO-SAM中的线程操作

int main(int argc, char** argv)
{
    ros::init(argc, argv, "lio_sam");
 
    mapOptimization MO;
 
    ROS_INFO("\033[1;32m----> Map Optimization Started.\033[0m");
    
    std::thread loopthread(&mapOptimization::loopClosureThread, &MO);
    std::thread visualizeMapThread(&mapOptimization::visualizeGlobalMapThread, &MO);
 
    ros::spin();
 
    loopthread.join();
    visualizeMapThread.join();
 
    return 0;
}

两个线程主要运行的函数主要时回环检测线程和全局地图可视化线程,在每个线程内部都有互斥锁操作防止两个线程运行时对相同数据进行干扰

互斥锁mutex是用来保证线程同步的,防止不同的线程同时操作同一个共享数据

通过mutex可以方便的对临界区域加锁,std::mutex类定义于mutex头文件,是用于保护共享数据避免从多个线程同时访问的同步原语。它提供了lock,try_lock,unlock等几个接口

#include<iostream>
#include<thread>
#include<mutex>
 
using namespace std;
 
mutex m;
int cnt = 10;
 
void thread1() {
    while (cnt > 5){
        m.lock();
        if (cnt > 0) {
            --cnt;
            cout << cnt << endl;
        }
        m.unlock();
    }
}
 
void thread2() {
    while (cnt > 0) {
        m.lock();
        if (cnt > 0) {
            cnt -= 10;
            cout << cnt << endl;
        }
        m.unlock();
    }
}
 
int main(int argc, char* argv[]) {
    thread th1(thread1);   //实例化一个线程对象th1,该线程开始执行
    thread th2(thread2);
    th1.join();
    th2.join();
    cout << "main..." << endl;
    return 0;
}

aloam中互斥锁的应用

void laserCloudCornerLastHandler(const sensor_msgs::PointCloud2ConstPtr &laserCloudCornerLast2)
{
	mBuf.lock();
	cornerLastBuf.push(laserCloudCornerLast2);
	mBuf.unlock();
}

在接收laserCloudCornerLast2时为了完整的接收到当前帧角点点云信息在开始接受时为了防止其他线程影响该数据使用mBuf.lock();接受完后再打开mBuf.unlock();

std::lock_guard因为mutex需要在数据处理开始和结束时成对出现,当数据处理过程很长时容易遗忘造成危害,所以使用std::lock_guard

要加锁的代码段,我们用{}括起来形成一个作用域,括号的开端创建lock_guard对象,把mutex对象作为参数传入lock_guard的构造函数即可

这就相当于下面代码

std::thread thread2([&]()){
    for(int i=0;i<10000;i++)
    {
        mtx.lock();
        ++num;
        mtx.unlock();
    }
});

LIO-SAM中的std::lock_guard

//订阅imu里程计,由imuPreintegration积分计算得到的每时刻imu位姿
    void odometryHandler(const nav_msgs::Odometry::ConstPtr& odometryMsg)
    {
        std::lock_guard<std::mutex> lock2(odoLock);
        odomQueue.push_back(*odometryMsg);
    }

在接收里程计数据时防止其他线程对接受数据造成干扰,使用std::lock_guard。该对象只在他所处的大括号内起作用

顺序容器概述

顺序容器使用原则通常,使用vector是最好的选择,除非你有很好的理由选择其他容器

Vector由于一般情况下vector使用较多,首先介绍一些vector的使用

size()返回容器中元素数目;
swap()交换两个容器的内容;
begin()返回一个指向容器中第一个元素的迭代器;
end()返回一个表示超过容器尾的迭代器(指向容器最后一个元素后面的那个元素位置);
push_back()将元素添加到矢量(vector)末尾;
erase()删除矢量中给定区间的元素;
insert()插入指定区间的元素到指定位置;

deque在slam接收储存一些传感器数据时也是用到队列先进先出

deque是一个的双向开口,意思是可以在头尾两端分别做元素的插入和删除操作,当然,vector 容器也可以在头尾两端插入元素,但是在其头部操作效率奇差,无法被接受。

用sort对deque排序

#include <iostream>
#include <deque>
#include <algorithm>
using namespace std;
 
void printDeque(const deque<int> &d)
{
    for(deque<int>::const_iterator it = d.begin(); it != d.end(); it++)
    {
        cout<<*it<<" ";		
    }
    cout<<endl;
}
 
/* 回调函数 */
bool compare(int v1, int v2)
{
    return v1 > v2; /* 此时的排序是从大到小 */
                    /* 如果从小到大应该改为"v1 < v2" */
}
 
void test()
{
    deque<int> d;
    d.push_back(3);
    d.push_back(4);
    d.push_back(1);
    d.push_back(7);
    d.push_back(2);
 
    sort(d.begin(), d.end(), compare);
    printDeque(d);
}

assign()STL中不同容器之间是不能直接赋值的,assign()可以实现不同容器但相容的类型赋值,如:

list<string> names;
vector<const char*> oldstyle = { "I","love","you" };
//names = oldstyle;错误!不同的类型不能执行"="操作
names.assign(oldstyle.cbegin(), oldstyle.cend());
list<string>::iterator it;
for (auto it = names.begin(); names.begin() != names.end(); it++)
        cout << *it << " ";

在 lego-loam中有如下操作

segMsg.startRingIndex.assign(N_SCAN, 0);
segMsg.endRingIndex.assign(N_SCAN, 0);

智能指针概念以及为什么引入智能指针

shared_ptr类的创建

shared_ptr<string> p1 //shared_ptr 指向string类型
shared_ptr<list<int>> p2 //shared_ptr 指向int类型的list

make_shared函数使用最安全的分配和使用动态内存的方法是调用一个名为make_shared的标准库函数。此函数在动态内存中分配一个对象并初始化它,返回指向此对象的shared_ptr。当要用make_shared时,必须指定想要创建的对象的类型,定义方式与模板类相同。在函数名之后跟一个尖括号,在其中给出类型。例如,调用make_shared<string>时传递的参数必须与string的某个构造函数相匹配。如果不传递任何参数,对象就会进行值初始化。

//指向一个值为24的int的shared_ptr
shared_ptr&lt;int&gt; p3 =make_shared&lt;int&gt;(42)
//指向一个值为"99999"的string的shared_ptr
shared_ptr&lt;int&gt; p4 =make_shared&lt;string&gt;(5,'9')
//指向一个值为0的int的shared_ptr
shared_ptr&lt;int&gt; p3 =make_shared&lt;int&gt;()

auto和make_shared通常用auto定义一个对象来保存make_shared的结果

//指向一个值为24的int的shared_ptr
auto p6 =make_shared&lt;int&gt;(42)

shared_ptr的拷贝和赋值1、当新的 shared_ptr 对象与指针关联时,则在其构造函数中,将与此指针关联的引用计数增加1。2、当任何 shared_ptr 对象超出作用域时,则在其析构函数中,它将关联指针的引用计数减1。如果引用计数变为0,则表示没有其他 shared_ptr 对象与此内存关联,在这种情况下,它使用delete函数删除该内存。

auto p=make_shared&lt;int&gt;(42) //p指向的对象只有p一个引用者
auto q(p) //p和q指向相同对象,此对象有两个引用者

检查 shared_ptr 对象的引用计数

p1.use_count();

完整实例

#include &lt;iostream&gt;
#include  &lt;memory&gt; // 需要包含这个头文件
 
int main()
{
	// 使用 make_shared 创建空对象
	std::shared_ptr&lt;int&gt; p1 = std::make_shared&lt;int&gt;();
	*p1 = 78;
	std::cout &lt;&lt; "p1 = " &lt;&lt; *p1 &lt;&lt; std::endl; // 输出78
 
	// 打印引用个数:1
	std::cout &lt;&lt; "p1 Reference count = " &lt;&lt; p1.use_count() &lt;&lt; std::endl;
 
	// 第2个 shared_ptr 对象指向同一个指针
	std::shared_ptr&lt;int&gt; p2(p1);
 
	// 下面两个输出都是:2
	std::cout &lt;&lt; "p2 Reference count = " &lt;&lt; p2.use_count() &lt;&lt; std::endl;
	std::cout &lt;&lt; "p1 Reference count = " &lt;&lt; p1.use_count() &lt;&lt; std::endl;
 
	// 比较智能指针,p1 等于 p2
	if (p1 == p2) {
		std::cout &lt;&lt; "p1 and p2 are pointing to same pointer\n";
	}
 
	std::cout&lt;&lt;"Reset p1 "&lt;&lt;std::endl;
 
	// 无参数调用reset,无关联指针,引用个数为0
	p1.reset();
	std::cout &lt;&lt; "p1 Reference Count = " &lt;&lt; p1.use_count() &lt;&lt; std::endl;
	
	// 带参数调用reset,引用个数为1
	p1.reset(new int(11));
	std::cout &lt;&lt; "p1  Reference Count = " &lt;&lt; p1.use_count() &lt;&lt; std::endl;
 
	// 把对象重置为NULL,引用计数为0
	p1 = nullptr;
	std::cout &lt;&lt; "p1  Reference Count = " &lt;&lt; p1.use_count() &lt;&lt; std::endl;
	if (!p1) {
		std::cout &lt;&lt; "p1 is NULL" &lt;&lt; std::endl; // 输出
	}
	return 0;
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2175667.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【C++】C++的Vector使用和实现

目录 vector的介绍 vector的使用 construct iterator capacity Element access mondifiers vector的原理介绍以及简单实现 vector的介绍 我们平时在写代码中可能会使用各种类型的array&#xff0c;也就是数组&#xff0c;但是这些数组都是静态的&#xff0c;意味着我们只能…

A股突破3000,连续大涨,公司国庆假放10天

关注▲洋洋科创星球▲一起成长&#xff01; 庆祝A股突破3000&#xff0c;连续大涨&#xff0c;也不知道老板抽了什么风&#xff0c;公司今天开始放国庆假了&#xff0c;连休10天&#xff0c;哈哈哈哈哈哈。 27号开始放国庆假&#xff0c;连休10&#xff0c;刺激。 中秋国庆这一…

在线代码编辑器

在线代码编辑器 文章说明前台核心代码后台核心代码效果展示源码下载 文章说明 采用Java结合vue3设计实现的在线代码编辑功能&#xff0c;支持在线编辑代码、运行代码&#xff0c;同时支持导入文件&#xff0c;支持图片识别&#xff0c;支持复制代码&#xff0c;可将代码导出为图…

网络安全带你练爬虫----添加异常处理代码

&#xff08;当代码越来越长的时候&#xff0c;异常处理代码有时候能起到很好的作用&#xff09; (注&#xff1a;其中的cookie需要填自己的) 一、异常处理代码&#xff1a; &#xff08;1&#xff09;try-except搭配&#xff1a;try关键字后面的代码是要监视异常的代码块&am…

DarkLabel 2.4 目标追标注工具介绍

DarkLabel介绍 https://github.com/darkpgmr/DarkLabel 官方地址 视频/图像标注工具&#xff0c;很适合用于目标追踪任务 DarkLabel可以在视频和图像中标注物体的边界框&#xff0c;并附上 ID 和name。还可以用于裁剪视频、从视频中采样训练图像以及对图像区域进行马赛克处理…

第十三周:机器学习

目录 摘要 Abstract 一、生成式对抗网络&#xff08;上&#xff09; 1、引入——generator 2、discriminator 3、GAN算法 4、GAN的理论 5、GAN的训练技巧 二、word2vec——gensim实践 1、引入 2、 word2vec模型 3、fasttext模型 总结 摘要 本周学习了对GAN进行了…

二叉树的前序遍历,中序遍历,后序遍历(非递归方法+C语言代码)

#include<stdlib.h> #include<stdio.h> #include<assert.h> #include<stdbool.h> //定义一个二叉树结点结构体 typedef int ElemTpye; typedef struct TreeNode {ElemTpye data;struct TreeNode* left;struct TreeNode* right; }TreeNode; //创建结点 …

Autosar EcuM学习笔记-上电初始化执行函数及下电前执行函数

文章目录 前言Autosar标准EcuM启动时的初始化EcuM下电执行过程 总结 前言 Autosar启动和下电过程由EcuM控制&#xff0c;本文介绍EcuM中的初始化和下电前的执行函数 Autosar标准 EcuM启动时的初始化 在标准中&#xff0c;主核启动流程如下&#xff1a; 从核启动流程如下&a…

98问答网是一个怎样的平台?它主要提供哪些服务?

98问答网是一个集知识分享、问题解答与社区交流为一体的综合性在线问答平台。该平台旨在通过汇聚来自各行各业的专家、学者以及广大网友的智慧&#xff0c;为用户提供一个快速获取准确信息、解决生活工作中遇到的各种问题的渠道。 主要服务包括&#xff1a; 问题提问与解答&am…

Mybatis中字段返回值映射问题

需求说明&#xff1a; 返回值列表扩展字段值&#xff0c;不改变原有代码的基础上&#xff0c;增加返回值 编写类VO: public class RegionVO extends Region {//点位数量private Integer nodeCount;public Integer getNodeCount() {return nodeCount;}public void setNodeCou…

scrapy快速上手

安装 除了scrapy本身还要安装两个库 pip install scrapy pip install pywin32 pip install wheel 创建项目 在要创建项目的地方打开powershell scrapy startproject 项目名 我们得到这样的项目结构&#xff0c;功能如下 scrapy.cfg 项目的主配置信息 …

基于STM32的智能人脸识别门锁系统

目录 引言项目背景环境准备 硬件准备软件安装与配置系统设计 系统架构关键技术代码示例 摄像头模块数据采集人脸识别与门锁控制OLED显示与报警功能应用场景结论 1. 引言 随着物联网&#xff08;IoT&#xff09;和人工智能&#xff08;AI&#xff09;技术的发展&#xff0c;智…

ERROR [internal] load metadata for docker.io/library/openjdk:8

ERROR: failed to solve: DeadlineExceeded: DeadlineExceeded: DeadlineExceeded: openjdk:8: failed to do request: Head “https://registry-1.docker.io/v2/library/openjdk/manifests/8”: dial tcp 202.160.129.6:443: i/o timeout 在构建docker镜像时从docker.io/libr…

Unity中的功能解释(数学位置相关和事件)

向量计算 Vector3.Slerp&#xff08;起点坐标&#xff0c;终点坐标&#xff0c;t&#xff09;&#xff0c;可是从起点坐标以一个圆形轨迹到终点坐标&#xff0c;有那么多条轨迹&#xff0c;那怎么办 Vector3.Slerp 进行的是沿球面插值&#xff0c;因此并不是沿着严格的“圆形…

Ubuntu 离线安装 docker

1、下载离线包&#xff0c;网址&#xff1a;https://download.docker.com/linux/ubuntu/dists/xenial/pool/stable/ 离线安装docker需要下载3个包&#xff0c;containerd.io &#xff0c;docker-ce-cli&#xff0c;docker-ce 2、下载完毕后拷贝到ubuntu上用 dpkg 命令安装&am…

【d53】【Java】【力扣】24.两两交换链表中的节点

思路 定义一个指针cur, 先指向头节点&#xff0c; 1.判断后一个节点是否为空&#xff0c;不为空则交换值&#xff0c; 2.指针向后走两次 代码 /*** Definition for singly-linked list.* public class ListNode {* int val;* ListNode next;* ListNode() {}*…

浅谈java异常[Exception]

一&#xff0e; 异常的定义 在《java编程思想》中这样定义 异常&#xff1a;阻止当前方法或作用域继续执行的问题。虽然java中有异常处理机制&#xff0c;但是要明确一点&#xff0c;决不应该用"正常"的态度来看待异常。绝对一点说异常就是某种意义上的错误&#xf…

制造业智能化建设的指标详解

制造业智能化建设的关键监测指标文章浏览阅读284次。10. |绿色化、安全及可靠性|8. |产品全生命周期管理|2. |生产数据自动采集率|4. |数据存储与分析能力|2. |生产数据自动采集率|4. |数据存储与分析能力|5. |企业数字化转型成效|2. |数据中心服务能力|1. |自动化设备应用|2. …

2024年9月25日,Intel发布至强6900P系列:128核心504MB缓存,终于追上AMD!

各位高性能计算领域的朋友们&#xff0c;你们期待已久的消息来了&#xff01; 添加图片注释&#xff0c;不超过 140 字&#xff08;可选&#xff09; Intel终于发布了至强6900P系列&#xff0c;这款全新的高性能计算&#xff08;HPC&#xff09;服务器处理器&#xff0c;不仅在…

怎样将多个视频合并成一个?7种无损视频合并技巧,1分钟剪辑出大片!

随着社交媒体和视频平台的兴起&#xff0c;身边很多人都开始拍摄vlog来记录自己的生活。剪辑视频最常见的需求就是视频合并&#xff0c;将多个视频合并成一个。视频合并算是比较简单的视频剪辑操作&#xff0c;现在有很多软件支持视频合并功能&#xff0c;本文整理了几个比较简…