一. 訊息佇列的操作

OS_EVENT  *OSQCreate (void **start, INT16U size);

void  *OSQPend (OS_EVENT *pevent, INT16U timeout, INT8U *err);

//以FIFO（先進先出）的方式組織訊息佇列
INT8U  OSQPost (OS_EVENT *pevent, void *msg);

//以LIFO（後進先出）的方式組織訊息佇列
INT8U  OSQPostFront (OS_EVENT *pevent, void *msg);

也就是往MsgTb1[]中新增資料。

4. 清空訊息佇列

INT8U  OSQFlush (OS_EVENT *pevent);

OS_EVENT  *OSQDel (OS_EVENT *pevent, INT8U opt, INT8U *err);

二. 例子

//主要往訊息佇列中發訊息
void  StartTask(void *pdata)
{
    OSStatInit();             /* 初始化ucos的統計任務 */
        OSTaskCreate(MyTask,
                (void*)0,
                &MyTaskStk[TASK_STK_SIZE - 1],
                3);

        OSTaskCreate(YouTask,
                (void*)0,
                &YouTaskStk[TASK_STK_SIZE - 1],
                4);
    
    s = "How many times can receive this string?";
    
    OSQPostFront(Str_Q, s);    //send message LIFO
                
    for (;;)
    {
          if(OSTimeGet()>100 && OSTimeGet()<500)
          {
              s100 = "Now, OSTime value between 100 to 500";
              OSQPostFront(Str_Q, s100);                        //send message
              
              s = "Which Task receive this string?";
              OSQPostFront(Str_Q, s);                                //send message
                      
          }
          
          if(OSTimeGet()>5000 && OSTimeGet()<5500)
          {
              s500 = "Now, OSTime value between 5000 to 5500";
              OSQPostFront(Str_Q, s500);                        //send message
          }

         OSTimeDlyHMSM(0,0,1,0); /* 等待1S */
    }
}

//從訊息佇列中取訊息
void  MyTask(void *pdata)
{
    for (;;)
    {
        PC_DispStr(0, ++y,"MyTask", DISP_BGND_BLACK+DISP_FGND_WHITE);
        
        ss = OSQPend(Str_Q, 0, &err); //request message queue
                    
        PC_DispStr(10,y, ss,DISP_BGND_BLACK+DISP_FGND_WHITE);
        
        OSTimeDlyHMSM(0,0,1,0); /* 等待1s */
    }
}

//從訊息佇列中取訊息
void  YouTask(void *pdata)
{
    for (;;)
    {
        PC_DispStr(0, ++y,"YouTask", DISP_BGND_BLACK+DISP_FGND_WHITE);
        
        ss = OSQPend(Str_Q, 0, &err);//request message queue    
            
        PC_DispStr(10, y, ss, DISP_BGND_BLACK+DISP_FGND_WHITE);

            OSTimeDlyHMSM(0,0,1,0); /* 等待1s */
        
    }
}
 

這個例子是：StartTask往訊息佇列裡發資料，而MyTask、YouTask不停的從佇列中取資料。

現象如下：

從現象可以看出：

1. 在MyTask取出How many times can receive this string? 後，MyTask和YouTask都處於了等待狀態。

2. 一段時間後(OSTime >5000)，來資料了，MyTask先獲得了資料。

3. 當資料取完後，MyTask和YouTask還是都處於了等待狀態。