當前位置:首頁 > 單片機 > 單片機
[導讀] /*==============================================================1ms時標 混合式調度器(一個搶占式任務,多個合作式任務)作者:shadow.hu======================================================

/*==============================================================
1ms時標 混合式調度器(一個搶占式任務,多個合作式任務)
作者:shadow.hu
===============================================================*/
#include
#define uchar unsigned char
#define ushort unsigned short
#define SCH_MAX_TASKS 9
#define ERROR_SCH_TOO_MANY_TASKS 9
#define ERROR_SCH_CANOT_DELETE_TASK 0
#define RETURN_ERROR 0
#define RETURN_NORMAL 1

#define INTERRPT_Timer_2_Overflow 5

#define SCH_REPORT_ERRORS
#ifdef SCH_REPORT_ERRORS
#define Error_Port P1
#endif

typedef data struct
{
void (code *pTask)(void);
ushort Delay;
ushort Period;
ushort RunMe;
uchar Co_op;//如果任務是合作式的,設置為1,如果任務是搶占式的,設置為0
}sTask;
sTask SCH_tasks_G[SCH_MAX_TASKS];

void SCH_Init_T2(void);
uchar SCH_Add_Task(void (code * pFunction)(),const ushort Delay, ushort PERIOD);
// 函數名指針 延時的時標數 執(zhí)行任務的時間間隔
// 為0則立即執(zhí)行 如果為0,表示單次任務
void SCH_Dispatch_Tasks(void);
void SCH_Start(void);
bit SCH_Delete_Task(const ushort TASK_INDEX);
void SCH_Go_To_Sleep(void);
void SCH_Report_Status(void);//報告系統(tǒng)狀況
voidLED_Flash_Init(void);
void LED_Flash_Update_A(void);
void LED_Flash_Update_B(void);
void LED_Flash_Update_C(void);
void LED_Flash_Update_D(void);
void LED_Flash_Update_E(void);
void LED_Flash_Update_F(void);
void LED_Flash_Update_G(void);
void LED_Flash_Update_H(void);

uchar Error_code_G = 0;//
statICushort Error_tick_count_G;//記住自從上一次紀錄錯誤以來的時間
static uchar Last_error_code_G;//上次的錯誤代碼(在1分鐘之后復位)

uchar LED_State_G_A = 0;
uchar LED_State_G_B = 0;
uchar LED_State_G_C = 0;
uchar LED_State_G_D = 0;
uchar LED_State_G_E = 0;
uchar LED_State_G_F = 0;
uchar LED_State_G_G = 0;
uchar LED_State_G_H = 0;

sbit LED_PIN_A = P1^0;
sbit LED_pin_B = P1^1;
sbit LED_pin_C = P1^2;
sbit LED_pin_D = P1^3;
sbit LED_pin_E = P1^4;
sbit LED_pin_F = P1^5;
sbit LED_pin_G = P1^6;
sbit LED_pin_H = P1^7;

//Error_code_G = ERROR_SCH_TOO_MANY_TASKS;
//Error_code_G = ERROR_SCH_WAITING_FOR_SLAVE_TO_ACK;
//Error_code_G = ERROR_SCH_WAITING_FOR_START_COMAND_FROM_MASTER;
//Error_code_G = ERROR_SCH_ONE_OR_MORE_SLAVES_DID_NOT_START;
//Error_code_G = ERROR_SCH_LOST_SLAVE;
//Error_code_G = ERROR_SCH_CAN_BUS_ERROR;
//Error_code_G = ERROR_I2C_WRITE_BYTE_AT24C64;

void main(void)
{
SCH_Init_T2();
LED_Flash_Init();
SCH_Add_Task(LED_Flash_Update_A,0,1000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_B,0,2000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_C,0,3000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_D,0,4000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_E,0,5000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_F,0,6000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_G,0,7000);//添加一個任務
SCH_Add_Task(LED_Flash_Update_H,0,8000);//添加一個任務

SCH_Start();//開全局中斷
while(1)
{
SCH_Dispatch_Tasks();
}
}
/*------------------------------------------------------------
這是調度器的中斷服務程序,初始化函數中的定時器設置決定了它
的調度頻率,這個版本的調度器由定時器2觸發(fā)中斷,定時器自動重裝。
-------------------------------------------------------------*/
void SCH_Update(void) interrupt INTERRPT_Timer_2_Overflow
{
//刷新任務隊列
uchar Index;
TF2 = 0;//必須手工清除
//注意:計算單位為時標(不是毫秒)
for(Index = 0;Index < SCH_MAX_TASKS;Index++)
{ //檢測這里是否有任務
if(SCH_tasks_G[Index].pTask)
{
if(SCH_tasks_G[Index].Delay == 0)
{
//任務需要運行,間隔的時間已經到了
if(SCH_tasks_G[Index].Co_op)
{
//如果是合作式任務,RunMe標志加1
SCH_tasks_G[Index].RunMe += 1;//要執(zhí)行任務的標志加1
}
else//如果它是搶占式任務,立即運行它
{
(*SCH_tasks_G[Index].pTask)();//運行任務
SCH_tasks_G[Index].RunMe -= 1;
//周期性的任務將自動再次運行,單次任務就刪除
if(SCH_tasks_G[Index].Period == 0)
{
SCH_tasks_G[Index].pTask = 0;
}
}
if(SCH_tasks_G[Index].Period)//時標間隔不等于0
{
//調度周期性的任務再次運行,每隔這個固定的時標長度執(zhí)行一次任務
SCH_tasks_G[Index].Delay = SCH_tasks_G[Index].Period;
}
}
else //任務有延遲執(zhí)行要求,還沒到達延遲的時間
{
//還沒有準備好運行,延遲減1
SCH_tasks_G[Index].Delay -= 1;
}
}
}
}

void SCH_Init_T2(void)
{
uchar i;
for(i=0;i{
SCH_Delete_Task(i);
}
Error_code_G = 0;
T2CON = 0x04;
TMOD = 0x00;
TH2 = 0xfc;
RCAP2H = 0xfc;
TL2 = 0x18;
RCAP2L = 0x18;
ET2 = 1;
TR2 = 1;
}
/*----------------------------------------------------------------------------
任務函數每隔一定時間間隔或在用戶定義的延遲之后運行
pFunction -- 將被調用的函數名稱。注意:被調函數必須是“void void”型
DELAY -- 在任務第一次被執(zhí)行之前的間隔
PERIOD -- 如果它為0,則只調用該函數一次,由DELAY確定其調用的時間
如果非0,那么它就是被重復調用的時間間隔
Co_op -- 如果是合作式任務則設置為1,如果是搶占式任務則設置為0.

注意:如果以后要刪除任務,將需要返回值
例子:
Task_ID = SCH_Add_Task(Do_X,1000,0,0);
使函數Do_X()在1000個調度器時標之后運行一次(搶占式任務)
Task_ID = SCH_Add_Task(Do_X,0,1000,1);
使函數Do_X()每隔1000個調度器時標運行一次(合作式任務)
Task_ID = SCH_Add_Task(Do_X,300,1000,0);
使函數Do_X()每隔1000個調度器時標運行一次,任務首先在T=300個時標時被執(zhí)行
然后是1300個時標.........(搶占式任務)

-----------------------------------------------------------------------------*/

uchar SCH_Add_Task(void (code * pFunction)(),const ushort DELAY, ushort PERIOD,bit Co_op)
{
uchar Index = 0;
//首先在隊列中找到一個空隙(如果有的話,否則就不添加新任務)
while((SCH_tasks_G[Index].pTask != 0)&&(Index < SCH_MAX_TASKS))
{
Index++;//當一個新任務被添加,且沒有超過任務上限
}
//是否達到任務隊列的結尾?
if(Index == SCH_MAX_TASKS)//任務數量達到上限
{
Error_code_G = ERROR_SCH_TOO_MANY_TASKS;
return SCH_MAX_TASKS;//直接返回,不添加這個新任務
}
//如果能運行到這里,說明任務隊列中有空隙,添加任務。
SCH_tasks_G[Index].pTask = pFunction;
SCH_tasks_G[Index].Delay = DELAY;
SCH_tasks_G[Index].Period = PERIOD;
SCH_tasks_G[Index].Co_op = Co_op;
SCH_tasks_G[Index].RunMe = 0;
return Index;//返回任務的位置(以便以后刪除)
}


void SCH_Dispatch_Tasks(void)
{
uchar Index;
//調度(運行)下一個任務(如果有任務就緒)
for(Index = 0;Index < SCH_MAX_TASKS;Index++)
{
//只調度合作式任務
if((SCH_tasks_G[Index].RunMe > 0)&&(SCH_tasks_G[Index].Co_op))
{
(*SCH_tasks_G[Index].pTask)();//執(zhí)行任務
SCH_tasks_G[Index].RunMe -= 1;//清除任務需要執(zhí)行的標志
}
//如果這是個“單次”任務,將它從隊列中刪除
if(SCH_tasks_G[Index].Period == 0)
{
SCH_tasks_G[Index].pTask = 0;// 比通過調用來刪除任務更快SCH_Delete_Task(Index);
}
}
SCH_Report_Status();//報告系統(tǒng)狀況
SCH_Go_To_Sleep();
}

void SCH_Start(void)
{
EA = 1;
}

bit SCH_Delete_Task(const ushort TASK_INDEX)
{
bit Return_code;
if(SCH_tasks_G[TASK_INDEX].pTask == 0)
{
//這里沒有任務。。。設置全局錯誤變量
Error_code_G = ERROR_SCH_CANOT_DELETE_TASK;
Return_code = RETURN_ERROR;//返回錯誤代碼
}
else
{
Return_code = RETURN_NORMAL;
}
//刪除任務
SCH_tasks_G[TASK_INDEX].pTask = 0x0000;
SCH_tasks_G[TASK_INDEX].Delay = 0;
SCH_tasks_G[TASK_INDEX].Period = 0;
SCH_tasks_G[TASK_INDEX].RunMe = 0;
return Return_code;
}

void SCH_Go_To_Sleep()
{
PCON |= 0x01;//進入休眠模式
}

void SCH_Report_Status(void)
{
/* #ifdef SCH_REPORT_ERRORS
if(Error_code_G != Last_error_code_G)
{
Error_Port = 255 - Error_code_G;
Last_error_code_G = Error_code_G;
if(Error_code_G != 0)
{
Error_tICk_count_G = 60000;
}
else
{
Error_tick_count_G = 0;
}
}
else
{
if(Error_tick_count_G != 0)
{
if(--Error_count_G == 0)
{
Error_code_G = 0;
}
}
}
#endif */
}

void

本站聲明: 本文章由作者或相關機構授權發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點,本站亦不保證或承諾內容真實性等。需要轉載請聯(lián)系該專欄作者,如若文章內容侵犯您的權益,請及時聯(lián)系本站刪除。
換一批
延伸閱讀

9月2日消息,不造車的華為或將催生出更大的獨角獸公司,隨著阿維塔和賽力斯的入局,華為引望愈發(fā)顯得引人矚目。

關鍵字: 阿維塔 塞力斯 華為

加利福尼亞州圣克拉拉縣2024年8月30日 /美通社/ -- 數字化轉型技術解決方案公司Trianz今天宣布,該公司與Amazon Web Services (AWS)簽訂了...

關鍵字: AWS AN BSP 數字化

倫敦2024年8月29日 /美通社/ -- 英國汽車技術公司SODA.Auto推出其旗艦產品SODA V,這是全球首款涵蓋汽車工程師從創(chuàng)意到認證的所有需求的工具,可用于創(chuàng)建軟件定義汽車。 SODA V工具的開發(fā)耗時1.5...

關鍵字: 汽車 人工智能 智能驅動 BSP

北京2024年8月28日 /美通社/ -- 越來越多用戶希望企業(yè)業(yè)務能7×24不間斷運行,同時企業(yè)卻面臨越來越多業(yè)務中斷的風險,如企業(yè)系統(tǒng)復雜性的增加,頻繁的功能更新和發(fā)布等。如何確保業(yè)務連續(xù)性,提升韌性,成...

關鍵字: 亞馬遜 解密 控制平面 BSP

8月30日消息,據媒體報道,騰訊和網易近期正在縮減他們對日本游戲市場的投資。

關鍵字: 騰訊 編碼器 CPU

8月28日消息,今天上午,2024中國國際大數據產業(yè)博覽會開幕式在貴陽舉行,華為董事、質量流程IT總裁陶景文發(fā)表了演講。

關鍵字: 華為 12nm EDA 半導體

8月28日消息,在2024中國國際大數據產業(yè)博覽會上,華為常務董事、華為云CEO張平安發(fā)表演講稱,數字世界的話語權最終是由生態(tài)的繁榮決定的。

關鍵字: 華為 12nm 手機 衛(wèi)星通信

要點: 有效應對環(huán)境變化,經營業(yè)績穩(wěn)中有升 落實提質增效舉措,毛利潤率延續(xù)升勢 戰(zhàn)略布局成效顯著,戰(zhàn)新業(yè)務引領增長 以科技創(chuàng)新為引領,提升企業(yè)核心競爭力 堅持高質量發(fā)展策略,塑強核心競爭優(yōu)勢...

關鍵字: 通信 BSP 電信運營商 數字經濟

北京2024年8月27日 /美通社/ -- 8月21日,由中央廣播電視總臺與中國電影電視技術學會聯(lián)合牽頭組建的NVI技術創(chuàng)新聯(lián)盟在BIRTV2024超高清全產業(yè)鏈發(fā)展研討會上宣布正式成立。 活動現場 NVI技術創(chuàng)新聯(lián)...

關鍵字: VI 傳輸協(xié)議 音頻 BSP

北京2024年8月27日 /美通社/ -- 在8月23日舉辦的2024年長三角生態(tài)綠色一體化發(fā)展示范區(qū)聯(lián)合招商會上,軟通動力信息技術(集團)股份有限公司(以下簡稱"軟通動力")與長三角投資(上海)有限...

關鍵字: BSP 信息技術
關閉
關閉