前言
在鴻蒙內(nèi)核中,廣義上可理解為一個Task就是一個線程
一、怎么理解Task
1. 官方文檔是怎么描述線程
基本概念
從系統(tǒng)的角度看,線程是競爭系統(tǒng)資源的最小運行單元。線程可以使用或等待CPU、使用內(nèi)存空間等系統(tǒng)資源,并獨立于其它線程運行。
鴻蒙內(nèi)核每個進程內(nèi)的線程獨立運行、獨立調(diào)度,當前進程內(nèi)線程的調(diào)度不受其它進程內(nèi)線程的影響。
鴻蒙內(nèi)核中的線程采用搶占式調(diào)度機制,同時支持時間片輪轉(zhuǎn)調(diào)度和FIFO調(diào)度方式。
鴻蒙內(nèi)核的線程一共有32個優(yōu)先級(0-31),最高優(yōu)先級為0,最低優(yōu)先級為31。
當前進程內(nèi)高優(yōu)先級的線程可搶占當前進程內(nèi)低優(yōu)先級線程,當前進程內(nèi)低優(yōu)先級線程必須在當前進程內(nèi)高優(yōu)先級線程阻塞或結(jié)束后才能得到調(diào)度。
線程狀態(tài)說明:
初始化(Init):該線程正在被創(chuàng)建。
就緒(Ready):該線程在就緒列表中,等待CPU調(diào)度。
運行(Running):該線程正在運行。
阻塞(Blocked):該線程被阻塞掛起。Blocked狀態(tài)包括:pend(因為鎖、事件、信號量等阻塞)、suspend(主動pend)、delay(延時阻塞)、pendtime(因為鎖、事件、信號量時間等超時等待)。
退出(Exit):該線程運行結(jié)束,等待父線程回收其控制塊資源。
圖 1 線程狀態(tài)遷移示意圖

注意官方文檔說的是線程,沒有提到task(任務(wù)),但內(nèi)核源碼中卻有大量 task代碼,很少有線程(thread)代碼 ,這是怎么回事?
其實在鴻蒙內(nèi)核中, task就是線程, 初學(xué)者完全可以這么理解,但二者還是有區(qū)別,否則干嘛要分兩個詞描述。
到底有什么區(qū)別?是管理上的區(qū)別,task是調(diào)度層面的概念,線程是進程層面的概念。 就像同一個人在不同的管理體系中會有不同的身份一樣,一個男人既可以是 孩子,爸爸,丈夫,或者程序員,視角不同功能也會不同。
如何證明是一個東西,繼續(xù)再往下看。
2. 執(zhí)行task命令
鴻蒙 task 命令的執(zhí)行結(jié)果:

task命令 查出每個任務(wù)在生命周期內(nèi)的運行情況,它運行的內(nèi)存空間,優(yōu)先級,時間片,入口執(zhí)行函數(shù),進程ID,狀態(tài)等等信息,非常的復(fù)雜。這么復(fù)雜的信息就需要一個結(jié)構(gòu)體來承載。而這個結(jié)構(gòu)體就是 LosTaskCB(任務(wù)控制塊)
對應(yīng)張大爺?shù)墓适拢簍ask就是一個用戶的節(jié)目清單里的一個節(jié)目,用戶總清單就是一個進程,所以上面會有很多的節(jié)目。
3. task長得什么樣子?
說LosTaskCB之前先說下官方文檔任務(wù)狀態(tài)對應(yīng)的 define,可以看出task和線程是一個東西。
#define OS_TASK_STATUS_INIT 0x0001U #define OS_TASK_STATUS_READY 0x0002U #define OS_TASK_STATUS_RUNNING 0x0004U #define OS_TASK_STATUS_SUSPEND 0x0008U #define OS_TASK_STATUS_PEND 0x0010U #define OS_TASK_STATUS_DELAY 0x0020U #define OS_TASK_STATUS_TIMEOUT 0x0040U #define OS_TASK_STATUS_PEND_TIME 0x0080U #define OS_TASK_STATUS_EXIT 0x0100U
LosTaskCB長什么樣?抱歉,它確實有點長,但還是要全部貼出全貌。
typedef struct {
VOID *stackPointer; /**< Task stack pointer */
UINT16 taskStatus; /**< Task status */
UINT16 priority; /**< Task priority */
UINT16 policy;
UINT16 timeSlice; /**< Remaining time slice */
UINT32 stackSize; /**< Task stack size */
UINTPTR topOfStack; /**< Task stack top */
UINT32 taskID; /**< Task ID */
TSK_ENTRY_FUNC taskEntry; /**< Task entrance function */
VOID *joinRetval; /**< pthread adaption */
VOID *taskSem; /**< Task-held semaphore */
VOID *taskMux; /**< Task-held mutex */
VOID *taskEvent; /**< Task-held event */
UINTPTR args[4]; /**< Parameter, of which the maximum number is 4 */
CHAR taskName[OS_TCB_NAME_LEN]; /**< Task name */
LOS_DL_LIST pendList; /**< Task pend node */
LOS_DL_LIST threadList; /**< thread list */
SortLinkList sortList; /**< Task sortlink node */
UINT32 eventMask; /**< Event mask */
UINT32 eventMode; /**< Event mode */
UINT32 priBitMap; /**< BitMap for recording the change of task priority,
the priority can not be greater than 31 */
INT32 errorNo; /**< Error Num */
UINT32 signal; /**< Task signal */
sig_cb sig;
#if (LOSCFG_KERNEL_SMP == YES)
UINT16 currCpu; /**< CPU core number of this task is running on */
UINT16 lastCpu; /**< CPU core number of this task is running on last time */
UINT16 cpuAffiMask; /**< CPU affinity mask, support up to 16 cores */
UINT32 timerCpu; /**< CPU core number of this task is delayed or pended */
#if (LOSCFG_KERNEL_SMP_TASK_SYNC == YES)
UINT32 syncSignal; /**< Synchronization for signal handling */
#endif
#if (LOSCFG_KERNEL_SMP_LOCKDEP == YES)
LockDep lockDep;
#endif
#if (LOSCFG_KERNEL_SCHED_STATISTICS == YES)
SchedStat schedStat; /**< Schedule statistics */
#endif
#endif
UINTPTR userArea;
UINTPTR userMapBase;
UINT32 userMapSize; /**< user thread stack size ,real size : userMapSize + USER_STACK_MIN_SIZE */
UINT32 processID; /**< Which belong process */
FutexNode futex;
LOS_DL_LIST joinList; /**< join list */
LOS_DL_LIST lockList; /**< Hold the lock list */
UINT32 waitID; /**< Wait for the PID or GID of the child process */
UINT16 waitFlag; /**< The type of child process that is waiting, belonging to a group or parent,
a specific child process, or any child process */
#if (LOSCFG_KERNEL_LITEIPC == YES)
UINT32 ipcStatus;
LOS_DL_LIST msgListHead;
BOOL accessMap[LOSCFG_BASE_CORE_TSK_LIMIT];
#endif
} LosTaskCB;
結(jié)構(gòu)體LosTaskCB內(nèi)容很多,各代表什么含義?
LosTaskCB相當于任務(wù)在內(nèi)核中的身份證,它反映出每個任務(wù)在生命周期內(nèi)的運行情況。既然是周期就會有狀態(tài),要運行就需要內(nèi)存空間,就需要被內(nèi)核算法調(diào)度,被選中CPU就去執(zhí)行代碼段指令,CPU要執(zhí)行就需要告訴它從哪里開始執(zhí)行,因為是多線程,但只有一個CPU就需要不斷的切換任務(wù),那執(zhí)行會被中斷,也需要再恢復(fù)后繼續(xù)執(zhí)行,又如何保證恢復(fù)的任務(wù)執(zhí)行不會出錯,這些問題都需要說明白。
二、Task怎么管理
1.什么是任務(wù)池?
前面已經(jīng)說了任務(wù)是內(nèi)核調(diào)度層面的概念,調(diào)度算法保證了task有序的執(zhí)行,調(diào)度機制詳見其他姊妹篇的介紹。
如此多的任務(wù)怎么管理和執(zhí)行?管理靠任務(wù)池和就緒隊列,執(zhí)行靠調(diào)度算法。
代碼如下(OsTaskInit):
LITE_OS_SEC_TEXT_INIT UINT32 OsTaskInit(VOID) { UINT32 index; UINT32 ret; UINT32 size; g_taskMaxNum = LOSCFG_BASE_CORE_TSK_LIMIT;//任務(wù)池中最多默認128個,可謂鐵打的任務(wù)池流水的線程 size = (g_taskMaxNum + 1) * sizeof(LosTaskCB); /* * This memory is resident memory and is used to save the system resources * of task control block and will not be freed. */ g_taskCBArray = (LosTaskCB *)LOS_MemAlloc(m_aucSysMem0, size);//任務(wù)池 常駐內(nèi)存,不被釋放 if (g_taskCBArray == NULL) { return LOS_ERRNO_TSK_NO_MEMORY; } (VOID)memset_s(g_taskCBArray, size, 0, size); LOS_ListInit(&g_losFreeTask);//空閑任務(wù)鏈表 LOS_ListInit(&g_taskRecyleList);//需回收任務(wù)鏈表 for (index = 0; index < g_taskMaxNum; index++) { g_taskCBArray[index].taskStatus = OS_TASK_STATUS_UNUSED; g_taskCBArray[index].taskID = index;//任務(wù)ID最大默認127 LOS_ListTailInsert(&g_losFreeTask, &g_taskCBArray[index].pendList);//都插入空閑任務(wù)鏈表 } ret = OsPriQueueInit();//創(chuàng)建32個任務(wù)優(yōu)先級隊列,即32個雙向循環(huán)鏈表 if (ret != LOS_OK) { return LOS_ERRNO_TSK_NO_MEMORY; } /* init sortlink for each core */ for (index = 0; index < LOSCFG_KERNEL_CORE_NUM; index++) { ret = OsSortLinkInit(&g_percpu[index].taskSortLink);//每個CPU內(nèi)核都有一個執(zhí)行任務(wù)鏈表 if (ret != LOS_OK) { return LOS_ERRNO_TSK_NO_MEMORY; } } return LOS_OK; }
g_taskCBArray 就是個任務(wù)池,默認創(chuàng)建128個任務(wù),常駐內(nèi)存,不被釋放。
g_losFreeTask是空閑任務(wù)鏈表,想創(chuàng)建任務(wù)時來這里申請一個空閑任務(wù),用完了就回收掉,繼續(xù)給后面的申請使用。
g_taskRecyleList是回收任務(wù)鏈表,專用來回收exit 任務(wù),任務(wù)所占資源被確認歸還后被徹底刪除,就像員工離職一樣,得有個離職隊列和流程,要歸還電腦,郵箱,有沒有借錢要還的 等操作。
對應(yīng)張大爺?shù)墓适拢河脩粢獊韴鲳^領(lǐng)取表格填節(jié)目單,場館只準備了128張表格,領(lǐng)完就沒有了,但是節(jié)目表演完了會回收表格,這樣多了一張表格就可以給其他人領(lǐng)取了,這128張表格對應(yīng)鴻蒙內(nèi)核這就是任務(wù)池,簡單吧。
2.就緒隊列是怎么回事
CPU執(zhí)行速度是很快的,鴻蒙內(nèi)核默認一個時間片是 10ms, 資源有限,需要在眾多任務(wù)中來回的切換,所以絕不能讓CPU等待任務(wù),CPU就像公司最大的領(lǐng)導(dǎo),下面很多的部門等領(lǐng)導(dǎo)來審批,吃飯。只有大家等領(lǐng)導(dǎo),哪有領(lǐng)導(dǎo)等你們的道理,所以工作要提前準備好,每個部門的優(yōu)先級又不一樣,所以每個部門都要有個任務(wù)隊列,里面放的是領(lǐng)導(dǎo)能直接處理的任務(wù),沒準備好的不要放進來,因為這是給CPU提前準備好的糧食!
這就是就緒隊列的原理,一共有32個就緒隊列,進程和線程都有,因為線程的優(yōu)先級是默認32個, 每個隊列中放同等優(yōu)先級的task.
還是看源碼吧
#define OS_PRIORITY_QUEUE_NUM 32
UINT32 OsPriQueueInit(VOID)
{
UINT32 priority;
/* system resident resource */
g_priQueueList = (LOS_DL_LIST *)LOS_MemAlloc(m_aucSysMem0, (OS_PRIORITY_QUEUE_NUM * sizeof(LOS_DL_LIST)));//常駐內(nèi)存,不被釋放
if (g_priQueueList == NULL) {
return LOS_NOK;
}
for (priority = 0; priority < OS_PRIORITY_QUEUE_NUM; ++priority) {
LOS_ListInit(&g_priQueueList[priority]);
}
return LOS_OK;
}
注意看g_priQueueList 的內(nèi)存分配,就是32個LOS_DL_LIST,還記得LOS_DL_LIST的妙用嗎,不清楚的去鴻蒙源碼分析(總目錄)里面翻。
對應(yīng)張大爺?shù)墓适拢壕褪情T口那些排隊的都是至少有一個節(jié)目單是符合表演標準的,資源都到位了,沒有的連排隊的資格都木有,就慢慢等吧。
3.任務(wù)棧是怎么回事
每個任務(wù)都是獨立開的,任務(wù)之間也相互獨立,之間通訊通過IPC,這里的“獨立”指的是每個任務(wù)都有自己的運行環(huán)境 —— ??臻g,稱為任務(wù)棧,棧空間里保存的信息包含局部變量、寄存器、函數(shù)參數(shù)、函數(shù)返回地址等等
但系統(tǒng)中只有一個CPU,任務(wù)又是獨立的,調(diào)度的本質(zhì)就是CPU執(zhí)行一個新task,老task在什么地方被中斷誰也不清楚,是隨機的。那如何保證老任務(wù)被再次調(diào)度選中時還能從上次被中斷的地方繼續(xù)玩下去呢?
答案是:任務(wù)上下文,CPU內(nèi)有一堆的寄存器,CPU運行本質(zhì)的就是這些寄存器的值不斷的變化,只要切換時把這些值保存起來,再還原回去就能保證task的連續(xù)執(zhí)行,讓用戶毫無感知。鴻蒙內(nèi)核給一個任務(wù)執(zhí)行的時間是 20ms ,也就是說有多任務(wù)競爭的情況下,一秒鐘內(nèi)最多要來回切換50次。
對應(yīng)張大爺?shù)墓适拢壕褪桥龅焦?jié)目沒有表演完就必須打斷的情況下,需要把當時的情況記錄下來,比如小朋友在演躲貓貓的游戲,一半不演了,張三正在樹上,李四正在廁所躲,都記錄下來,下次再回來你們上次在哪就會哪呆著去,就位了繼續(xù)表演。這樣就接上了,觀眾就木有感覺了。
任務(wù)上下文(TaskContext)是怎樣的呢?還是直接看源碼
/* The size of this structure must be smaller than or equal to the size specified by OS_TSK_STACK_ALIGN (16 bytes). */
typedef struct {
#if !defined(LOSCFG_ARCH_FPU_DISABLE)
UINT64 D[FP_REGS_NUM]; /* D0-D31 */
UINT32 regFPSCR; /* FPSCR */
UINT32 regFPEXC; /* FPEXC */
#endif
UINT32 resved; /* It's stack 8 aligned */
UINT32 regPSR;
UINT32 R[GEN_REGS_NUM]; /* R0-R12 */
UINT32 SP; /* R13 */
UINT32 LR; /* R14 */
UINT32 PC; /* R15 */
} TaskContext;
發(fā)現(xiàn)基本都是CPU寄存器的恢復(fù)現(xiàn)場值, 具體各寄存器有什么作用大家可以去網(wǎng)上詳查,后續(xù)也有專門的文章來介紹。這里說其中的三個寄存器 SP, LR, PC
LR
用途有二,一是保存子程序返回地址,當調(diào)用BL、BX、BLX等跳轉(zhuǎn)指令時會自動保存返回地址到LR;二是保存異常發(fā)生的異常返回地址。
PC(Program Counter)
為程序計數(shù)器,用于保存程序的執(zhí)行地址,在ARM的三級流水線架構(gòu)中,程序流水線包括取址、譯碼和執(zhí)行三個階段,PC指向的是當前取址的程序地址,所以32位ARM中,譯碼地址(正在解析還未執(zhí)行的程序)為PC-4,執(zhí)行地址(當前正在執(zhí)行的程序地址)為PC-8, 當突然發(fā)生中斷的時候,保存的是PC的地址。
SP
每一種異常模式都有其自己獨立的r13,它通常指向異常模式所專用的堆棧,當ARM進入異常模式的時候,程序就可以把一般通用寄存器壓入堆棧,返回時再出棧,保證了各種模式下程序的狀態(tài)的完整性。
4.任務(wù)棧初始化
任務(wù)棧的初始化就是任務(wù)上下文的初始化,因為任務(wù)沒開始執(zhí)行,里面除了上下文不會有其他內(nèi)容,注意上下文存放的位置在棧的底部。
三、Task函數(shù)集
LITE_OS_SEC_TEXT_INIT VOID *OsTaskStackInit(UINT32 taskID, UINT32 stackSize, VOID *topStack, BOOL initFlag) { UINT32 index = 1; TaskContext *taskContext = NULL; if (initFlag == TRUE) { OsStackInit(topStack, stackSize); } taskContext = (TaskContext *)(((UINTPTR)topStack + stackSize) - sizeof(TaskContext));//注意看上下文將存放在棧的底部 /* initialize the task context */ #ifdef LOSCFG_GDB taskContext->PC = (UINTPTR)OsTaskEntrySetupLoopFrame; #else taskContext->PC = (UINTPTR)OsTaskEntry;//程序計數(shù)器,CPU首次執(zhí)行task時跑的第一條指令位置 #endif taskContext->LR = (UINTPTR)OsTaskExit; /* LR should be kept, to distinguish it's THUMB or ARM instruction */ taskContext->resved = 0x0; taskContext->R[0] = taskID; /* R0 */ taskContext->R[index++] = 0x01010101; /* R1, 0x01010101 : reg initialed magic word */ for (; index < GEN_REGS_NUM; index++) { //R2 - R12的初始化很有意思,為什么要這么做? taskContext->R[index] = taskContext->R[index - 1] + taskContext->R[1]; /* R2 - R12 */ } #ifdef LOSCFG_INTERWORK_THUMB // 16位模式 taskContext->regPSR = PSR_MODE_SVC_THUMB; /* CPSR (Enable IRQ and FIQ interrupts, THUMNB-mode) */ #else taskContext->regPSR = PSR_MODE_SVC_ARM; /* CPSR (Enable IRQ and FIQ interrupts, ARM-mode) */ #endif #if !defined(LOSCFG_ARCH_FPU_DISABLE) /* 0xAAA0000000000000LL : float reg initialed magic word */ for (index = 0; index < FP_REGS_NUM; index++) { taskContext->D[index] = 0xAAA0000000000000LL + index; /* D0 - D31 */ } taskContext->regFPSCR = 0; taskContext->regFPEXC = FP_EN; #endif return (VOID *)taskContext; }
1.使用場景和功能
任務(wù)創(chuàng)建后,內(nèi)核可以執(zhí)行鎖任務(wù)調(diào)度,解鎖任務(wù)調(diào)度,掛起,恢復(fù),延時等操作,同時也可以設(shè)置任務(wù)優(yōu)先級,獲取任務(wù)優(yōu)先級。任務(wù)結(jié)束的時候,則進行當前任務(wù)自刪除操作。
Huawei LiteOS 系統(tǒng)中的任務(wù)管理模塊為用戶提供下面幾種功能。
| 功能分類 | 接口名 | 描述 |
|---|---|---|
| 任務(wù)的創(chuàng)建和刪除 | LOS_TaskCreateOnly | 創(chuàng)建任務(wù),并使該任務(wù)進入suspend狀態(tài),并不調(diào)度。 |
| LOS_TaskCreate | 創(chuàng)建任務(wù),并使該任務(wù)進入ready狀態(tài),并調(diào)度。 | |
| LOS_TaskDelete | 刪除指定的任務(wù)。 | |
| 任務(wù)狀態(tài)控制 | LOS_TaskResume | 恢復(fù)掛起的任務(wù)。 |
| LOS_TaskSuspend | 掛起指定的任務(wù)。 | |
| LOS_TaskDelay | 任務(wù)延時等待。 | |
| LOS_TaskYield | 顯式放權(quán),調(diào)整指定優(yōu)先級的任務(wù)調(diào)度順序。 | |
| 任務(wù)調(diào)度的控制 | LOS_TaskLock | 鎖任務(wù)調(diào)度。 |
| LOS_TaskUnlock | 解鎖任務(wù)調(diào)度。 | |
| 任務(wù)優(yōu)先級的控制 | LOS_CurTaskPriSet | 設(shè)置當前任務(wù)的優(yōu)先級。 |
| LOS_TaskPriSet | 設(shè)置指定任務(wù)的優(yōu)先級。 | |
| LOS_TaskPriGet | 獲取指定任務(wù)的優(yōu)先級。 | |
| 任務(wù)信息獲取 | LOS_CurTaskIDGet | 獲取當前任務(wù)的ID。 |
| LOS_TaskInfoGet | 設(shè)置指定任務(wù)的優(yōu)先級。 | |
| LOS_TaskPriGet | 獲取指定任務(wù)的信息。 | |
| LOS_TaskStatusGet | 獲取指定任務(wù)的狀態(tài)。 | |
| LOS_TaskNameGet | 獲取指定任務(wù)的名稱。 | |
| LOS_TaskInfoMonitor | 監(jiān)控所有任務(wù),獲取所有任務(wù)的信息。 | |
| LOS_NextTaskIDGet | 獲取即將被調(diào)度的任務(wù)的ID。 |
2.創(chuàng)建任務(wù)的過程
創(chuàng)建任務(wù)之前先了解另一個結(jié)構(gòu)體 tagTskInitParam
typedef struct tagTskInitParam {
TSK_ENTRY_FUNC pfnTaskEntry; /**< Task entrance function */
UINT16 usTaskPrio; /**< Task priority */
UINT16 policy; /**< Task policy */
UINTPTR auwArgs[4]; /**< Task parameters, of which the maximum number is four */
UINT32 uwStackSize; /**< Task stack size */
CHAR *pcName; /**< Task name */
#if (LOSCFG_KERNEL_SMP == YES)
UINT16 usCpuAffiMask; /**< Task cpu affinity mask */
#endif
UINT32 uwResved; /**< It is automatically deleted if set to LOS_TASK_STATUS_DETACHED. It is unable to be deleted if set to 0. */
UINT16 consoleID; /**< The console id of task belongs */
UINT32 processID;
UserTaskParam userParam;
} TSK_INIT_PARAM_S;
這些初始化參數(shù)是外露的任務(wù)初始參數(shù),pfnTaskEntry對java來說就是你new進程的run(),需要上層使用者提供.
看個例子吧:shell中敲 ping 命令看下它創(chuàng)建的過程
u32_t osShellPing(int argc, const char **argv)
{
int ret;
u32_t i = 0;
u32_t count = 0;
int count_set = 0;
u32_t interval = 1000; /* default ping interval */
u32_t data_len = 48; /* default data length */
ip4_addr_t dst_ipaddr;
TSK_INIT_PARAM_S stPingTask;
// ...省去一些中間代碼
/* start one task if ping forever or ping count greater than 60 */
if (count == 0 || count > LWIP_SHELL_CMD_PING_RETRY_TIMES) {
if (ping_taskid > 0) {
PRINTK("Ping task already running and only support one now
");
return LOS_NOK;
}
stPingTask.pfnTaskEntry = (TSK_ENTRY_FUNC)ping_cmd;//線程的執(zhí)行函數(shù)
stPingTask.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE;//0x4000 = 16K
stPingTask.pcName = "ping_task";
stPingTask.usTaskPrio = 8; /* higher than shell 優(yōu)先級高于10,屬于內(nèi)核態(tài)線程*/
stPingTask.uwResved = LOS_TASK_STATUS_DETACHED;
stPingTask.auwArgs[0] = dst_ipaddr.addr; /* network order */
stPingTask.auwArgs[1] = count;
stPingTask.auwArgs[2] = interval;
stPingTask.auwArgs[3] = data_len;
ret = LOS_TaskCreate((UINT32 *)(&ping_taskid), &stPingTask);
}
// ...
return LOS_OK;
ping_error:
lwip_ping_usage();
return LOS_NOK;
}
發(fā)現(xiàn)ping的調(diào)度優(yōu)先級是8,比shell 還高,那shell的是多少?答案是:看源碼是 9
LITE_OS_SEC_TEXT_MINOR UINT32 ShellTaskInit(ShellCB *shellCB)
{
CHAR *name = NULL;
TSK_INIT_PARAM_S initParam = {
0};
if (shellCB->consoleID == CONSOLE_SERIAL) {
name = SERIAL_SHELL_TASK_NAME;
} else if (shellCB->consoleID == CONSOLE_TELNET) {
name = TELNET_SHELL_TASK_NAME;
} else {
return LOS_NOK;
}
initParam.pfnTaskEntry = (TSK_ENTRY_FUNC)ShellTask;
initParam.usTaskPrio = 9; /* 9:shell task priority */
initParam.auwArgs[0] = (UINTPTR)shellCB;
initParam.uwStackSize = 0x3000;
initParam.pcName = name;
initParam.uwResved = LOS_TASK_STATUS_DETACHED;
(VOID)LOS_EventInit(&shellCB->shellEvent);
return LOS_TaskCreate(&shellCB->shellTaskHandle, &initParam);
}
關(guān)于shell后續(xù)會詳細介紹,請持續(xù)關(guān)注。
前置條件了解清楚后,具體看任務(wù)是如何一步步創(chuàng)建的,如何和進程綁定,加入調(diào)度就緒隊列,還是繼續(xù)看源碼
LITE_OS_SEC_TEXT_INIT UINT32 LOS_TaskCreate(UINT32 *taskID, TSK_INIT_PARAM_S *initParam)
{
UINT32 ret;
UINT32 intSave;
LosTaskCB *taskCB = NULL;
if (initParam == NULL) {
return LOS_ERRNO_TSK_PTR_NULL;
}
if (OS_INT_ACTIVE) {
return LOS_ERRNO_TSK_YIELD_IN_INT;
}
if (initParam->uwResved & OS_TASK_FLAG_IDLEFLAG) {
initParam->processID = OsGetIdleProcessID();
} else if (OsProcessIsUserMode(OsCurrProcessGet())) {
initParam->processID = OsGetKernelInitProcessID();
} else {
initParam->processID = OsCurrProcessGet()->processID;
}
initParam->uwResved &= ~OS_TASK_FLAG_IDLEFLAG;
initParam->uwResved &= ~OS_TASK_FLAG_PTHREAD_JOIN;
if (initParam->uwResved & LOS_TASK_STATUS_DETACHED) {
initParam->uwResved = OS_TASK_FLAG_DETACHED;
}
ret = LOS_TaskCreateOnly(taskID, initParam);
if (ret != LOS_OK) {
return ret;
}
taskCB = OS_TCB_FROM_TID(*taskID);
SCHEDULER_LOCK(intSave);
taskCB->taskStatus &= ~OS_TASK_STATUS_INIT;
OS_TASK_SCHED_QUEUE_ENQUEUE(taskCB, 0);
SCHEDULER_UNLOCK(intSave);
/* in case created task not running on this core,
schedule or not depends on other schedulers status. */
LOS_MpSchedule(OS_MP_CPU_ALL);
if (OS_SCHEDULER_ACTIVE) {
LOS_Schedule();//*kyf 任務(wù)創(chuàng)建完了 申請調(diào)度
}
return LOS_OK;
}
對應(yīng)張大爺?shù)墓适拢壕褪枪?jié)目單要怎么填,按格式來,從哪里開始演,要多大的空間,王場館好協(xié)調(diào)好現(xiàn)場的環(huán)境。這里注意在同一個節(jié)目單只要節(jié)目沒演完,王場館申請場地的空間就不能給別人用,這個場地空間對應(yīng)的就是鴻蒙任務(wù)的??臻g,除非整個節(jié)目單都完了,就回收了。把整個場地干干凈凈的留給下一個人的節(jié)目單來表演。
至此的創(chuàng)建已經(jīng)完成,已各就各位,源碼最后還申請了一次LOS_Schedule();因為鴻蒙的調(diào)度方式是搶占式的,如何本次task的任務(wù)優(yōu)先級高于其他就緒隊列,那么接下來要執(zhí)行的任務(wù)就是它了!
編輯:hfy
-
內(nèi)核
+關(guān)注
關(guān)注
4文章
1476瀏覽量
43098 -
線程
+關(guān)注
關(guān)注
0文章
510瀏覽量
20873 -
鴻蒙系統(tǒng)
+關(guān)注
關(guān)注
183文章
2642瀏覽量
70141
發(fā)布評論請先 登錄
Linux內(nèi)核驅(qū)動開發(fā)的技術(shù)核心精要
代碼照亮未來:蘭州大學(xué)開源鴻蒙技術(shù)俱樂部的六種青春答卷
開源鴻蒙城市技術(shù)沙龍上海站圓滿落幕
Linux多線程對比單線程的優(yōu)勢
開源鴻蒙技術(shù)大會2025丨虛擬化與容器分論壇:構(gòu)筑開源鴻蒙虛擬化技術(shù)高地
開源鴻蒙技術(shù)大會2025丨OS內(nèi)核與視窗分論壇:筑基開源鴻蒙核心內(nèi)核,共拓視窗技術(shù)邊界
Task任務(wù):LuatOS實現(xiàn)“任務(wù)級并發(fā)”的核心引擎
揭秘LuatOS Task:多任務(wù)管理的“智能中樞”
開源系統(tǒng)適配:聚徽分享國產(chǎn)工控平板在 Linux / 鴻蒙系統(tǒng)下的技術(shù)優(yōu)化
鴻蒙5開發(fā)寶藏案例分享---跨線程性能優(yōu)化指南
鴻蒙5開發(fā)寶藏案例分享---分析幀率問題
鴻蒙5開發(fā)寶藏案例分享---性能優(yōu)化案例解析
鴻蒙5開發(fā)寶藏案例分享---應(yīng)用并發(fā)設(shè)計
鴻蒙5開發(fā)寶藏案例分享---應(yīng)用架構(gòu)實戰(zhàn)技巧
鴻蒙操作系統(tǒng)首登電腦端,華為開啟鴻蒙辦公新時代
鴻蒙內(nèi)核源碼Task/線程技術(shù)分析
評論