52 lines
1.2 KiB
C
52 lines
1.2 KiB
C
|
||
|
||
#include "user_common.h"
|
||
|
||
|
||
// 全局通用队列（所有任务共用）
|
||
QueueHandle_t xGlobalMsgQueue;
|
||
|
||
// 电源相关队列
|
||
QueueHandle_t xPowerTaskQueue;
|
||
|
||
|
||
|
||
|
||
// 消息分发函数用于进行消息分发
|
||
void msg_dispatch_task(void* arg)
|
||
{
|
||
GeneralMsg_t received_msg;
|
||
|
||
// 创建用于任务间通讯的消息队列
|
||
xGlobalMsgQueue = xQueueCreate(
|
||
32, // 队列长度（可存储32条消息）
|
||
sizeof(GeneralMsg_t) // 每条消息大小
|
||
);
|
||
configASSERT(xGlobalMsgQueue != NULL);
|
||
|
||
xPowerTaskQueue = xQueueCreate(
|
||
32, // 队列长度（可存储32条消息）
|
||
sizeof(GeneralMsg_t) // 每条消息大小
|
||
);
|
||
configASSERT(xPowerTaskQueue != NULL);
|
||
|
||
while (1)
|
||
{
|
||
if(xQueueReceive(xGlobalMsgQueue, &received_msg, portMAX_DELAY)) //若没有消息接收则将任务设置为阻塞态
|
||
{
|
||
switch (received_msg.type)
|
||
{
|
||
case MSG_TYPE_POWER_OFF:
|
||
// 将消息下发到电源处理任务中
|
||
xQueueSend(xPowerTaskQueue, &received_msg, 0);
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
} |