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

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

news 2026/1/14 4:43:03

本节体验下多线程。

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

调用支付宝接口响应40004 SYSTEM_ERROR问题排查

在对接支付宝API的时候，遇到了一些问题，记录一下排查过程。 Body:{"datadigital_fincloud_generalsaas_face_certify_initialize_response":{"msg":"Business Failed","code":"40004","sub_msg…...

编程新知 2026/1/8 5:35:53

React hook之useRef

React useRef 详解 useRef 是 React 提供的一个 Hook，用于在函数组件中创建可变的引用对象。它在 React 开发中有多种重要用途，下面我将全面详细地介绍它的特性和用法。基本概念 1. 创建 ref const refContainer useRef(initialValue);initialValu…...

编程新知 2025/6/11 15:21:26

Golang 面试经典题：map 的 key 可以是什么类型？哪些不可以？

Golang 面试经典题：map 的 key 可以是什么类型？哪些不可以？ 在 Golang 的面试中，map 类型的使用是一个常见的考点，其中对 key 类型的合法性是一道常被提及的基础却很容易被忽视的问题。本文将带你深入理解 Golang 中…...

编程新知 2025/12/20 7:42:02

Frozen-Flask ：将 Flask 应用“冻结”为静态文件

Frozen-Flask 是一个用于将 Flask 应用“冻结”为静态文件的 Python 扩展。它的核心用途是：将一个 Flask Web 应用生成成纯静态 HTML 文件，从而可以部署到静态网站托管服务上，如 GitHub Pages、Netlify 或任何支持静态文件的网站服务器。 &am…...

编程新知 2025/12/5 20:57:13

Java多线程实现之Thread类深度解析

Java多线程实现之Thread类深度解析一、多线程基础概念1.1 什么是线程1.2 多线程的优势1.3 Java多线程模型二、Thread类的基本结构与构造函数2.1 Thread类的继承关系2.2 构造函数三、创建和启动线程3.1 继承Thread类创建线程3.2 实现Runnable接口创建线程四、Thread类的核心…...

编程新知 2025/8/28 21:52:02

Python+ZeroMQ实战：智能车辆状态监控与模拟模式自动切换

目录关键点技术实现1 技术实现2 摘要： 本文将介绍如何利用Python和ZeroMQ消息队列构建一个智能车辆状态监控系统。系统能够根据时间策略自动切换驾驶模式（自动驾驶、人工驾驶、远程驾驶、主动安全），并通过实时消息推送更新车…...

编程新知 2025/11/12 0:06:50

为什么要创建 Vue 实例

核心原因：Vue 需要一个「控制中心」来驱动整个应用你可以把 Vue 实例想象成你应用的**「大脑」或「引擎」。它负责协调模板、数据、逻辑和行为，将它们变成一个活的、可交互的应用**。没有这个实例，你的代码只是一堆静态的 HTML、JavaScript 变量和函数，无法「活」起来。 …...

编程新知 2026/1/3 7:21:08

适应性Java用于现代 API：REST、GraphQL 和事件驱动

在快速发展的软件开发领域，REST、GraphQL 和事件驱动架构等新的 API 标准对于构建可扩展、高效的系统至关重要。Java 在现代 API 方面以其在企业应用中的稳定性而闻名，不断适应这些现代范式的需求。随着不断发展的生态系统，Java 在现代 API 方…...

编程新知 2025/11/10 19:07:59

tauri项目，如何在rust端读取电脑环境变量

如果想在前端通过调用来获取环境变量的值，可以通过标准的依赖： std::env::var(name).ok() 想在前端通过调用来获取，可以写一个command函数： #[tauri::command] pub fn get_env_var(name: String) -> Result<String, Stri…...

编程新知 2026/1/9 20:36:45

嵌入式学习之系统编程(九)OSI模型、TCP/IP模型、UDP协议网络相关编程（6.3）

目录一、网络编程--OSI模型二、网络编程--TCP/IP模型三、网络接口四、UDP网络相关编程及主要函数编辑编辑 UDP的特征 socke函数 bind函数 recvfrom函数（接收函数） sendto函数（发送函数） 五、网络编程之 UDP 用…...

编程新知 2026/1/9 13:25:05

python示例

C++示例

相关文章：