zhangzhaopeng/fusion
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

同步更新示例

Browse Source
This commit is contained in:
张兆鹏
2026-01-12 17:47:15 +08:00
parent a02dc81bbf
commit 85ab99350e
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
mw/has_task_msg_manager/msg_example.c
View File

@@ -43,8 +43,8 @@ void *gui_function(void *arg)
has_msg_publish(GUI, gui_publish_buffer3, sizeof(gui_publish_buffer3)); // GUI发布第三条消息 has_msg_publish(GUI, gui_publish_buffer3, sizeof(gui_publish_buffer3)); // GUI发布第三条消息
while (1) while (1)
{ {
usleep(500 * 1000); // usleep(500 * 1000);
has_msg_handle(GUI, gui_handle_cb); // 处理一条GUI收到的消息，先入先出 has_msg_handle(GUI, gui_handle_cb, 500); // 处理一条GUI收到的消息，先入先出
} }
} }
@@ -63,9 +63,9 @@ void *sensor_function(void *arg)
has_msg_publish(moude_ID, sensor_publish_buffer2, sizeof(sensor_publish_buffer2)); // SENSOR发布第二条消息 has_msg_publish(moude_ID, sensor_publish_buffer2, sizeof(sensor_publish_buffer2)); // SENSOR发布第二条消息
while (1) while (1)
{ {
usleep(500 * 1000); // usleep(500 * 1000);
has_msg_handle(moude_ID, sensor_handle_cb); // 处理一条SENSOR收到的消息，先入先出 has_msg_handle(moude_ID, sensor_handle_cb, 500); // 处理一条SENSOR收到的消息，先入先出
has_msg_handle_latest(moude_ID, sensor_handle_cb); // 处理一条SENSOR最新收到的消息 has_msg_handle_latest(moude_ID, sensor_handle_cb, 0); // 处理一条SENSOR最新收到的消息
if (has_msg_is_message_empty(moude_ID) != 0) // 判断是否还有消息未处理 if (has_msg_is_message_empty(moude_ID) != 0) // 判断是否还有消息未处理
{ {
printf("模块：%d 还有%d条消息待处理\n", moude_ID, has_msg_get_message_number(moude_ID)); printf("模块：%d 还有%d条消息待处理\n", moude_ID, has_msg_get_message_number(moude_ID));