RTthread线程间通信(邮箱,消息队列,信号/软件中断)---01实际使用API函数

本文主要是介绍RTthread线程间通信(邮箱,消息队列,信号/软件中断)---01实际使用API函数,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!


layout: post
title: “RT-Thread线程间通信”
date: 2024-2-5 15:39:08 +0800
tags: RT-Thread


线程间通信

这一篇是实际使用, 代码分析看后面的文章

一般可以使用全局变量以及线程间同步进行实现

RT-Thread也提供了一部分的通信机制

邮箱

一个线程发送, 另外的线程接受信息, 进行处理

使用邮箱的时候每一次只能发送一个四字节的数据(32位处理器),特点是开销比较低,效率较高

可以发送一个地址从而达到发送多个数据的目的

非阻塞方式的邮件发送过程能够安全的应用于中断服务中, 发送以及接受信息的时候可以使用阻塞的模式

邮箱有一个缓存区, 使用rt_mailbox_t进行控制

实际使用

image-20240205161002594

创建(初始化)
/** 动态的方式创建* This function will create a mailbox object from system resource** @param name the name of mailbox 记录一个名字* @param size the size of mailbox 记录一下缓存区的大小* @param flag the flag of mailbox 一个标志位** @return the created mailbox, RT_NULL on error happen*/
rt_mailbox_t rt_mb_create(const char *name, rt_size_t size, rt_uint8_t flag)/** 静态的方式创建* This function will initialize a mailbox and put it under control of resource* management.** @param mb the mailbox object 邮箱的句柄* @param name the name of mailbox 名字* @param msgpool the begin address of buffer to save received mail 缓存区的地址* @param size the size of mailbox	缓冲区大小* @param flag the flag of mailbox 标志** @return the operation status, RT_EOK on successful*/
rt_err_t rt_mb_init(rt_mailbox_t mb,const char  *name,void        *msgpool,rt_size_t    size,rt_uint8_t   flag)

这一个标志位可以为RT_IPC_FLAG_FIFO或RT_IPC_FLAG_PRIO, 设置的是挂起任务被释放的时候是按照进入的顺序先进入的先出去还是优先级比较高的先出去

删除
/**动态* This function will delete a mailbox object and release the memory** @param mb the mailbox object** @return the error code*/
rt_err_t rt_mb_delete(rt_mailbox_t mb)
/**静态* This function will detach a mailbox from resource management** @param mb the mailbox object** @return the operation status, RT_EOK on successful*/
rt_err_t rt_mb_detach(rt_mailbox_t mb)
发送邮件
/*** This function will send a mail to mailbox object, if there are threads* suspended on mailbox object, it will be waked up. This function will return* immediately, if you want blocking send, use rt_mb_send_wait instead.** @param mb the mailbox object* @param value the mail 要发送的数据** @return the error code*/
rt_err_t rt_mb_send(rt_mailbox_t mb, rt_ubase_t value)

这是一个不等待的时钟发送函数

/*** This function will send a mail to mailbox object. If the mailbox is full,* current thread will be suspended until timeout.** @param mb the mailbox object* @param value the mail* @param timeout the waiting time 多了一个等待时间** @return the error code*/
rt_err_t rt_mb_send_wait(rt_mailbox_t mb,rt_ubase_t   value,rt_int32_t   timeout)
接收
/*** This function will receive a mail from mailbox object, if there is no mail* in mailbox object, the thread shall wait for a specified time.** @param mb the mailbox object* @param value the received mail will be saved in 给出一个存放收到的数据的位置* @param timeout the waiting time** @return the error code*/
rt_err_t rt_mb_recv(rt_mailbox_t mb, rt_ubase_t *value, rt_int32_t timeout)

使用技巧

可以使用一个这样的结构体, 每次发送这一个结构体的地址, 进行大于32字节的数据发送

struct msg
{uint32_t *data;uint32_t size;
}

消息队列

是邮箱的扩展, 没有4字节的限制

消息队列能够接收来自线程或中断服务例程中不固定长度的消息,并把消息缓存在自己的内存空间中。这些消息使用的是链表进行连接, 消息先进先出

这一个使用的拷贝的模式进行传输, 不建议直接发送大量数据(可以发送一个地址)

可以用于发送不定长的数据, 实际使用的时候可以使用消息队列发送消息, 使用邮箱表示接收到数据了

image-20240205164352685

实际使用

image-20240205164847142

创建
/**动态* This function will create a message queue object from system resource** @param name the name of message queue 名字* @param msg_size the size of message	每一个消息的大小(字节)* @param max_msgs the maximum number of message in queue 记录一下消息的最大的个数* @param flag the flag of message queue 一个标志** @return the created message queue, RT_NULL on error happen*/
rt_mq_t rt_mq_create(const char *name,rt_size_t   msg_size,rt_size_t   max_msgs,rt_uint8_t  flag)
/**静态* This function will initialize a message queue and put it under control of* resource management.** @param mq the message object	对象的句柄* @param name the name of message queue* @param msgpool the beginning address of buffer to save messages 缓冲区的地址, 动态申请*		 的时候这个的大小是 (一个数据的大小+sizeof(struct rt_mq_message)) * mq->max_msgs* @param msg_size the maximum size of message一个消息的大小* @param pool_size the size of buffer to save messages 缓冲区的大小* @param flag the flag of message queue** @return the operation status, RT_EOK on successful*/
rt_err_t rt_mq_init(rt_mq_t     mq,const char *name,void       *msgpool,rt_size_t   msg_size,rt_size_t   pool_size,rt_uint8_t  flag)

这一个标志位可以为RT_IPC_FLAG_FIFO或RT_IPC_FLAG_PRIO, 设置的是挂起任务被释放的时候是按照进入的顺序先进入的先出去还是优先级比较高的先出去

删除
/**动态* This function will delete a message queue object and release the memory** @param mq the message queue object** @return the error code*/
rt_err_t rt_mq_delete(rt_mq_t mq)
/**静态* This function will detach a message queue object from resource management** @param mq the message queue object** @return the operation status, RT_EOK on successful*/
rt_err_t rt_mq_detach(rt_mq_t mq)
发送消息
/*** This function will send a message to message queue object, if there are* threads suspended on message queue object, it will be waked up.** @param mq the message queue object * @param buffer the message 发送的消息的地址* @param size the size of buffer 发送的数据的大小** @return the error code*/
rt_err_t rt_mq_send(rt_mq_t mq, const void *buffer, rt_size_t size)

不等待

/*** This function will send a message to message queue object. If the message queue is full,* current thread will be suspended until timeout.** @param mq the message queue object* @param buffer the message* @param size the size of buffer* @param timeout the waiting time** @return the error code*/
rt_err_t rt_mq_send_wait(rt_mq_t     mq,const void *buffer,rt_size_t   size,rt_int32_t  timeout)

等待

/*** This function will send an urgent message to message queue object, which* means the message will be inserted to the head of message queue. If there* are threads suspended on message queue object, it will be waked up.** @param mq the message queue object* @param buffer the message* @param size the size of buffer** @return the error code*/
rt_err_t rt_mq_urgent(rt_mq_t mq, const void *buffer, rt_size_t size)

发送一个紧急的消息, 这一个消息会直接放到队首

接收
/*** This function will receive a message from message queue object, if there is* no message in message queue object, the thread shall wait for a specified* time.** @param mq the message queue object* @param buffer the received message will be saved in 接收到的数据* @param size the size of buffer* @param timeout the waiting time** @return the error code*/
rt_err_t rt_mq_recv(rt_mq_t    mq,void      *buffer,rt_size_t  size,rt_int32_t timeout)

信号(软件中断信号)

**注: **信号这块应该是要在微内核里使用,如果你是用宏内核版本,不推荐使用信号功能。

POSIX标准定义了sigset_t类型来定义一个信号集, 实际是一个unsigned long类型的数据, 应用程序能够使用的信号为SIGUSR1(10)和SIGUSR2(12)

他的本质是一个软件中断

收到信号的线程实际的处理方法有三种

  • 类似中断的处理程序,对于需要处理的信号,线程可以指定处理函数,由该函数来处理。
  • 忽略某个信号,对该信号不做任何处理,就像未发生过一样。
  • 对该信号的处理保留系统的默认值。

image-20240205171441255

需要定义RT_USING_SIGNALS这一个宏

实际使用

image-20240205171459644

安装信号

如果线程要处理某一信号,那么就要在线程中安装该信号。

主要用来确定信号值及线程针对该信号值的动作之间的映射关系,即线程将要处理哪个信号,该信号被传递给线程时,将执行何种操作。

rt_sighandler_t rt_signal_install(int signo, rt_sighandler_t handler)

(这一个函数是给现在的线程安装)

signo信号值(只有SIGUSR1和SIGUSR2是开放给用户使用的)

handler设置对信号值的处理方式, 这一个的实际的函数是void (*rt_sighandler_t)(int signo);

也可以使用SIG_IGN,忽略某个信号, SIG_DFL,系统会调用默认的处理函数_signal_default_handler()

返回安装信号前的handler值表示成功

阻塞(屏蔽)信号

该信号将不会递达给安装此信号的线程,也不会引发软中断处理。

void rt_signal_mask(int signo)
解除信号阻塞
void rt_signal_unmask(int signo)
发送信号
int rt_thread_kill(rt_thread_t tid, int sig)

tid: 接收信号的线程

sig: 信号值

等待信号
int rt_signal_wait(const rt_sigset_t *set, rt_siginfo_t *si, rt_int32_t timeout)

set: 指定等待的信号

si: 指向存储等到信号信息的指针

这篇关于RTthread线程间通信(邮箱,消息队列,信号/软件中断)---01实际使用API函数的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/682603

相关文章

使用Python和OpenCV库实现实时颜色识别系统

《使用Python和OpenCV库实现实时颜色识别系统》:本文主要介绍使用Python和OpenCV库实现的实时颜色识别系统,这个系统能够通过摄像头捕捉视频流,并在视频中指定区域内识别主要颜色(红... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间详解

Windows下C++使用SQLitede的操作过程

《Windows下C++使用SQLitede的操作过程》本文介绍了Windows下C++使用SQLite的安装配置、CppSQLite库封装优势、核心功能(如数据库连接、事务管理)、跨平台支持及性能优... 目录Windows下C++使用SQLite1、安装2、代码示例CppSQLite:C++轻松操作SQ

Python常用命令提示符使用方法详解

《Python常用命令提示符使用方法详解》在学习python的过程中,我们需要用到命令提示符(CMD)进行环境的配置,:本文主要介绍Python常用命令提示符使用方法的相关资料,文中通过代码介绍的... 目录一、python环境基础命令【Windows】1、检查Python是否安装2、 查看Python的安

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

《Python并行处理实战之如何使用ProcessPoolExecutor加速计算》Python提供了多种并行处理的方式,其中concurrent.futures模块的ProcessPoolExecu... 目录简介完整代码示例代码解释1. 导入必要的模块2. 定义处理函数3. 主函数4. 生成数字列表5.

Python中help()和dir()函数的使用

《Python中help()和dir()函数的使用》我们经常需要查看某个对象(如模块、类、函数等)的属性和方法,Python提供了两个内置函数help()和dir(),它们可以帮助我们快速了解代... 目录1. 引言2. help() 函数2.1 作用2.2 使用方法2.3 示例(1) 查看内置函数的帮助(

Linux脚本(shell)的使用方式

《Linux脚本(shell)的使用方式》:本文主要介绍Linux脚本(shell)的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录概述语法详解数学运算表达式Shell变量变量分类环境变量Shell内部变量自定义变量:定义、赋值自定义变量:引用、修改、删

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.

Python中使用uv创建环境及原理举例详解

《Python中使用uv创建环境及原理举例详解》uv是Astral团队开发的高性能Python工具,整合包管理、虚拟环境、Python版本控制等功能,:本文主要介绍Python中使用uv创建环境及... 目录一、uv工具简介核心特点:二、安装uv1. 通过pip安装2. 通过脚本安装验证安装:配置镜像源(可

C++ 函数 strftime 和时间格式示例详解

《C++函数strftime和时间格式示例详解》strftime是C/C++标准库中用于格式化日期和时间的函数,定义在ctime头文件中,它将tm结构体中的时间信息转换为指定格式的字符串,是处理... 目录C++ 函数 strftipythonme 详解一、函数原型二、功能描述三、格式字符串说明四、返回值五

LiteFlow轻量级工作流引擎使用示例详解

《LiteFlow轻量级工作流引擎使用示例详解》:本文主要介绍LiteFlow是一个灵活、简洁且轻量的工作流引擎,适合用于中小型项目和微服务架构中的流程编排,本文给大家介绍LiteFlow轻量级工... 目录1. LiteFlow 主要特点2. 工作流定义方式3. LiteFlow 流程示例4. LiteF