环境：
主机:WIN8
开发环境:MDK4.72
ucgui版本：3.90
ucos版本：ucos-ii
mcu: stm32f103VE
说明:
本示例中task1时间片为1s，task2时间片为8s。task1每秒往消息队列写入1个数据，task2全部读取出来。所以task2每次能读到8个数据。
注意：
1.消息队列需要一个指针数组指向消息
2.应该有一个固定的消息数组存储消息，不应将局部变量填入发送消息函数
3.QSQPost为先进先出函数(FIFO)，QSQPostFornt为后进先出函数(LIFO)
效果图：
源码：
#defineTASK_STK_SIZE512
/*********************************************************************
*静态函数
**********************************************************************/
staticvoidtask_start(void*pdata);
staticvoidtask1(void*pdata);
staticvoidtask2(void*pdata);
/*********************************************************************
*静态变量
**********************************************************************/
/*********************************************************************
*任务堆栈空间
**********************************************************************/
staticOS_STKTask_Start_Stk[TASK_STK_SIZE];
staticOS_STKTask1_Stk[TASK_STK_SIZE];
staticOS_STKTask2_Stk[TASK_STK_SIZE];
/*********************************************************************
*信号量
**********************************************************************/
OS_EVENT*Semaphore;
/*********************************************************************
*消息队列数组
**********************************************************************/
void*Msg_Group[10];
charMsg_Arr[10][30];
uint8_tIndex_Msg_Arr=0;
/*********************************************************************
*函数
**********************************************************************/
intmain(void)
{
//初始化内核
OSInit();
//创建任务
OSTaskCreate(task_start,(void*)0,Task_Start_Stk+TASK_STK_SIZE-1,10);
//启动任务
OSStart();
}
/*********************************************************************
*任务函数
**********************************************************************/
staticvoidtask_start(void*pdata)
{
//载入世界
world_load();
//设置背景色
GUI_SetBkColor(0xb07c17);
GUI_Clear();
GUI_SetColor(GUI_BLACK);
Semaphore=OSQCreate(Msg_Group,10);
//新建任务
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()); //发送信号量 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); } }
