嵌入式软件，使用消息队列处理事件的例子。

工程师进阶笔记 · 发表于昨天 17:51

我是老温，一名热爱学习的嵌入式工程师关注我，一起变得更加优秀！
在嵌入式中开发应用消息队列处理事件主要是为了解耦，减少模块与模块之间的耦合。
实现数据结构：
typedef struct msg_node{
void *parm;
void (*handler)(void *parm);
}msg_node_t;  /* 消息数据结构 */
typedefstruct msg_driver{
unsignedint in;             //写入的位置
unsignedint out;             //读出的位置
msg_node_t *buf[MSG_DRIVER_SIZE];
}msg_driver_t;
将消息插入到消息队列中：
bool publish_msg(msg_driver_t *msg_buf, msg_node_t *msg)
{
if( is_msg_buf_full (msg_buf) == TRUE )
{
      return FALSE;
}
msg_buf->buf[msg_buf->in] = msg;
msg_buf->in = (++msg_buf->in) % MSG_DRIVER_SIZE; //防止越界

return TRUE;
}
获取消息：
static msg_node_t *get_messge(msg_driver_t *msg_buf)
{
msg_node_t *msg = NULL;
if( is_msg_buf_empty(msg_buf) )
{
      return NULL;
}
msg = msg_buf->buf[msg_buf->out];
msg_buf->out = (++msg_buf->out) % MSG_DRIVER_SIZE; //防止越界
return msg;
}
从队列循环取出消息处理：
由于每次发布消息都是送的处理函数指针，所以处理函数都不用修改。
void message_driver_handle(msg_driver_t *msg_buf)
{
msg_node_t *msg;
while( (msg = get_messge(msg_buf)) != NULL )
{
  if (msg->handler != NULL)
msg->handler(msg->parm);
}
}
测试：
msg_driver_t msg_driver;
static void msg1_handle(void *parm)
{
printf("gets msg1\r
");
}
static void msg2_handle(void *parm)
{
printf("get msg2\r
");
}
static void msg3_handle(void *parm)
{
printf("do msg3\r
");
}
msg_node_t msg1 = {
.parm = "I love u",
.handler = msg1_handle
};
msg_node_t msg2 = {
.parm = "I hate u",
.handler = msg2_handle
};
msg_node_t msg3 = {
.parm = NULL,
.handler = msg3_handle
};
publish_msg(&msg_driver, &msg1);
publish_msg(&msg_driver, &msg2);
publish_msg(&msg_driver, &msg3);
int main(void)
{
while(1)
{
message_driver_handle(&msg_driver);
}
}
原文：https://blog.csdn.net/qq_36413982/article/details/108110422* n& M0 t+ a9 P$ M8 g& @

-END-
往期推荐：点击图片即可跳转阅读

vehk5oupxuk6406163516.jpg

性能炸裂！关键是，价格非常香，8核2.2GHz+6T算力的开发套件！

hbbi1n1synn6406163616.jpg

手把手教学！把OpenHarmony移植到ARMv9架构，并且开发出好玩的应用程序！

0qrp4pq1qzh6406163716.jpg

一份完善的《嵌入式Linux内核编码风格》官方手册！
我是老温，一名热爱学习的嵌入式工程师
关注我，一起变得更加优秀！