找回密码
 立即注册

QQ登录

只需一步,快速开始

搜索
查看: 3180|回复: 1
收起左侧

stm32f4 UCOSIII任务内建消息队列的源码

[复制链接]
ID:82098 发表于 2018-5-29 22:16 | 显示全部楼层 |阅读模式
UCOS扩展例程- UCOSIII任务内建消息队列

单片机源程序如下:
  1. #include "sys.h"
  2. #include "delay.h"
  3. #include "usart.h"
  4. #include "led.h"
  5. #include "lcd.h"
  6. #include "key.h"
  7. #include "pcf8574.h"
  8. #include "ltdc.h"
  9. #include "sdram.h"
  10. #include "malloc.h"
  11. #include "includes.h"


  12. //任务优先级
  13. #define START_TASK_PRIO                3
  14. //任务堆栈大小       
  15. #define START_STK_SIZE                 128
  16. //任务控制块
  17. OS_TCB StartTaskTCB;
  18. //任务堆栈       
  19. CPU_STK START_TASK_STK[START_STK_SIZE];
  20. //任务函数
  21. void start_task(void *p_arg);

  22. //任务优先级
  23. #define MAIN_TASK_PRIO                4
  24. //任务堆栈大小       
  25. #define MAIN_STK_SIZE                 128
  26. //任务控制块
  27. OS_TCB Main_TaskTCB;
  28. //任务堆栈       
  29. CPU_STK MAIN_TASK_STK[MAIN_STK_SIZE];
  30. void main_task(void *p_arg);

  31. //任务优先级
  32. #define MSGDIS_TASK_PRIO        6
  33. //任务堆栈
  34. #define MSGDIS_STK_SIZE                128
  35. //任务控制块
  36. OS_TCB        Msgdis_TaskTCB;
  37. //任务堆栈
  38. CPU_STK        MSGDIS_TASK_STK[MSGDIS_STK_SIZE];
  39. //任务函数
  40. void msgdis_task(void *p_arg);

  41. //LCD刷屏时使用的颜色
  42. int lcd_discolor[14]={        WHITE, BLACK, BLUE,  BRED,      
  43.                                                 GRED,  GBLUE, RED,   MAGENTA,                
  44.                                                 GREEN, CYAN,  YELLOW,BROWN,                        
  45.                                                 BRRED, GRAY };

  46. #define TASK_Q_NUM        4                //发任务内建消息队列的长度
  47.                                                
  48. ////////////////////////定时器////////////////////////////////
  49. u8 tmr1sta=0;         //标记定时器的工作状态
  50. OS_TMR        tmr1;        //定义一个定时器
  51. void tmr1_callback(void *p_tmr,void *p_arg); //定时器1回调函数
  52.                                                
  53.                                                
  54. //加载主界面
  55. void ucos_load_main_ui(void)
  56. {
  57.         POINT_COLOR = RED;
  58.         LCD_ShowString(10,10,200,16,16,"Apollo STM32F4/F7");       
  59.         LCD_ShowString(10,30,200,16,16,"UCOSIII Examp 11-2");
  60.         LCD_ShowString(10,50,200,16,16,"Task Queue");
  61.         LCD_ShowString(10,70,220,16,16,"KEY_UP:Tmr1");
  62.         LCD_ShowString(10,90,200,16,16,"2016/1/21");
  63.        
  64.         POINT_COLOR = BLACK;
  65.         LCD_DrawLine(0,107,239,107);                //画线
  66.         POINT_COLOR = RED;
  67.         LCD_ShowString(30,130,100,16,16,"tmr1 state:");
  68.         LCD_ShowString(30,170,120,16,16,"Task_QMsg Size:");
  69.         LCD_ShowString(30,210,120,16,16,"Task_QMsg rema:");
  70.         LCD_ShowString(30,250,100,16,16,"Task_QMsg:");
  71.         POINT_COLOR = BLUE;
  72.         LCD_ShowString(40,150,100,16,16,"TMR1 STOP! ");
  73. }

  74. //查询DATA_Msg消息队列中的总队列数量和剩余队列数量
  75. void check_msg_queue(u8 *p)
  76. {
  77.         CPU_SR_ALLOC();
  78.         u8 msgq_remain_size;        //消息队列剩余大小
  79.         OS_CRITICAL_ENTER();        //进入临界段
  80.         msgq_remain_size =Msgdis_TaskTCB.MsgQ.NbrEntriesSize-Msgdis_TaskTCB.MsgQ.NbrEntries;
  81.         p = mymalloc(SRAMIN,20);        //申请内存
  82.         sprintf((char*)p,"Total Size:%d",Msgdis_TaskTCB.MsgQ.NbrEntriesSize);        //显示DATA_Msg消息队列总的大小
  83.         LCD_ShowString(40,190,100,16,16,p);
  84.         sprintf((char*)p,"Remain Size:%d",msgq_remain_size);        //显示DATA_Msg剩余大小
  85.         LCD_ShowString(40,230,100,16,16,p);
  86.         myfree(SRAMIN,p);                //释放内存
  87.         OS_CRITICAL_EXIT();                //退出临界段
  88. }
  89.                         
  90. int main(void)
  91. {
  92.     OS_ERR err;
  93.         CPU_SR_ALLOC();
  94.    
  95.     Stm32_Clock_Init(360,25,2,8);   //设置时钟,180Mhz   
  96.     HAL_Init();                     //初始化HAL库
  97.     delay_init(180);                //初始化延时函数
  98.     uart_init(115200);              //初始化USART
  99.     LED_Init();                     //初始化LED
  100.     KEY_Init();                     //初始化按键
  101.     PCF8574_Init();                 //初始化PCF8974
  102.     SDRAM_Init();                   //初始化SDRAM
  103.         LCD_Init();                                    //初始化LCD
  104.     my_mem_init(SRAMIN);            //初始化内部内存池
  105.     ucos_load_main_ui();            //加载主UI
  106.    
  107.         OSInit(&err);                            //初始化UCOSIII
  108.         OS_CRITICAL_ENTER();                //进入临界区       
  109.         //创建开始任务
  110.         OSTaskCreate((OS_TCB         * )&StartTaskTCB,                //任务控制块
  111.                                  (CPU_CHAR        * )"start task",                 //任务名字
  112.                  (OS_TASK_PTR )start_task,                         //任务函数
  113.                  (void                * )0,                                        //传递给任务函数的参数
  114.                  (OS_PRIO          )START_TASK_PRIO,     //任务优先级
  115.                  (CPU_STK   * )&START_TASK_STK[0],        //任务堆栈基地址
  116.                  (CPU_STK_SIZE)START_STK_SIZE/10,        //任务堆栈深度限位
  117.                  (CPU_STK_SIZE)START_STK_SIZE,                //任务堆栈大小
  118.                  (OS_MSG_QTY  )0,                                        //任务内部消息队列能够接收的最大消息数目,为0时禁止接收消息
  119.                  (OS_TICK          )0,                                        //当使能时间片轮转时的时间片长度,为0时为默认长度,
  120.                  (void           * )0,                                        //用户补充的存储区
  121.                  (OS_OPT      )OS_OPT_TASK_STK_CHK|OS_OPT_TASK_STK_CLR|OS_OPT_TASK_SAVE_FP, //任务选项,为了保险起见,所有任务都保存浮点寄存器的值
  122.                  (OS_ERR         * )&err);                                //存放该函数错误时的返回值
  123.         OS_CRITICAL_EXIT();                    //退出临界区         
  124.         OSStart(&err);                  //开启UCOSIII
  125.     while(1)
  126.     {
  127.         }
  128. }

  129. //开始任务函数
  130. void start_task(void *p_arg)
  131. {
  132.         OS_ERR err;
  133.         CPU_SR_ALLOC();
  134.         p_arg = p_arg;
  135.        
  136.         CPU_Init();
  137. #if OS_CFG_STAT_TASK_EN > 0u
  138.    OSStatTaskCPUUsageInit(&err);          //统计任务               
  139. #endif
  140.        
  141. #ifdef CPU_CFG_INT_DIS_MEAS_EN                //如果使能了测量中断关闭时间
  142.     CPU_IntDisMeasMaxCurReset();       
  143. #endif
  144.        
  145. #if        OS_CFG_SCHED_ROUND_ROBIN_EN  //当使用时间片轮转的时候
  146.         //使能时间片轮转调度功能,设置默认的时间片长度
  147.         OSSchedRoundRobinCfg(DEF_ENABLED,1,&err);  
  148. #endif       
  149.                
  150.         OS_CRITICAL_ENTER();        //进入临界区
  151.         //创建定时器1
  152.         OSTmrCreate((OS_TMR                *)&tmr1,                //定时器1
  153.                 (CPU_CHAR        *)"tmr1",                //定时器名字
  154.                 (OS_TICK         )0,                        //0ms
  155.                 (OS_TICK         )50,           //50*10=500ms
  156.                 (OS_OPT                 )OS_OPT_TMR_PERIODIC, //周期模式
  157.                 (OS_TMR_CALLBACK_PTR)tmr1_callback,//定时器1回调函数
  158.                 (void            *)0,                        //参数为0
  159.                 (OS_ERR            *)&err);                //返回的错误码
  160.         //创建主任务
  161.         OSTaskCreate((OS_TCB         * )&Main_TaskTCB,               
  162.                                  (CPU_CHAR        * )"Main task",                
  163.                  (OS_TASK_PTR )main_task,                        
  164.                  (void                * )0,                                       
  165.                  (OS_PRIO          )MAIN_TASK_PRIO,     
  166.                  (CPU_STK   * )&MAIN_TASK_STK[0],       
  167.                  (CPU_STK_SIZE)MAIN_STK_SIZE/10,       
  168.                  (CPU_STK_SIZE)MAIN_STK_SIZE,               
  169.                  (OS_MSG_QTY  )0,                                       
  170.                  (OS_TICK          )0,                                         
  171.                  (void           * )0,                                       
  172.                  (OS_OPT      )OS_OPT_TASK_STK_CHK|OS_OPT_TASK_STK_CLR|OS_OPT_TASK_SAVE_FP,
  173.                  (OS_ERR         * )&err);                                       
  174.         //创建MSGDIS任务
  175.         OSTaskCreate((OS_TCB         * )&Msgdis_TaskTCB,               
  176.                                  (CPU_CHAR        * )"Msgdis task",                
  177.                  (OS_TASK_PTR )msgdis_task,                        
  178.                  (void                * )0,                                       
  179.                  (OS_PRIO          )MSGDIS_TASK_PRIO,     
  180.                  (CPU_STK   * )&MSGDIS_TASK_STK[0],       
  181.                  (CPU_STK_SIZE)MSGDIS_STK_SIZE/10,       
  182.                  (CPU_STK_SIZE)MSGDIS_STK_SIZE,               
  183.                  (OS_MSG_QTY  )TASK_Q_NUM,                //任务Msgdis_task需要使用内建消息队列,消息队列长度为4                                       
  184.                  (OS_TICK          )0,                                         
  185.                  (void           * )0,                                       
  186.                  (OS_OPT      )OS_OPT_TASK_STK_CHK|OS_OPT_TASK_STK_CLR|OS_OPT_TASK_SAVE_FP,
  187.                  (OS_ERR         * )&err);       
  188.         OS_CRITICAL_EXIT();        //退出临界区
  189.         OSTaskDel((OS_TCB*)0,&err);        //删除start_task任务自身
  190. }

  191. //定时器1的回调函数
  192. void tmr1_callback(void *p_tmr,void *p_arg)
  193. {
  194.         u8 *pbuf;
  195.         static u8 msg_num;
  196.         OS_ERR err;
  197.         pbuf = mymalloc(SRAMIN,10);        //申请10个字节
  198.         if(pbuf)        //申请内存成功
  199.         {
  200.                 msg_num++;
  201.                 sprintf((char*)pbuf,"ALIENTEK %d",msg_num);
  202.                 //发送消息
  203.                 OSTaskQPost((OS_TCB*        )&Msgdis_TaskTCB,        //向任务Msgdis发送消息
  204.                     (void*                )pbuf,
  205.                     (OS_MSG_SIZE)10,
  206.                     (OS_OPT                )OS_OPT_POST_FIFO,
  207.                                         (OS_ERR*        )&err);
  208.                 if(err != OS_ERR_NONE)
  209.                 {
  210.                         myfree(SRAMIN,pbuf);        //释放内存
  211.                         OSTmrStop(&tmr1,OS_OPT_TMR_NONE,0,&err); //停止定时器1
  212.                         tmr1sta = !tmr1sta;
  213.                         LCD_ShowString(40,150,100,16,16,"TMR1 STOP! ");
  214.                 }
  215.         }       
  216. }

  217. //主任务的任务函数
  218. void main_task(void *p_arg)
  219. {
  220.         u8 key,num;
  221.         OS_ERR err;
  222.         u8 *p;
  223.         while(1)
  224.         {
  225.                 key = KEY_Scan(0);  //扫描按键
  226.                 if(key==WKUP_PRES)
  227.                 {
  228.                         tmr1sta = !tmr1sta;
  229.                         if(tmr1sta)
  230.                         {
  231.                                 OSTmrStart(&tmr1,&err);
  232.                                 LCD_ShowString(40,150,100,16,16,"TMR1 START!");
  233.                         }
  234.                         else
  235.                         {
  236.                                 OSTmrStop(&tmr1,OS_OPT_TMR_NONE,0,&err); //停止定时器1
  237.                                 LCD_ShowString(40,150,100,16,16,"TMR1 STOP! ");
  238.                         }
  239.                 }
  240.                 num++;
  241.                 if(num%10==0) check_msg_queue(p);//检查DATA_Msg消息队列的容量
  242.                 if(num==50)
  243.                 {
  244.                         num=0;
  245.                         LED0=!LED0;
  246.                 }
  247.                 OSTimeDlyHMSM(0,0,0,10,OS_OPT_TIME_PERIODIC,&err);   //延时10ms
  248.         }
  249. }

  250. //显示消息队列中的消息
  251. void msgdis_task(void *p_arg)
  252. {
  253.         u8 *p;
  254.         OS_MSG_SIZE size;
  255.         OS_ERR err;
  256.         while(1)
  257.         {
  258.                 //请求消息
  259.                 p=OSTaskQPend((OS_TICK                )0,
  260.                       (OS_OPT                )OS_OPT_PEND_BLOCKING,
  261.                       (OS_MSG_SIZE*        )&size,
  262.                       (CPU_TS*                )0,
  263.                       (OS_ERR*      )&err );
  264.                 LCD_ShowString(40,270,100,16,16,p);
  265.                 myfree(SRAMIN,p);        //释放内存
  266.                 OSTimeDlyHMSM(0,0,1,0,OS_OPT_TIME_PERIODIC,&err); //延时1s
  267.         }
  268. }
复制代码

所有资料51hei提供下载:
UCOS扩展例程- UCOSIII任务内建消息队列.rar (1.29 MB, 下载次数: 31)

评分

参与人数 1黑币 +50 收起 理由
admin + 50 共享资料的黑币奖励!

查看全部评分

回复

使用道具 举报

ID:419800 发表于 2018-11-6 15:28 | 显示全部楼层
谢谢共享源码!刚好我的任务消息队列不知道怎么的只能传一次就报硬件错误了。
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表