个人分享心得(八)——线程间通信(消息队列)

发表在 内核学习营2019-4-11 00:12 [复制链接] 1 328

本帖最后由 家定不举棋 于 2019-4-11 00:25 编辑
# k% L5 L/ l2 e. g. E5 i4 E

消息队列

- }5 @+ |  G; d1 S

消息队列 messagequeue:另一种线程间的通信方式,与邮箱不同的是能够接收的消息长度是不固定的。消息队列的结构体如下所示:

/ B5 U& `6 x, J6 z
    struct rt_messagequeue
8 M  E) n' [( ~$ d& v    {
, z  H$ T; `, ]3 h3 _# `- I8 i        struct rt_ipc_object parent;0 ^& T4 O8 V- L( B' `4 |
        void                *msg_pool;
( S* Y! N$ [; c        rt_uint16_t          msg_size;
" c5 Q, Z+ s9 X  N, e        rt_uint16_t          max_msgs;" B, [- z; U& |1 d) k. F
        rt_uint16_t          entry;
8 i3 v$ Z  |! |( |* B( @" F$ v: R        void                *msg_queue_head;
0 P* y3 G8 h/ R: v1 A; S        void                *msg_queue_tail;
. J1 z, V3 I6 T! |& l0 X        void                *msg_queue_free;
. F  u5 V+ L/ J    };
& T  A6 v( ?& S8 K5 t

msg_pool 是指向存放消息的消息池的指针,它跟数组类似,指向的是消息池的首地址;msg_size 是一条消息的长度,后面对该消息队列发送的消息长度都不能超过该长度,若发送的消息长度超过该值则会返回错误标志 -RT_ERROR;
- ]" f4 @0 w* p6 \" r; Emax_mags 是消息池中最大能容纳的消息数,当发送的消息数量超过该值时,则会返回错误标志-RT_EFULL- j! |& h: q6 U9 {5 E entry 是消息队列中的消息数,通过该参数可以知道消息队列中消息的具体数量;
% f/ {( f5 Y/ Q% t' ]* tmsg_queue_head 是消息链表头;msg_queue_tail 是消息链表尾;msg_queue_free  是空闲消息链表。

0 }2 s7 m, g" a/ a3 j" ]6 ^

消息队列的内存池大小即为每条消息的长度与消息队列中能存放的最大消息数和下一条的消息大小之和的乘积:max_msgs * (msg_size + sizeof(struct rt_mq_message))。其中下一条消息的大小为4,即 sizeof(struct rt_mq_message) 的值为4。

0 h9 \: d  W! e7 K  s5 L3 r

第一步便是对创建初始化一个消息队列,这一过程的关键点便是对 msg_sizemax_msgs 两个参数进行设置,而这之中又分为静态初始化消息队列 rt_mq_init 和动态创建消息队列 rt_mq_create。对于静态初始化而言需要注意以下几点:

- a& {/ W* y, _$ h9 v
    4 C: B' c! D, R$ j! g" V
  1. msg_size 的值会自动4字节对齐;
  2. " h  \- S% j4 N  t
  3. msg_size 的值比 pool_size 的值大时,准确的说是 (mq->msg_size + sizeof(struct rt_mq_message)) 的值比 pool_size 的值大时,max_msgs 的值就会变为0;
  4. # L* S, F) n) k$ K: R1 M
  5. pool_size 的值不能超过前面创建的消息队列内存大小,当该值超过了内存队列的大小的时候,初始化的时候可能不会产生错误,但是使用的时候会占用未初始化内存,从而产生未知的bug;
  6. ; j# ?4 A8 b: Q9 X% Q
  7. flag 的值可以设置为 RT_IPC_FLAG_FIFORT_IPC_FLAG_PRIO,对于这两者的区别在前面的帖子里写过;
  8. * q- b$ Z6 g' ^' V! {
+ b. `' Y- u4 I( y5 z; s

而对于动态创建消息队列而言,通过 msg_sizemax_msgs 的值动态分配内存,在动态创建的时候程序允许将 msg_size 设置为0,但是不允许将 max_msgs设置为0。(PS:在真正使用的时候都不允许将上述两个值设置为0,因为在创建的时候没有异常,但是在使用的时候会产生异常。)1 ]' w, C# n) ^ 而对于将 msg_size 设置为0时会自动4字节对齐,那么消息队列结构体中的 msg_size 的值对齐为4,那么如果内存空间有足够的空间进行分配,那么便可以进行分配;但是当 max_msgs 的值设置为0时,向内存空间申请的消息队列内存为 RT_NULL

% Z' m: x& x  q

在正确初始化创建消息队列后便是对其进行使用,我们可以对其以下操作:发送普通消息 rt_mq_send、发送紧急消息 rt_mq_urgent、接收消息 rt_mq_recv
- L* M9 [2 {7 D/ T0 Y& \& g1 f不管发送紧急消息还是普通消息,size 的大小都不能超过 msg_size 的值,而对于接收消息没有这个限制的要求。因为当 size 的值大于 msg_size 时,接收的消息大小自动设置为 msg_size

- e! h* W; P, W" ?# X
使用道具 举报 显示全部楼层 回复
最新评论 | 正序浏览
显示全部楼层 |楼层直达:
发表于 2019-4-11 10:34:33 | 显示全部楼层
使用道具 举报 回复
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

Archiver|手机版|小黑屋|RT-Thread开发者社区  

© 2013-2017 上海睿赛德电子科技有限公司 沪ICP备13014002号-1

Powered by RT-Thread

快速回复 返回顶部 返回列表