采用Protothread實現實時多任務系統
在許多系統資源非常緊張的單片機應用中,使用實時操作系統進行任務調度來實現實時多任務系統時,由操作系統帶來的系統開銷往往是不可接受的。通過升級硬件來改善系統資源緊張,意味著成本的增加,降低產品的競爭力。本文介紹采用Protothread在非常小的系統開銷下實現實時多任務系統的方法。
關鍵詞? Protothread? 實時? 多任務? 線程模型
嵌入式程序框架一般類似于程序1所示結構:系統中有3個任務——TaskA、TaskB、TaskC,均放置于主循環內,在每一個循環周期內都被執行一次。在這種結構中,能滿足系統實時性要求的條件是: (當且僅當)TaskA 、TaskB、TaskC三個任務的運行時間之和要小于系統實時響應的時間要求。在系統較為簡單、任務運行時間能滿足實時要求的情況下,可以采用這種最簡單、最直接的順序執行方式。但是更多的情形是,系統不僅要對一些事件做出實時響應,并且還要承擔很多其他的非實時任務,并且這些非實時任務的運行時間要遠遠超出了實時響應時間的要求。傳統的這種程序結構顯然不能滿足系統的實時性要求。通常的解決方案是,引入實時操作系統,由操作系統進行任務的調度,優先執行實時任務,達到滿足系統實時性的要求。
程序1嵌入式程序框架
void main(void) {
Init();
while(1) {
TaskA();
TaskB();
TaskC();
}
}
void Interrupt_1(void) interrupt 1 {
…
}
void Interrupt_2(void) interrupt 2 {
…
}
一般來說,在嵌入式系統開發中引入實時操作系統有諸多優點:
◆ 更好地支持多任務,實時性要求能夠得以保障;
◆ 程序開發更加容易,也更便于維護;
◆ 有利于提高系統的穩定性和可靠性。但是,操作系統的引入也將帶來較多的系統開銷:
◆ 實時操作系統往往使用定時器中斷來切換任務,需要消耗不少的CPU處理時間;
◆ 實時操作系統在切換任務時需要保護當前任務的執行現場,這就需要為每個任務準備足夠多的RAM空間來實現任務切換;
◆ 實時操作系統的本身也需要占用相當數量的Flash空間和RAM空間。
如果這些系統開銷都在可承受的范圍內,那么采用實時操作系統將是最佳的選擇。但是在很多應用的場合,特別是系統的資源非常緊張的單片機應用,實時操作系統帶來的系統開銷往往是不可接受的。而更換速度更快、RAM更大、Flash更多的CPU意味著成本的增加,且會降低產品的競爭力。當系統中的任務不須進行非常復雜的優先級調度,而且其任務也相對簡單時,引入實時操作系統似有殺雞用牛刀之嫌。
1? Protothread的特點
Protothread是專為資源有限的系統設計的一種耗費資源特別少并且不使用堆棧的線程模型,其特點是:
◆ 以純C語言實現,無硬件依賴性;
◆ 極少的資源需求,每個Protothread僅需要2個額外的字節;
◆ 可以用于有操作系統或無操作系統的場合;
◆ 支持阻塞操作且沒有棧的切換。
使用Protothread實現多任務的最主要的好處在于它的輕量級。每個Protothread不需要擁有自已的堆棧,所有的Protothread共享同一個堆棧空間,這一點對于RAM資源有限的系統尤為有利。相對于操作系統下的多任務而言,每個任務都有自已的堆棧空間,這將消耗大量的RAM資源,而每個Protothread僅使用一個整型值保存當前狀態。
2? Protothread的阻塞運行機制
以下是一個典型的Protothread程序示例:
程序2Protothread程序示例
PT_THREAD(radio_wake_thread(struct pt *pt)) {
PT_BEGIN(pt);
while(1) {
radio_on();
timer_set(&timer, T_AWAKE);
PT_WAIT_UNTIL(pt, timer_expired(&timer));
timer_set(&timer, T_SLEEP);
if(!communication_complete()) {
PT_WAIT_UNTIL(pt, communication_complete()‖timer_expired(&timer));
}
if(!timer_expired(&timer)) {
radio_off();
PT_WAIT_UNTIL(pt, timer_expired(&timer));
}
}
PT_END(pt);
}
這是一個非常簡單的無線通信的狀態切換程序①,展開Protothread的宏定義,便可以得到程序3所示的展開代碼:
程序3Protothread宏展開代碼
void radio_wake_thread(struct pt *pt) {
switch(pt﹥lc) {
case 0:
while(1) {
radio_on();
timer_set(&timer, T_AWAKE);
pt﹥lc = 8;
case 8:
if(!timer_expired(&timer)) {
return;
}
timer_set(&timer, T_SLEEP);
if(!communication_complete()) {
pt﹥lc = 13;
case 13:
if(!(communication_complete() ||timer_expired(&timer))) {
return;
}
}
if(!timer_expired(&timer)) {
radio_off();
pt﹥lc = 18;
case 18:
if(!timer_expired(&timer)) {
return;
}
}
}
}
}
當Protothread程序運行到PT_WAIT_UNTIL時,判斷其運行條件是否滿足,若不滿足,則阻塞。通過比對程序2和程序3的程序代碼可以得知,Protothread的阻塞其實質就是函數返回,只不過在返回前保存了當前的阻塞位置,待下一次Protothread被調用時,直接跳到阻塞位置執行,再次判斷運行條件是否滿足,并執行后續程序或繼續阻塞。
3? 利用Protothread構造實時多任務系統
與操作系統下的多任務不同,操作系統下的每個任務可在任意時刻被打斷并阻塞,Protothread僅能在程序員指定位置阻塞。用Protothread實現實時多任務,正是利用了Protothread在指定位置阻塞的特點,讓出執行權限給更高優先級的任務先運行。
下面舉例說明如何利用Protothread構造實時多任務系統。
系統要求:
TaskA實時任務,30 ms內響應,運行時間<20 ms;
TaskB實時任務,200 ms內響應,運行時間<40 ms;
TaskC非實時任務,響應時間無要求,運行時間>30 ms。
設計思路:
將TaskB和TaskC分成若干步,每步運行時間不超過10 ms(這個時間可視系統需求而定,例如TaskA若為40 ms內響應,則每步可擴至20 ms)。任務以3個Protothread的方式運行。首先執行TaskA,在TaskA執行完成1次后,釋放執行權限,讓TaskB和TaskC執行。TaskB或TaskC在每執行1步之前檢查運行時間,一旦發現30 ms內不夠執行1步時,阻塞運行,讓出執行權限給TaskA。同樣,TaskB和TaskC的調度關系也類似,先運行TaskB,完成時釋放執行權限,讓TaskC執行;TaskC在每執行1步之前檢查運行時間,若發現200 ms內不夠執行1步時,阻塞運行,讓出執行權限重新交給TaskB。
源程序(Task0TimeCounter、Task1TimeCounter為計數器,每毫秒加1):
#include "ptsem.h"
#define TASKA_MAX_RUN_TIME20
#define TASKA_CYCLE_TIME30
#define TASKB_CYCLE_TIME200
#define TASK_STEP_TIME10
#define TASK0_VALID_TIME TASKA_CYCLE_TIME?TASK_STEP_TIME
#define TASK1_VALID_TIME TASKB_CYCLE_TIME?TASK_STEP_TIME?TASKA_MAX_RUN_TIME *2
/*按照PT_WAIT_UNTIL 的宏定義擴展一個新宏:當程序進入阻塞時發送一信號,告知高優先級任務獲得執行權限*/
#define LC_STEP_SET(s,n) s = __LINE__ + n; case __LINE__ + n:
#define PT_SEM_WAIT_UNTIL(pt, s, condition, n)\\
do {
LC_STEP_SET((pt)﹥lc,n);
if(!(condition)) {if((s)﹥count==0)
PT_SEM_SIGNAL(pt,s);
return PT_WAITING;
}
} while(0)
struct pt TaskAPt;
struct pt TaskBPt;
struct pt TaskCPt;
struct pt_sem SemRunTaskA;
struct pt_sem SemRunTaskB;
/*若30 ms內已經不夠時間執行1步,則讓出TaskA的執行權限*/
#define TASKB_STEP(pt)?\\
PR_SEM_WAIT_UNTIL(pt, & SemRunTaskA,TaskOTimeCounter<=TASKO_VALID_TIME,0)
/*若200 ms內已經不夠時間執行1步,則讓出TaskB的執行權限*/
/*若30 ms內已經不夠時間執行1步,則讓出TaskA的執行權限*/
#define TASKC_STEP(pt) \\
PT_SEM_WAIT_UNTIL(pt,?&SemRunTaskB,Task1TimeCounter<=TASK1_VALID_TIME,0);\\
PT_SEM_WAIT_UNTIL(pt,?&SemRunTaskA,Task0TimeCounter<=TASK0_VALID_TIME,1)
int ProtothreadTaskA(struct pt *pt) {
PT_BEGIN(pt);
PT_SEM_WAIT(pt, &SemRunTaskA);/*等待其他任務讓出執行權限*/
ResetTask0TimeCounter;/*對時間計數器置0*/
TaskA();/*TaskA任務*/
PT_END(pt);
}
int ProtothreadTaskB(struct pt *pt) {
PT_BEGIN(pt);
PT_SEM_WAIT(pt, &SemRunTaskB);/*等待TaskC讓出執行權限*/
ResetTask1TimeCounter;/*對時間計數器置0*/
TASKB_STEP(pt);/*如果不夠1步執行,則阻塞,讓出執行權限*/
TaskB_1();/*TaskB任務的第1步*/
TASKB_STEP(pt);
TaskB_2();/*TaskB任務的第2步*/
TASKB_STEP(pt);
TaskB_3();/*…*/
PT_END(pt);
}
int ProtothreadTaskC(struct pt *pt) {
PT_BEGIN(pt);
TASKC_STEP(pt);/*如果不夠1步執行,則阻塞,讓出執行權限*/
TaskC_1();/*TaskB任務的第1步*/
TASKC_STEP(pt);
TaskC_2();/*TaskB任務的第2步*/
TASKC_STEP(pt);
TaskC_3();/*…*/
TASKC_STEP(pt);
TaskC_4();
PT_END(pt);
}
void main(void) {/*系統初始化*/?
PT_INIT(&TaskAPt);
PT_INIT(&TaskBPt);
PT_INIT(&TaskCPt);
PT_SEM_INIT(&SemRunTaskA,1);
PT_SEM_INIT(&SemRunTaskB,1);/*運行任務*/
while(1) {
ProtothreadTaskA(&TaskAPt);
ProtothreadTaskB(&TaskBPt);
ProtothreadTaskC(&TaskCPt);
}
}
模擬運行結果如表1所列。運行結果顯示,3個任務的運行情況完全滿足系統的設計要求。從資源需求來看,完成此例的系統設計,共需要12個字節的RAM空間。筆者進一步對Protothread定義文件做了少許修改和優化,最終僅耗費6個字節。
結語
本文旨在解決資源緊張型應用的、多任務環境下的實時性問題。 通過借助Protothread的阻塞運行機制, 成功實現了低開銷的實時多任務系統。
評論
查看更多