读了鸿蒙 OS 的代码后,我发现优秀项目都有这个共性!
作者 | 馬超
責編 | 胡巍巍
出品 | 程序人生(ID:coder_life)
兩個項目對于任務調度模塊的實現對比1.鴻蒙OS的調度模塊與一般操作系統一樣,鴻蒙也將任務狀態通常分為以下三種:
就緒(Ready):該任務在就緒列表中,只等待CPU。
運行(Running):該任務正在執行。
阻塞(Blocked):該任務不在就緒列表中。包含任務被掛起、任務被延時、任務正在等待信號量、讀寫隊列或者等待讀寫事件等。
{
????UINTPTR?uvIntSave;
????LOS_TASK_CB?*pstTaskCB;
????UINT16?usTempStatus;
????UINT32?uwErrRet?=?OS_ERROR;
????if?(uwTaskID?>?LOSCFG_BASE_CORE_TSK_LIMIT)
????{
????????return?LOS_ERRNO_TSK_ID_INVALID;
????}
????pstTaskCB?=?OS_TCB_FROM_TID(uwTaskID);
????uvIntSave?=?LOS_IntLock();
????usTempStatus?=?pstTaskCB->usTaskStatus;
????if?(OS_TASK_STATUS_UNUSED?&?usTempStatus)
????{
????????uwErrRet?=?LOS_ERRNO_TSK_NOT_CREATED;
????????OS_GOTO_ERREND();
????}
????else?if?(!(OS_TASK_STATUS_SUSPEND?&?usTempStatus))
????{
????????uwErrRet?=?LOS_ERRNO_TSK_NOT_SUSPENDED;
????????OS_GOTO_ERREND();
????}
????//以上為任務狀態檢查
????pstTaskCB->usTaskStatus?&=?(~OS_TASK_STATUS_SUSPEND);//清除任務的suspend標志位置
????if?(!(OS_CHECK_TASK_BLOCK?&?pstTaskCB->usTaskStatus)?)//若任務的還自在阻塞狀態則變為就緒狀態?,并調用?LOS_Schedule()進行調度
????{
????????pstTaskCB->usTaskStatus?|=?OS_TASK_STATUS_READY;
????????LOS_PriqueueEnqueue(&pstTaskCB->stPendList,?pstTaskCB->usPriority);
????????if?(g_bTaskScheduled)
????????{
????????????(VOID)LOS_IntRestore(uvIntSave);
????????????LOS_Schedule();
????????????return?LOS_OK;
????????}
????????g_stLosTask.pstNewTask?=?LOS_DL_LIST_ENTRY(LOS_PriqueueTop(),?LOS_TASK_CB,?stPendList);?/*lint?!e413*/
????}
????(VOID)LOS_IntRestore(uvIntSave);
????return?LOS_OK;
LOS_ERREND:
????(VOID)LOS_IntRestore(uvIntSave);
????return?uwErrRet;
}
我們看到這個函數的處理過程基本分為三步:
任務合法性(TaskId)及任務狀態校驗:判斷任務序號以及任務當前狀態是否確實為掛起。
改變任務狀態:將任務的suspend狀態位清掉
起用任務調度:如果任務被阻塞,則調起LOS_Schedule進行調度。
初始化任務隊列
加入任務
循環處理任務
銷毀任務隊列
??SSchedMsg????msg;
??SSchedQueue?*pSched?=?(SSchedQueue?*)param;
??while?(1)?{
????if?(sem_wait(&pSched->fullSem)?!=?0)?{
??????pError("wait?%s?fullSem?failed,?errno:%d,?reason:%s",?pSched->label,?errno,?strerror(errno));
??????if?(errno?==?EINTR)?{
????????/*?sem_wait?is?interrupted?by?interrupt,?ignore?and?continue?*/
????????continue;
??????}
????}
????if?(pthread_mutex_lock(&pSched->queueMutex)?!=?0)
??????pError("lock?%s?queueMutex?failed,?reason:%s",?pSched->label,?strerror(errno));
????msg?=?pSched->queue[pSched->fullSlot];
????memset(pSched->queue?+?pSched->fullSlot,?0,?sizeof(SSchedMsg));
????pSched->fullSlot?=?(pSched->fullSlot?+?1)?%?pSched->queueSize;//從隊尾取出消息不斷處理
????if?(pthread_mutex_unlock(&pSched->queueMutex)?!=?0)
??????pError("unlock?%s?queueMutex?failed,?reason:%s\n",?pSched->label,?strerror(errno));
????if?(sem_post(&pSched->emptySem)?!=?0)
??????pError("post?%s?emptySem?failed,?reason:%s\n",?pSched->label,?strerror(errno));
????if?(msg.fp)
??????(*(msg.fp))(&msg);
????else?if?(msg.tfp)
??????(*(msg.tfp))(msg.ahandle,?msg.thandle);
??}
}
int?taosScheduleTask(void?*qhandle,?SSchedMsg?*pMsg)?{
??SSchedQueue?*pSched?=?(SSchedQueue?*)qhandle;
??if?(pSched?==?NULL)?{
????pError("sched?is?not?ready,?msg:%p?is?dropped",?pMsg);
????return?0;
??}
??if?(sem_wait(&pSched->emptySem)?!=?0)?pError("wait?%s?emptySem?failed,?reason:%s",?pSched->label,?strerror(errno));
??if?(pthread_mutex_lock(&pSched->queueMutex)?!=?0)
????pError("lock?%s?queueMutex?failed,?reason:%s",?pSched->label,?strerror(errno));
??pSched->queue[pSched->emptySlot]?=?*pMsg;
??pSched->emptySlot?=?(pSched->emptySlot?+?1)?%?pSched->queueSize;
??if?(pthread_mutex_unlock(&pSched->queueMutex)?!=?0)
????pError("unlock?%s?queueMutex?failed,?reason:%s",?pSched->label,?strerror(errno));
??if?(sem_post(&pSched->fullSem)?!=?0)?pError("post?%s?fullSem?failed,?reason:%s",?pSched->label,?strerror(errno));
??return?0;
}
軟件定時器是系統資源,在模塊初始化的時候已經分配了一塊連續的內存,系統支持的最大定時器個數可以在los_config.h文件中配置。
軟件定時器使用了系統的一個隊列和任務資源,軟件定時器的觸發遵循隊列規則,先進先出。
定時時間短的定時器總是比定時時間長的靠近隊列頭,滿足優先被觸發的準則。
軟件定時器以Tick為基本計時單位,當用戶創建并啟動一個軟件定時器時,Huawei LiteOS會根據當前系統Tick時間及用戶設置的定時間隔確定該定時器的到期Tick時間,并將該定時器控制結構掛入計時全局鏈表。
當Tick中斷到來時,在Tick中斷處理函數中掃描軟件定時器的計時全局鏈表,看是否有定時器超時,若有則將超時的定時器記錄下來。
Tick處理結束后,軟件定時器任務(優先級為最高)被喚醒,在該任務中調用之前記錄下來的超時定時器的處理函數。
首先明確鴻蒙的定時器是為了節省硬件定時器資源而設計的。
由于硬件定時器往往數量有限而系統實際運行中,對于定時器的需求往往高于硬件定時器的數量,所以操作系統都會實現軟件定時器以滿足用戶需求。
先啟動硬件定時器,注冊硬件定時器的tick事件,也就是硬件定時器到時發生tick時會調用軟件定時器的處理函數。
將在同一時刻到期的timer放在同一鏈表中。
在硬件產生tick事件時,取出當時到期的定時器列表,并順序調起鏈表內所有到時定時器的處理函數。
{
????SWTMR_HANDLER_ITEM_P?pstSwtmrHandle?=?(SWTMR_HANDLER_ITEM_P)NULL;
????SWTMR_HANDLER_ITEM_S?stSwtmrHandle;
????UINT32?uwRet;
????for?(?;?;?)
????{
????????uwRet?=?LOS_QueueRead(m_uwSwTmrHandlerQueue,?&pstSwtmrHandle,?sizeof(SWTMR_HANDLER_ITEM_P),?LOS_WAIT_FOREVER);
????????if?(uwRet?==?LOS_OK)
????????{
????????????if?(pstSwtmrHandle?!=?NULL)
????????????{
????????????????stSwtmrHandle.pfnHandler?=?pstSwtmrHandle->pfnHandler;
????????????????stSwtmrHandle.uwArg?=?pstSwtmrHandle->uwArg;
????????????????(VOID)LOS_MemboxFree(m_aucSwTmrHandlerPool,?pstSwtmrHandle);
????????????????if?(stSwtmrHandle.pfnHandler?!=?NULL)
????????????????{
????????????????????stSwtmrHandle.pfnHandler(stSwtmrHandle.uwArg);
????????????????}
????????????}
????????}
????}//end?of?for
}
以上函數的運行原理動畫解析如下:
結語從上面這兩個簡單的模塊中我們也看到這些優秀的項目都使用最精簡的設計,緊貼需求、甩掉包袱、輕裝上陣才能回歸本質取得成功。無論是TdEngine取消任務調度的優先級排序,還是鴻蒙放棄對定時器精度的支持,都是看來出乎意料,實則頗具內涵的減法操作。真正優秀的項目都是敢于做減法的,只有減掉那些看似高大上的設計,才能向著有取有舍,大道至簡的境界邁進。原文:https://blog.csdn.net/BEYONDMA/article/details/100049796?utm_source=app
在 GitHub 更新中,歡迎關注,歡迎star。
直面Java第262期:volatile是如何解決有序性問題的?
深入并發第009期:到底什么是Java內存模型?
- MORE | 更多精彩文章 -
如果你喜歡本文,
請長按二維碼,關注?Hollis.
轉發至朋友圈,是對我最大的支持。
好文章,我在看??
總結
以上是生活随笔為你收集整理的读了鸿蒙 OS 的代码后,我发现优秀项目都有这个共性!的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: SpringBoot 2.x Shard
- 下一篇: CodeForces 321A Ciel