如何在信息量中实现令牌获取的插队？

比如说在某些特殊情况下，需要让几个特定的线程优先获取令牌（tokens），应该如何实现？

对于OH轻量系统来说，CMSIS-RTOS2的osSemaphoreAcquire()函数是这样实现的：

1. osStatus_t osSemaphoreAcquire(osSemaphoreId_t semaphore_id, uint32_t timeout)
   
2. {
   
3.     UINT32 uwRet;
   
4. 
   
5.     if (semaphore_id == NULL) {
   
6.         return osErrorParameter;
   
7.     }
   
8. 
   
9.     if (OS_INT_ACTIVE && (timeout != LOS_NO_WAIT)) {
   
10.         return osErrorISR;
    
11.     }
    
12. 
    
13.     uwRet = LOS_SemPend(((LosSemCB *)semaphore_id)->semID, timeout);
    
14.     if (uwRet == LOS_OK) {
    
15.         return osOK;
    
16.     } else if (uwRet == LOS_ERRNO_SEM_TIMEOUT) {
    
17.         return osErrorTimeout;
    
18.     } else if (uwRet == LOS_ERRNO_SEM_INVALID) {
    
19.         return osErrorParameter;
    
20.     } else if (uwRet == LOS_ERRNO_SEM_PEND_INTERR) {
    
21.         return osErrorISR;
    
22.     } else {
    
23.         return osErrorResource;
    
24.     }
    
25. }

复制代码

其中的关键函数LOS_SemPend()定义如下：

1. /*****************************************************************************
   
2. Function     : LOS_SemPend
   
3. Description  : Specified semaphore P operation
   
4. Input        : semHandle --------- semaphore operation handle
   
5.               : timeout   --------- waitting time
   
6. Output       : None
   
7. Return       : LOS_OK on success or error code on failure
   
8. *****************************************************************************/
   
9. LITE_OS_SEC_TEXT UINT32 LOS_SemPend(UINT32 semHandle, UINT32 timeout)
   
10. {
    
11.     UINT32 intSave;
    
12.     LosSemCB *semPended = NULL;
    
13.     UINT32 retErr;
    
14.     LosTaskCB *runningTask = NULL;
    
15. 
    
16.     if (semHandle >= (UINT32)LOSCFG_BASE_IPC_SEM_LIMIT) {
    
17.         OS_RETURN_ERROR(LOS_ERRNO_SEM_INVALID);
    
18.     }
    
19. 
    
20.     semPended = GET_SEM(semHandle);
    
21.     intSave = LOS_IntLock();
    
22. 
    
23.     retErr = OsSemValidCheck(semPended);
    
24.     if (retErr) {
    
25.         goto ERROR_SEM_PEND;
    
26.     }
    
27. 
    
28.     if (semPended->semCount > 0) {
    
29.         semPended->semCount--;
    
30.         LOS_IntRestore(intSave);
    
31.         return LOS_OK;
    
32.     }
    
33. 
    
34.     if (!timeout) {
    
35.         retErr = LOS_ERRNO_SEM_UNAVAILABLE;
    
36.         goto ERROR_SEM_PEND;
    
37.     }
    
38. 
    
39.     runningTask = (LosTaskCB *)g_losTask.runTask;
    
40.     runningTask->taskSem = (VOID *)semPended;
    
41.     OsTaskWait(&semPended->semList, OS_TASK_STATUS_PEND, timeout);
    
42.     LOS_IntRestore(intSave);
    
43.     LOS_Schedule();
    
44. 
    
45.     if (runningTask->taskStatus & OS_TASK_STATUS_TIMEOUT) {
    
46.         intSave = LOS_IntLock();
    
47.         runningTask->taskStatus &= (~OS_TASK_STATUS_TIMEOUT);
    
48.         retErr = LOS_ERRNO_SEM_TIMEOUT;
    
49.         goto ERROR_SEM_PEND;
    
50.     }
    
51. 
    
52.     return LOS_OK;
    
53. 
    
54. ERROR_SEM_PEND:
    
55.     LOS_IntRestore(intSave);
    
56.     OS_RETURN_ERROR(retErr);
    
57. }

复制代码

其中调用了OsTaskWait：

1. /**************************************************************************
   
2. Function    : OsTaskWait
   
3. Description : pend the running task in a list
   
4. Input       : pendingList   -- The pending list
   
5.                taskStatus    -- The status need to be converted to
   
6.                timeout       -- Expiry time
   
7. Output      : None
   
8. Return      : None
   
9. **************************************************************************/
   
10. VOID OsTaskWait(LOS_DL_LIST *pendingList, UINT32 taskStatus, UINT32 timeout)
    
11. {
    
12.     LosTaskCB *runTask = NULL;
    
13.     LOS_DL_LIST *pendObj = NULL;
    
14. 
    
15.     runTask = g_losTask.runTask;
    
16.     OsPriqueueDequeue(&runTask->pendList);
    
17.     runTask->taskStatus &= (~OS_TASK_STATUS_READY);
    
18.     pendObj = &runTask->pendList;
    
19.     runTask->taskStatus |= taskStatus;
    
20.     LOS_ListTailInsert(pendingList, pendObj);
    
21.     if (timeout != LOS_WAIT_FOREVER) {
    
22.         runTask->taskStatus |= OS_TASK_STATUS_TIMEOUT;
    
23.         OsTaskAdd2TimerList((LosTaskCB *)runTask, timeout);
    
24.     }
    
25. }

复制代码

可以看到是排到队尾的。线程调度的时候看线程优先级。