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

ros2笔记-2.5.3 多线程与回调函数

news 2025/6/10 0:37:33

本节体验下多线程。

python示例

在src/demo_python_pkg/demo_python_pkg/下新建文件，learn_thread.py

import threading
import requestsclass Download:def download(self,url,callback):print(f'线程：{threading.get_ident()} 开始下载：{url}')reponse = requests.get(url)reponse.encoding = 'utf-8'callback(url,reponse.text)def start_download(self,url,callback):thread  = threading.Thread(target=self.download,args=(url,callback))thread.start()    def world_cout(url,result):print(f"{url}:{len(result)}->{result[:30]}")def main():download = Download()download.start_download('https://fishros.com/d2lros2/#/humble/chapt1/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB',world_cout) download.start_download('https://fishros.com/d2lros2/#/humble/chapt2/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB',world_cout) download.start_download('https://fishros.com/d2lros2/#/humble/chapt3/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB',world_cout)

python的线程库是threading，http请求库是requests.

Download 类定义了两个方法download、start_download。其中download 是真正的下载，start_download启动thread来运行目标函数download。

回调函数world_cout，用于处理下载完成的数据。main函数是入口，实例化一个Download类型的对象download,分别去下载，url 测试下。书上例子是自己造的TXT。

在setup.py添加learn_thread节点，编译后运行。

bohu@bohu-TM1701:~/2/2_ws$ colcon build
Starting >>> demo_cpp_pkg
Finished <<< demo_cpp_pkg [0.16s]                     
Starting >>> demo_python_pkg
Finished <<< demo_python_pkg [1.24s]          Summary: 2 packages finished [1.75s]
bohu@bohu-TM1701:~/2/2_ws$ ros2 run demo_python_pkg learn_thread 
线程：126326222620224 开始下载：https://fishros.com/d2lros2/#/humble/chapt1/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB
线程：126326212134464 开始下载：https://fishros.com/d2lros2/#/humble/chapt2/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB
线程：126326126151232 开始下载：https://fishros.com/d2lros2/#/humble/chapt3/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB
https://fishros.com/d2lros2/#/humble/chapt1/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB:5794-><!DOCTYPE html>
<html lang="en
https://fishros.com/d2lros2/#/humble/chapt3/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB:5794-><!DOCTYPE html>
<html lang="en
https://fishros.com/d2lros2/#/humble/chapt2/%E7%AB%A0%E8%8A%82%E5%AF%BC%E8%AF%BB:5794-><!DOCTYPE html>
<html lang="en

C++示例

先下载依赖库

bohu@bohu-TM1701:~/2/2_ws/src/demo_cpp_pkg/include$ git clone https://gitee.com/ohhuo/cpp-httplib.git
正克隆到 'cpp-httplib'...
remote: Enumerating objects: 4527, done.
remote: Total 4527 (delta 0), reused 0 (delta 0), pack-reused 4527
接收对象中: 100% (4527/4527), 2.27 MiB | 2.55 MiB/s, 完成.
处理 delta 中: 100% (3057/3057), 完成.

下载完成后，还要在CMakeLists.txt 添加目录

include_directories(include) #包含include头文件目录

在2_ws/src/demo_cpp_pkg/src下新建learn_thread.cpp文件。

#include <iostream>
#include <thread>
#include <chrono> //时间相关
#include <functional>
#include <cpp-httplib/httplib.h>
using namespace std;class Download
{public:void download(const string &host,const string &path,const function<void(const string &,const string &)> &callback){cout<<" 线程ID： "<< this_thread::get_id() << endl;httplib::Client client(host);auto response = client.Get(path);if(response && response->status==200){callback(path,response->body);} };void  start_download(const string &host,const string &path,const function<void(const string &,const string &)> &callback){auto download_fun = bind(&Download::download,this,placeholders::_1,placeholders::_2,placeholders::_3);thread thread(download_fun,host,path,callback);thread.detach();  };     };int main()
{auto d= Download();auto word_count = [](const string &path,const string &result) -> void{cout << "下载完成" << path <<""<<result.length()<<"->"<<result.substr(0,100)<< endl;};d.start_download("http://0.0.0.0:8000","/novel1.txt",word_count);d.start_download("http://0.0.0.0:8000","/novel2.txt",word_count);d.start_download("http://0.0.0.0:8000","/novel3.txt",word_count);this_thread::sleep_for(chrono::seconds(10));return 0;
}

开头还是引用头文件。然后声明了Download类，添加了download函数和start_download函数。

download函数使用了httplib下载，start_download函数里面thread.detach(); 将线程与当前进程分离，使得线程可以后台运行。

main函数是入口，通过lambda创建了回调函数。并三次调用start_download 下载。最后延迟了10秒，防止程序直接退出。

在CMakeLists.txt 添加节点，编译运行。运行结果：

bohu@bohu-TM1701:~/2/2_ws$ ros2 run demo_cpp_pkg learn_thread
线程ID： 138510887552576
线程ID： 138510877066816
线程ID： 138510747043392
下载完成/novel2.txt85-> BH8VYW，你好，这里是BH8ZZZ，你的信号是59，能否抄收我的信号？

下载完成/novel3.txt85-> BH8ZZZ，你好，这里是BH8VYW，你的信号是59，能够抄收你的信号。

下载完成/novel1.txt70->CQ，CQ，CQ，这里是BH8VYW，这里是BH8VYW，收到请回答。

ros2笔记-2.5.3 多线程与回调函数

本节体验下多线程。 python示例在src/demo_python_pkg/demo_python_pkg/下新建文件，learn_thread.py import threading import requestsclass Download:def download(self,url,callback):print(f线程：{threading.get_ident()} 开始下载：{…...

编程日记 2025/1/7 15:55:01

第5章：Go语言错误处理和异常

第5章：Go语言错误处理和异常 5.1 错误类型基础 5.1.1 error接口 // error接口定义 type error interface {Error() string }// 自定义错误 type CustomError struct {Message stringCode int }func (e *CustomError) Error() string {return fmt.Sprintf(&quo…...

编程日记 2025/1/7 15:52:53

题库刷题知识点总结

算法与机器学习相关支持向量机：是一种有监督的机器学习算法，用于分类和回归任务。它通过寻找一个最优超平面来将不同类别的数据点分开，最大化两类数据点到超平面的间隔，具有良好的泛化能力和抗噪声能力。机器学习：是…...

编程日记 2025/1/7 15:51:48

GraphRAG：LLM之Graphrag接入milvus

前言微软目前的graphrag更像个demo，数据量大的时候不是很友好的啊，所以将milvus接入了graphrag，看完这篇文章，其他数据库接入应该也没问题注：这篇文章只是在search的时候接入进来，index过程或者说整个流…...

编程日记 2025/1/7 15:50:47

adb使用及常用命令

目录介绍组成启用adb调试常用命令连接设备版本信息安装应用卸载应用文件操作日志查看屏幕截图和录制设备重启端口转发调试相关设置属性设备信息查询获取帮助模拟输入介绍 adb全称为 Android Debug Bridge(Android调试桥)，是 A…...

编程日记 2025/1/7 15:49:45

omnipeek分析beacon帧

omnipeek查询设备发送beacon时同一信道两个beacon发送间隔目录用例要求分析抓包数据 1.用例要求 Beacon帧发送频率符合规范要求。参数-【同一个信道两个beacon发送间隔不能超过100ms】 2.分析抓包数据打开becon.pkt文件（用omnipeek工具提前抓取包&#xff09…...

编程日记 2025/1/7 15:47:43

Java数组问题

题目2： 定义一个数组，存储1，2，3，4，5，6，7，8，9，10 遍历数组得到的每一个元素，统计数组里面一共多少个能被3整除的数字 package com.s…...

编程日记 2025/1/7 15:46:43

salesforce 可以为同一个简档的同一个 recordtype 的对象设置多种页面布局吗

在 Salesforce 中，对于同一个 Record Type（记录类型），默认情况下，每个 Profile（用户简档） 只能分配一个 Page Layout（页面布局）。也就是说，页面布局的分配规则…...

编程日记 2025/1/7 15:44:40

使用vue项目中，使用webpack模板和直接用vue.config来配置相关插件区别是什么，具体有哪些提现呢

在 Vue 项目中，使用 Webpack 模板和 vue.config.js 来配置相关插件的主要区别在于配置的复杂度、灵活性和易用性。以下是两者的详细对比： 1. Webpack 模板 Webpack 模板是 Vue CLI 早期版本（如 Vue CLI 2.x）中提供的项目初始化模…...

编程日记 2025/1/7 15:41:36

五、包图

包图、基本概念概念： 用来描述模型中的包和其所含元素的组织方式的图，是维护和控制系统总体结构的重要内容。包可以把所建立的各种模型组织起来，形成各种功能或用途的模块，并可以控制包中元素的可见性以及描述包之间的依赖…...

编程日记 2025/1/7 15:36:30

关于重构一点简单想法

关于重构一点简单想法当前工作的组内，由于业务开启的时间正好处于集团php-》go技术栈全面迁移的时间点，组内语言技术栈存在：php、go两套。因此需求开发过程中通常要考虑两套技术栈的逻辑，一些基础的逻辑也没有办法复用。在这…...

编程日记 2025/1/7 15:34:27

kafka使用以及基于zookeeper集群搭建集群环境

一、环境介绍 zookeeper下载地址：https://zookeeper.apache.org/releases.html kafka下载地址：https://kafka.apache.org/downloads 192.168.142.129 apache-zookeeper-3.8.4-bin.tar.gz kafka_2.13-3.6.0.tgz 192.168.142.130 apache-zookee…...

编程日记 2025/1/7 15:31:19

GAN对抗生成网络（二）——算法及Python实现

1 算法步骤上一篇提到的GAN的最优化问题是，本文记录如何求解这一问题。首先为了表示方便，记，这里让最大的可视作常量。第一步，给定初始的，使用梯度上升找到 ,最大化。关于梯度下降，可以参考笔者另一篇…...

编程日记 2025/1/7 15:28:16

并发线程（21）——线程池

文章目录二十一、day211. 线程池实现1.1 完整代码1.2 解释二十一、day21 我们之前在学习std::future、std::async、std::promise相关的知识时，通过std::promise和packaged_task构建了一个可用的线程池，可参考文章：并发编程（6&a…...

编程日记 2025/1/7 15:27:15

基于32单片机的智能语音家居

一、主要功能介绍以STM32F103C8T6单片机为控制核心，设计一款智能远程家电控制系统，该系统能实现如下功能： 1、可通过语音命令控制照明灯、空调、加热器、窗户及窗帘的开关； 2、可通过手机显示和控制照明灯、空调、窗户及窗帘的开…...

编程日记 2025/1/7 15:26:12

VScode怎么重启

原文链接：【vscode】vscode重新启动键盘按下 Ctrl Shift p 打开命令行，如下图： 输入Reload Window，如下图：...

编程日记 2025/1/7 15:20:06

分析服务器 systemctl 启动gozero项目报错的解决方案

### 分析 systemctl start beisen.service 报错在 Linux 系统中，systemctl 是管理系统和服务的主要工具。当我们尝试重启某个服务时，如果服务启动失败，systemctl 会输出错误信息，帮助我们诊断和解决问题。本文将通过一个实际的…...

编程日记 2025/1/7 15:19:05

大模型LLM-Prompt-OPTIMAL

1 OPTIMAL OPTIMAL 具体每项内容解释如下： Objective Clarity（目标清晰）：明确定义任务的最终目标和预期成果。 Purpose Definition（目的定义）：阐述任务的目的和它的重要性。 Information Gat…...

编程日记 2025/1/7 15:17:02

3. 多线程(1) --- 创建线程，Thread类

文章目录前言1. API2. 创建线程2.1. 继承 Thread类2.2. 实现 Runnable 接口2.3. 匿名内部类2.4. lambda2.5.其他方法 3. Thread类及其常见的方法和属性3.1. Thread 的常见构造方法3.2. Thread 的常见属性3.3. start() --- 启动一个线程3.4. 中断一个线程3.5. 等待线程3.6. 休眠…...

编程日记 2025/1/7 15:14:58

简单的jmeter数据请求学习

简单的jmeter数据请求学习 1.需求我们的流程服务由原来的workflow-server调用wfms进行了优化，将wfms服务操作并入了workflow-server中，去除了原来的webservice服务调用形式，增加了并发处理，现在想测试模拟一下，在一…...

编程日记 2025/1/7 15:13:55

大数据学习（129）-Hive数据分析

🍋🍋大数据学习🍋🍋 🔥系列专栏： 👑哲学语录: 用力所能及，改变世界。 💖如果觉得博主的文章还不错的话，请点赞👍收藏⭐️留言📝支持一…...

编程新知 2025/6/10 0:07:31

PHP 表单 - 验证邮件和URL

PHP 表单 - 验证邮件和URL 引言在Web开发中，表单是用户与网站交互的重要途径。一个功能完善的表单不仅可以收集用户数据，还能提高用户体验。在表单设计中，验证邮件地址和URL是常见的需求。本文将详细介绍如何在PHP中实现邮件和URL的验证&a…...

编程新知 2025/6/9 23:59:04

Spring Cloud Alibaba Seata安装+微服务实战

目录介绍核心功能三层核心架构安装微服务实战创建三个业务数据库编写库存和账户两个Feign接口订单微服务 seata-order-service9701库存微服务 seata-store-service9702账户微服务 seata-account-service9703测试结果总结介绍 Spring Cloud Alibaba Seata 是一款开源的分布式…...

编程新知 2025/6/9 23:09:33

全球化2.0｜云轴科技ZStack助力香港服务机构VMware替代

香港一家大型社会服务机构长期致力于为公众提供支持与服务，是本地具有代表性的社会服务组织，在香港设有数十个服务中心。为应对VMware订阅模式带来的成本上升和硬件资源受限等问题，该机构决定采用云轴科技ZStack Cloud云平台替代VMware虚拟化…...

编程新知 2025/6/9 22:14:30

Elasticsearch从安装到实战、kibana安装以及自定义IK分词器/集成整合SpringBoot详细的教程ES（三）

DSL官方地址： DSL查询分类 Elasticsearch提供了基于JSON的DSL（https://www.elastic.co/docs/explore-analyze/query-filter/languages/querydsl）来定义查询。常见的查询类型包括： 查询所有：查询出所有数据&#xff0…...

编程新知 2025/6/9 19:56:05

html - ＜mark＞标签

<mark> 标签在HTML中用于高亮显示文本，通常用于突出显示某些重要的部分。它的默认样式通常是背景色为黄色，但你可以通过CSS自定义其外观。 1. 基本用法 <mark> 标签用于标记文本的高亮显示。它常用于搜索结果中，突出显示匹配的…...

编程新知 2025/6/9 19:44:42

【Elasticsearch】映射：Join 类型、Flattened 类型、多表关联设计

映射：Join 类型、Flattened 类型、多表关联设计 1.Join 类型1.1 主要应用场景1.1.1 一对多关系建模1.1.2 多层级关系建模1.1.3 需要独立更新子文档的场景1.1.4 文档分离但需要关联查询 1.2 使用注意事项1.3 与 Nested 类型的区别 2.Flattened 类型2.1 实际运用场景和…...

编程新知 2025/6/9 18:25:53

Vue-Leaflet地图组件开发（三）地图控件与高级样式设计

第三篇：Vue-Leaflet地图控件与高级样式设计 1. 专业级比例尺组件实现 1.1 比例尺控件集成 import { LControl } from "vue-leaflet/vue-leaflet";// 在模板中添加比例尺控件 <l-control-scaleposition"bottomleft":imperial"false&qu…...

编程新知 2025/6/9 18:11:12

正则持续学习呀

源匹配为 (.*): (.*)$ 替换匹配为 "$1": "$2", 可将headers改为字典参考【爬虫军火库】如何优雅地复制请求头 - 知乎...

编程新知 2025/6/9 17:53:32

分类场景数据集大全「包含数据标注+训练脚本」 (持续原地更新)

一、作者介绍：六年算法开发经验、AI 算法经理、阿里云专家博主。擅长：检测、分割、理解、大模型等算法训练与推理部署任务。二、数据集介绍： 质量高：高质量图片、高质量标注数据，吐血标注、整理，可以作为…...

编程新知 2025/6/9 14:06:45

python示例

C++示例

相关文章：