ucos-ii示例5:消息隊(duì)列測試

環(huán)境：

主機(jī):WIN8

開發(fā)環(huán)境:MDK4.72

ucgui版本：3.90

ucos版本：ucos-ii

mcu: stm32f103VE

說明:

本示例中task1時間片為1s，task2時間片為8s。task1每秒往消息隊(duì)列寫入1個數(shù)據(jù)，task2全部讀取出來。所以task2每次能讀到8個數(shù)據(jù)。

注意：

1.消息隊(duì)列需要一個指針數(shù)組指向消息

2.應(yīng)該有一個固定的消息數(shù)組存儲消息，不應(yīng)將局部變量填入發(fā)送消息函數(shù)

3.QSQPost為先進(jìn)先出函數(shù)(FIFO)，QSQPostFornt為后進(jìn)先出函數(shù)(LIFO)

效果圖：

源碼：

#defineTASK_STK_SIZE512

/*********************************************************************

*靜態(tài)函數(shù)

**********************************************************************/

staticvoidtask_start(void*pdata);

staticvoidtask1(void*pdata);

staticvoidtask2(void*pdata);

/*********************************************************************

*靜態(tài)變量

**********************************************************************/

/*********************************************************************

*任務(wù)堆?？臻g

**********************************************************************/

staticOS_STKTask_Start_Stk[TASK_STK_SIZE];

staticOS_STKTask1_Stk[TASK_STK_SIZE];

staticOS_STKTask2_Stk[TASK_STK_SIZE];

/*********************************************************************

*信號量

**********************************************************************/

OS_EVENT*Semaphore;

/*********************************************************************

*消息隊(duì)列數(shù)組

**********************************************************************/

void*Msg_Group[10];

charMsg_Arr[10][30];

uint8_tIndex_Msg_Arr=0;

/*********************************************************************

*函數(shù)

**********************************************************************/

intmain(void)

{

//初始化內(nèi)核

OSInit();

//創(chuàng)建任務(wù)

OSTaskCreate(task_start,(void*)0,Task_Start_Stk+TASK_STK_SIZE-1,10);

//啟動任務(wù)

OSStart();

}

/*********************************************************************

*任務(wù)函數(shù)

**********************************************************************/

staticvoidtask_start(void*pdata)

{

//載入世界

world_load();

//設(shè)置背景色

GUI_SetBkColor(0xb07c17);

GUI_Clear();

GUI_SetColor(GUI_BLACK);

Semaphore=OSQCreate(Msg_Group,10);

//新建任務(wù)

OSTaskCreate(task1,(void*)0,Task1_Stk+TASK_STK_SIZE-1,11);

OSTaskCreate(task2,(void*)0,Task2_Stk+TASK_STK_SIZE-1,12);

while(1)

{

OSTimeDlyHMSM(0,0,3,0);

}

}

staticvoidtask1(void*pdata)

{

charstr[30]={0};

uint8_terr=0;

char*mail;

uint8_ti=0;

OS_Q_DATAquery;

while(1)

{

//打印接收的消息

OSQQuery(Semaphore,&query);

for(i=0;i

{

//請求信號量

mail=OSQPend(Semaphore,0,&err);

//顯示

sprintf(str,"task1receive:%s",mail);

GUI_DispStringHCenterAt(str,120,40+i*20);

}

//顯示

sprintf(str,"task1time:%ds",OSTimeGet());

GUI_DispStringHCenterAt(str,120,5);

WM_Exec();

OSTimeDlyHMSM(0,0,8,0);

}

}

staticvoidtask2(void*pdata)

{

charstr[30]={0};

while(1)

{

//顯示

sprintf(*(Msg_Arr+Index_Msg_Arr),"task2send:%ds",OSTimeGet());

//發(fā)送信號量

OSQPost(Semaphore,*(Msg_Arr+Index_Msg_Arr));

Index_Msg_Arr++;

if(Index_Msg_Arr>=10)

{

Index_Msg_Arr=0;

}

//顯示

sprintf(str,"task2time:%ds",OSTimeGet());

GUI_DispStringHCenterAt(str,120,20);

WM_Exec();

OSTimeDlyHMSM(0,0,1,0);

}

}