EEPW论坛

    之前使用时间任务调度的方式，完成任务调度处理。今天和大家分享另外一种任务调度的方法。

硬件平台：瑞萨RA0E2 开发板

软件工具：E2s  5.9.0版本。

一：消息队列的基础知识：

1、消息队列只 是一种先进先出的队列型数据结构口，实际上是系统内核中的一个内部链表。消息被顺序插入队列中，其中发送进程将消息添加到队列未尾，接受进程从队列头读取消息。

2、多个进程可同时向一个消息队列发送消息，也可以同时从一个消息队列中接收消息。发送进程把消息发送到队列尾部，接受进程从消息队列头部读取消息，消息一旦被读出就从队列中删除。在主程序中进行处理任务，删除任务。若不删除任务，会导致任务堆栈的溢出，从而导致程序的进入硬件错误。

二、结构

1、消息队列中消息本身由消息类型和消息数据组成，通常使用如下结构:

typedef  struct MESSAGE0    //消息结构体
{
int iWParm;   //消息参数
int iLParm;
int Mnumber;  //消息值，取值1-254
}MESSAGE;

1) iWparm 指定了消息类型，为正整数。

引入消息类型之后，消息队列在逻辑上由一个消息链表转化为多个消息链表。发送进程仍然无条件把消息写入队列的尾部，但接收进程却可以有选择地读取某个特定类型的消息中最接近队列头的一个，即使该消息不在队列头。相应消息一旦被读取，就从队列中删除，其它消息维持不变。

2)iLParm指定了消息的数据。我们可以定义任意的数据类型甚至包括结构来描述消息数据。

2:消息队列的创建：

定义消息队列的深度和当前指针的个数

MESSAGE ArrayMessage[MES_MAX];   //消息队列最大64
static char  CurrentMesgPoint;   //当前需要操作的消息指针

具体的创建任务如下，组成环形队列

/***************************************************************************************
*SendMessage()
*发送消息到消息队列
*Mnumber:消息值
*WParm:消息参数1
*LParm:消息参数2
****************************************************************************************/
void SendMessage(char Mnumber,int WParm,int LParm)
{
char i;
CurrentMesgPoint++; //这样处理的原因是避免在SendMessage函数重入导致的消息被改写的BUG
if(CurrentMesgPoint >= MES_MAX)
CurrentMesgPoint = 0;
i = CurrentMesgPoint;
if(ArrayMessage[i].Mnumber == 0)
{
ArrayMessage[i].Mnumber = Mnumber;
ArrayMessage[i].iWParm = WParm;
ArrayMessage[i].iLParm = LParm;
return;
}
}

3：消息队列的删除：

/***************************************************************************************
*DeleteMessage()
*从消息队列中删除消息
*MPoint:消息队列数组下标
****************************************************************************************/
void DeleteMessage(char MPoint)
{
ArrayMessage[MPoint].iWParm = 0;
ArrayMessage[MPoint].iLParm = 0;
ArrayMessage[MPoint].Mnumber=0; //避免函数重载出现BUG，对Mnumber的改写放在最后面
}

三：软件代码的如下所示：

3.1 在定时器0中添加100ms，200ms，1000ms的任务：

void g_timer0_callback(timer_callback_args_t *p_args)
{
if (TIMER_EVENT_CYCLE_END == p_args->event)
{
time0Point++ ;

if(time0Point %100 == 0)
SendMessage(MW_TIMERINT,1,0);  //发出TIM 100ms中断消息
if(time0Point %200 == 0)
SendMessage(MW_TIMERINT,2,0);  //发出TIM 100ms中断消息
if(time0Point %1000 == 0)
{
time0Point = 0 ;
SendMessage(MW_TIMERINT,10,0);  //发出TIM 100ms中断消息
}
}
}

3.2 添加定时器的处理任务函数：

void System_Tim_Driver(char Tim_Intev)
{
switch(Tim_Intev)
{
case 1:  printf("EEPW world test printf!  by queue test!!\n");//100ms

break;

case 2:     if(dataflag ==0)
{
dataflag =1 ;
R_IOPORT_PinWrite(&g_ioport_ctrl, BSP_IO_PORT_01_PIN_03, BSP_IO_LEVEL_LOW);
}
else
{
dataflag =0 ;
R_IOPORT_PinWrite(&g_ioport_ctrl, BSP_IO_PORT_01_PIN_03, BSP_IO_LEVEL_HIGH);
}
break;
default:break;
}
}

3.3 在主函数添加对消息任务的处理如下所示：

while(1)
{
//       Task_Pro_Handler_Callback();
mspoint ++;
if(mspoint>=MES_MAX)    mspoint = 0;    //消息循环查讯
if(ArrayMessage[mspoint].Mnumber !=0)
{
switch(ArrayMessage[mspoint].Mnumber)
{
case MW_TIMERINT:
System_Tim_Driver(ArrayMessage[mspoint].iWParm);
break;
default:
break;
}
DeleteMessage(mspoint);  //删除已经处理的消息
}
}

四：验证如下所示

1、采用消息队列方式比之前采用时间任务调度具有更多的灵活性，通信的进程不但没有时间上的要求，也不需要进行同步处理。只需要根据消息触发的顺序，进行执行，从响应时效性上更加的灵活。

2、消息队列是一种先进先出的队列型数据结构;

3、消息队列将输出的信息进行了打包处理，可以保证以消息为单位进行接收;为了防止消息队列的溢出，可以将任务队列加大，从而使实现任务深度的增加，防止任务的丢失。