stm32f4 UCOSIII任務內建消息隊列的源碼

ID:82098 · 發(fā)表于 2018-5-29 22:16

UCOS擴展例程- UCOSIII任務內建消息隊列

單片機源程序如下:

#include "sys.h"
#include "delay.h"
#include "usart.h"
#include "led.h"
#include "lcd.h"
#include "key.h"
#include "pcf8574.h"
#include "ltdc.h"
#include "sdram.h"
#include "malloc.h"
#include "includes.h"
//任務優(yōu)先級
#define START_TASK_PRIO 3
//任務堆棧大小
#define START_STK_SIZE 128
//任務控制塊
OS_TCB StartTaskTCB;
//任務堆棧
CPU_STK START_TASK_STK[START_STK_SIZE];
//任務函數(shù)
void start_task(void *p_arg);
//任務優(yōu)先級
#define MAIN_TASK_PRIO 4
//任務堆棧大小
#define MAIN_STK_SIZE 128
//任務控制塊
OS_TCB Main_TaskTCB;
//任務堆棧
CPU_STK MAIN_TASK_STK[MAIN_STK_SIZE];
void main_task(void *p_arg);
//任務優(yōu)先級
#define MSGDIS_TASK_PRIO 6
//任務堆棧
#define MSGDIS_STK_SIZE 128
//任務控制塊
OS_TCB Msgdis_TaskTCB;
//任務堆棧
CPU_STK MSGDIS_TASK_STK[MSGDIS_STK_SIZE];
//任務函數(shù)
void msgdis_task(void *p_arg);
//LCD刷屏時使用的顏色
int lcd_discolor[14]={ WHITE, BLACK, BLUE, BRED,
GRED, GBLUE, RED, MAGENTA,
GREEN, CYAN, YELLOW,BROWN,
BRRED, GRAY };
#define TASK_Q_NUM 4 //發(fā)任務內建消息隊列的長度
////////////////////////定時器////////////////////////////////
u8 tmr1sta=0; //標記定時器的工作狀態(tài)
OS_TMR tmr1; //定義一個定時器
void tmr1_callback(void *p_tmr,void *p_arg); //定時器1回調函數(shù)
//加載主界面
void ucos_load_main_ui(void)
{
POINT_COLOR = RED;
LCD_ShowString(10,10,200,16,16,"Apollo STM32F4/F7");
LCD_ShowString(10,30,200,16,16,"UCOSIII Examp 11-2");
LCD_ShowString(10,50,200,16,16,"Task Queue");
LCD_ShowString(10,70,220,16,16,"KEY_UP:Tmr1");
LCD_ShowString(10,90,200,16,16,"2016/1/21");
POINT_COLOR = BLACK;
LCD_DrawLine(0,107,239,107); //畫線
POINT_COLOR = RED;
LCD_ShowString(30,130,100,16,16,"tmr1 state:");
LCD_ShowString(30,170,120,16,16,"Task_QMsg Size:");
LCD_ShowString(30,210,120,16,16,"Task_QMsg rema:");
LCD_ShowString(30,250,100,16,16,"Task_QMsg:");
POINT_COLOR = BLUE;
LCD_ShowString(40,150,100,16,16,"TMR1 STOP! ");
}
//查詢DATA_Msg消息隊列中的總隊列數(shù)量和剩余隊列數(shù)量
void check_msg_queue(u8 *p)
{
CPU_SR_ALLOC();
u8 msgq_remain_size; //消息隊列剩余大小
OS_CRITICAL_ENTER(); //進入臨界段
msgq_remain_size =Msgdis_TaskTCB.MsgQ.NbrEntriesSize-Msgdis_TaskTCB.MsgQ.NbrEntries;
p = mymalloc(SRAMIN,20); //申請內存
sprintf((char*)p,"Total Size:%d",Msgdis_TaskTCB.MsgQ.NbrEntriesSize); //顯示DATA_Msg消息隊列總的大小
LCD_ShowString(40,190,100,16,16,p);
sprintf((char*)p,"Remain Size:%d",msgq_remain_size); //顯示DATA_Msg剩余大小
LCD_ShowString(40,230,100,16,16,p);
myfree(SRAMIN,p); //釋放內存
OS_CRITICAL_EXIT(); //退出臨界段
}
int main(void)
{
OS_ERR err;
CPU_SR_ALLOC();
Stm32_Clock_Init(360,25,2,8); //設置時鐘,180Mhz
HAL_Init(); //初始化HAL庫
delay_init(180); //初始化延時函數(shù)
uart_init(115200); //初始化USART
LED_Init(); //初始化LED
KEY_Init(); //初始化按鍵
PCF8574_Init(); //初始化PCF8974
SDRAM_Init(); //初始化SDRAM
LCD_Init(); //初始化LCD
my_mem_init(SRAMIN); //初始化內部內存池
ucos_load_main_ui(); //加載主UI
OSInit(&err); //初始化UCOSIII
OS_CRITICAL_ENTER(); //進入臨界區(qū)
//創(chuàng)建開始任務
OSTaskCreate((OS_TCB * )&StartTaskTCB, //任務控制塊
(CPU_CHAR * )"start task", //任務名字
(OS_TASK_PTR )start_task, //任務函數(shù)
(void * )0, //傳遞給任務函數(shù)的參數(shù)
(OS_PRIO )START_TASK_PRIO, //任務優(yōu)先級
(CPU_STK * )&START_TASK_STK[0], //任務堆棧基地址
(CPU_STK_SIZE)START_STK_SIZE/10, //任務堆棧深度限位
(CPU_STK_SIZE)START_STK_SIZE, //任務堆棧大小
(OS_MSG_QTY )0, //任務內部消息隊列能夠接收的最大消息數(shù)目,為0時禁止接收消息
(OS_TICK )0, //當使能時間片輪轉時的時間片長度，為0時為默認長度，
(void * )0, //用戶補充的存儲區(qū)
(OS_OPT )OS_OPT_TASK_STK_CHK|OS_OPT_TASK_STK_CLR|OS_OPT_TASK_SAVE_FP, //任務選項,為了保險起見，所有任務都保存浮點寄存器的值
(OS_ERR * )&err); //存放該函數(shù)錯誤時的返回值
OS_CRITICAL_EXIT(); //退出臨界區(qū)
OSStart(&err); //開啟UCOSIII
while(1)
{
}
}
//開始任務函數(shù)
void start_task(void *p_arg)
{
OS_ERR err;
CPU_SR_ALLOC();
p_arg = p_arg;
CPU_Init();
#if OS_CFG_STAT_TASK_EN > 0u
OSStatTaskCPUUsageInit(&err); //統(tǒng)計任務
#endif
#ifdef CPU_CFG_INT_DIS_MEAS_EN //如果使能了測量中斷關閉時間
CPU_IntDisMeasMaxCurReset();
#endif
#if OS_CFG_SCHED_ROUND_ROBIN_EN //當使用時間片輪轉的時候
//使能時間片輪轉調度功能,設置默認的時間片長度
OSSchedRoundRobinCfg(DEF_ENABLED,1,&err);
#endif
OS_CRITICAL_ENTER(); //進入臨界區(qū)
//創(chuàng)建定時器1
OSTmrCreate((OS_TMR *)&tmr1, //定時器1
(CPU_CHAR *)"tmr1", //定時器名字
(OS_TICK )0, //0ms
(OS_TICK )50, //50*10=500ms
(OS_OPT )OS_OPT_TMR_PERIODIC, //周期模式
(OS_TMR_CALLBACK_PTR)tmr1_callback,//定時器1回調函數(shù)
(void *)0, //參數(shù)為0
(OS_ERR *)&err); //返回的錯誤碼
//創(chuàng)建主任務
OSTaskCreate((OS_TCB * )&Main_TaskTCB,
(CPU_CHAR * )"Main task",
(OS_TASK_PTR )main_task,
(void * )0,
(OS_PRIO )MAIN_TASK_PRIO,
(CPU_STK * )&MAIN_TASK_STK[0],
(CPU_STK_SIZE)MAIN_STK_SIZE/10,
(CPU_STK_SIZE)MAIN_STK_SIZE,
(OS_MSG_QTY )0,
(OS_TICK )0,
(void * )0,
(OS_OPT )OS_OPT_TASK_STK_CHK|OS_OPT_TASK_STK_CLR|OS_OPT_TASK_SAVE_FP,
(OS_ERR * )&err);
//創(chuàng)建MSGDIS任務
OSTaskCreate((OS_TCB * )&Msgdis_TaskTCB,
(CPU_CHAR * )"Msgdis task",
(OS_TASK_PTR )msgdis_task,
(void * )0,
(OS_PRIO )MSGDIS_TASK_PRIO,
(CPU_STK * )&MSGDIS_TASK_STK[0],
(CPU_STK_SIZE)MSGDIS_STK_SIZE/10,
(CPU_STK_SIZE)MSGDIS_STK_SIZE,
(OS_MSG_QTY )TASK_Q_NUM, //任務Msgdis_task需要使用內建消息隊列，消息隊列長度為4
(OS_TICK )0,
(void * )0,
(OS_OPT )OS_OPT_TASK_STK_CHK|OS_OPT_TASK_STK_CLR|OS_OPT_TASK_SAVE_FP,
(OS_ERR * )&err);
OS_CRITICAL_EXIT(); //退出臨界區(qū)
OSTaskDel((OS_TCB*)0,&err); //刪除start_task任務自身
}
//定時器1的回調函數(shù)
void tmr1_callback(void *p_tmr,void *p_arg)
{
u8 *pbuf;
static u8 msg_num;
OS_ERR err;
pbuf = mymalloc(SRAMIN,10); //申請10個字節(jié)
if(pbuf) //申請內存成功
{
msg_num++;
sprintf((char*)pbuf,"ALIENTEK %d",msg_num);
//發(fā)送消息
OSTaskQPost((OS_TCB* )&Msgdis_TaskTCB, //向任務Msgdis發(fā)送消息
(void* )pbuf,
(OS_MSG_SIZE)10,
(OS_OPT )OS_OPT_POST_FIFO,
(OS_ERR* )&err);
if(err != OS_ERR_NONE)
{
myfree(SRAMIN,pbuf); //釋放內存
OSTmrStop(&tmr1,OS_OPT_TMR_NONE,0,&err); //停止定時器1
tmr1sta = !tmr1sta;
LCD_ShowString(40,150,100,16,16,"TMR1 STOP! ");
}
}
}
//主任務的任務函數(shù)
void main_task(void *p_arg)
{
u8 key,num;
OS_ERR err;
u8 *p;
while(1)
{
key = KEY_Scan(0); //掃描按鍵
if(key==WKUP_PRES)
{
tmr1sta = !tmr1sta;
if(tmr1sta)
{
OSTmrStart(&tmr1,&err);
LCD_ShowString(40,150,100,16,16,"TMR1 START!");
}
else
{
OSTmrStop(&tmr1,OS_OPT_TMR_NONE,0,&err); //停止定時器1
LCD_ShowString(40,150,100,16,16,"TMR1 STOP! ");
}
}
num++;
if(num%10==0) check_msg_queue(p);//檢查DATA_Msg消息隊列的容量
if(num==50)
{
num=0;
LED0=!LED0;
}
OSTimeDlyHMSM(0,0,0,10,OS_OPT_TIME_PERIODIC,&err); //延時10ms
}
}
//顯示消息隊列中的消息
void msgdis_task(void *p_arg)
{
u8 *p;
OS_MSG_SIZE size;
OS_ERR err;
while(1)
{
//請求消息
p=OSTaskQPend((OS_TICK )0,
(OS_OPT )OS_OPT_PEND_BLOCKING,
(OS_MSG_SIZE* )&size,
(CPU_TS* )0,
(OS_ERR* )&err );
LCD_ShowString(40,270,100,16,16,p);
myfree(SRAMIN,p); //釋放內存
OSTimeDlyHMSM(0,0,1,0,OS_OPT_TIME_PERIODIC,&err); //延時1s
}
}

復制代碼

所有資料51hei提供下載:

UCOS擴展例程- UCOSIII任務內建消息隊列.rar (1.29 MB, 下載次數(shù): 32)

ID:419800 · 發(fā)表于 2018-11-6 15:28

謝謝共享源碼！剛好我的任務消息隊列不知道怎么的只能傳一次就報硬件錯誤了。

帳號		自動登錄	找回密碼
密碼			立即注冊

久久久久久久999_99精品久久精品一区二区爱城_成人欧美一区二区三区在线播放_国产精品日本一区二区不卡视频_国产午夜视频_欧美精品在线观看免费

stm32f4 UCOSIII任務內建消息隊列的源碼

評分