typedef struct QueueDefinition
{
    int8_t *pcHead;             /* 指向隊列存儲區(qū)起始位置,即第一個隊列項 */
    int8_t *pcTail;             /* 指向隊列存儲區(qū)結(jié)束后的下一個字節(jié) */
    int8_t *pcWriteTo;          /* 指向下隊列存儲區(qū)的下一個空閑位置 */
    union                       /* 使用聯(lián)合體用來確保兩個互斥的結(jié)構(gòu)體成員不會同時出現(xiàn) */
    {
        int8_t *pcReadFrom;     /* 當(dāng)結(jié)構(gòu)體用于隊列時,這個字段指向出隊項目中的最后一個. */
        UBaseType_t uxRecursiveCallCount;/* 當(dāng)結(jié)構(gòu)體用于互斥量時,用作計數(shù)器,保存遞歸互斥量被"獲取"的次數(shù). */
    } u;
    List_t xTasksWaitingToSend;      /* 因為等待入隊而阻塞的任務(wù)列表,按照優(yōu)先級順序存儲 */
    List_t xTasksWaitingToReceive;   /* 因為等待隊列項而阻塞的任務(wù)列表,按照優(yōu)先級順序存儲 */
    volatile UBaseType_t uxMessagesWaiting;/*< 當(dāng)前隊列的隊列項數(shù)目 */
    UBaseType_t uxLength;            /* 隊列項的數(shù)目 */
    UBaseType_t uxItemSize;          /* 每個隊列項的大小 */
    volatile BaseType_t xRxLock;   /* 隊列上鎖后,存儲從隊列收到的列表項數(shù)目，如果隊列沒有上鎖，設(shè)置為queueUNLOCKED */
    volatile BaseType_t xTxLock;   /* 隊列上鎖后,存儲發(fā)送到隊列的列表項數(shù)目，如果隊列沒有上鎖，設(shè)置為queueUNLOCKED */
    #if ( configUSE_QUEUE_SETS == 1 )
        struct QueueDefinition *pxQueueSetContainer;
    #endif
     #if ( configUSE_TRACE_FACILITY == 1 )
        UBaseType_t uxQueueNumber;
        uint8_t ucQueueType;
    #endif
    #if ( configSUPPORT_STATIC_ALLOCATION == 1 )
        uint8_t ucStaticAllocationFlags;
    #endif
} xQUEUE;
 typedef xQUEUE Queue_t;

QueueHandle_t xQueueGenericCreate
        ( 
                const UBaseType_t uxQueueLength, 
                const UBaseType_t uxItemSize, 
                uint8_t *pucQueueStorage, 
                StaticQueue_t *pxStaticQueue, 
                const uint8_t ucQueueType 
        )

QueueHandle_t xQueueGenericCreate( 
              const UBaseType_t uxQueueLength, 
              const UBaseType_t uxItemSize, 
             uint8_t *pucQueueStorage, 
             StaticQueue_t *pxStaticQueue, 
             const uint8_t ucQueueType )
{
Queue_t *pxNewQueue;
    /* 如果使能可視化跟蹤調(diào)試,這里用來消除編譯器警告. */
    ( void ) ucQueueType;
    /*分配隊列結(jié)構(gòu)體和隊列項存儲空間.可以靜態(tài)也可以動態(tài)分配,取決于參數(shù)值,FreeRTOS默認(rèn)采取動態(tài)分配 */
    pxNewQueue = prvAllocateQueueMemory( uxQueueLength, uxItemSize, &pucQueueStorage, pxStaticQueue );
    if( pxNewQueue != NULL )
    {
        if( uxItemSize == ( UBaseType_t ) 0 )
        {
            /* 沒有為隊列項存儲分配內(nèi)存,但是pcHead指針不能設(shè)置為NULL,因為隊列用作互斥量時,pcHead要設(shè)置成NULL.這里只是將pcHead指向一個已知的區(qū)域 */
            pxNewQueue->pcHead = ( int8_t * ) pxNewQueue;
        }
        else
        {
            /* 指向隊列項存儲區(qū)域*/
            pxNewQueue->pcHead = ( int8_t * ) pucQueueStorage;
        }
        /* 初始化隊列結(jié)構(gòu)體成員*/
        pxNewQueue->uxLength = uxQueueLength;
        pxNewQueue->uxItemSize = uxItemSize;
        ( void ) xQueueGenericReset( pxNewQueue, pdTRUE );
        #if ( configUSE_TRACE_FACILITY == 1 )
        {
            pxNewQueue->ucQueueType = ucQueueType;
        }
        #endif /* configUSE_TRACE_FACILITY */
        traceQUEUE_CREATE( pxNewQueue );
    }
    return ( QueueHandle_t ) pxNewQueue;
}

BaseType_t xQueueGenericSend
				( 
					QueueHandle_t xQueue, 
					const void * const pvItemToQueue, 
					TickType_t xTicksToWait, 
					const BaseType_t xCopyPosition 
				)

BaseType_t xQueueGenericSend( 
				QueueHandle_t xQueue, 
				const void * const pvItemToQueue, 
				TickType_t xTicksToWait, 
				const BaseType_t xCopyPosition )
{
BaseType_t xEntryTimeSet = pdFALSE, xYieldRequired;
TimeOut_t xTimeOut;
Queue_t * const pxQueue = ( Queue_t * ) xQueue;
     for( ;; )
    {
        taskENTER_CRITICAL();
        {
            /* 隊列還有空閑?正在運行的任務(wù)一定要比等待訪問隊列的任務(wù)優(yōu)先級高.如果使用覆蓋式入隊,則不需要關(guān)注隊列是否滿*/
            if( ( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) || ( xCopyPosition == queueOVERWRITE ) )
            {
                /*完成數(shù)據(jù)拷貝工作,分為從隊列尾入隊,從隊列首入隊和覆蓋式入隊*/
                xYieldRequired = prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition );
                /* 如果有任務(wù)在此等待隊列數(shù)據(jù)到來,則將該任務(wù)解除阻塞*/
                if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE )
                {
                    /*有任務(wù)因等待出隊而阻塞,則將任務(wù)從隊列等待接收列表中刪除,然后加入到就緒列表*/
                    if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE )
                    {
                        /* 解除阻塞的任務(wù)有更高的優(yōu)先級,則當(dāng)前任務(wù)要讓出CPU,因此觸發(fā)一個上下文切換.又因為現(xiàn)在還在臨界區(qū),要等退出臨界區(qū)后,才會執(zhí)行上下文切換.*/
                        queueYIELD_IF_USING_PREEMPTION();
                    }
                }
                else if( xYieldRequired != pdFALSE )
                {
                    /* 這個分支處理特殊情況*/
                    queueYIELD_IF_USING_PREEMPTION();
                }
                taskEXIT_CRITICAL();
                return pdPASS;
            }
            else
            {
                if( xTicksToWait == ( TickType_t ) 0 )
                {
                    /* 如果隊列滿并且沒有設(shè)置超時,則直接退出 */
                    taskEXIT_CRITICAL();
                    /* 返回隊列滿錯誤碼 */
                    return errQUEUE_FULL;
                }
                else if( xEntryTimeSet == pdFALSE )
                {
                    /* 隊列滿并且規(guī)定了阻塞時間,因此需要配置超時結(jié)構(gòu)體對象 */
                    vTaskSetTimeOutState( &xTimeOut );
                    xEntryTimeSet = pdTRUE;
                }
            }
        }
        taskEXIT_CRITICAL();
        /* 退出臨界區(qū),至此,中斷和其它任務(wù)可以向這個隊列執(zhí)行入隊(投遞)或出隊(讀取)操作.因為隊列滿,任務(wù)無法入隊,下面的代碼將當(dāng)前任務(wù)將阻塞在這個隊列上,在這段代碼執(zhí)行過程中我們需要掛起調(diào)度器,防止其它任務(wù)操作隊列事件列表;掛起調(diào)度器雖然可以禁止其它任務(wù)操作這個隊列,但并不能阻止中斷服務(wù)程序操作這個隊列,因此還需要將隊列上鎖,防止中斷程序讀取隊列后,使阻塞在出隊操作其它任務(wù)解除阻塞,執(zhí)行上下文切換(因為調(diào)度器掛起后,不允許執(zhí)行上下文切換) */
        vTaskSuspendAll();
        prvLockQueue( pxQueue );
        /* 查看任務(wù)的超時時間是否到期 */
        if( xTaskCheckForTimeOut( &xTimeOut, &xTicksToWait ) == pdFALSE )
        {
            if( prvIsQueueFull( pxQueue ) != pdFALSE )
            {
                /*超時時間未到期,并且隊列仍然滿*/
                vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToSend ), xTicksToWait );
                /* 解除隊列鎖,如果有任務(wù)要解除阻塞,則將任務(wù)移到掛起就緒列表中(因為當(dāng)前調(diào)度器掛起,所以不能移到就緒列表)*/
                prvUnlockQueue( pxQueue );
                /* 恢復(fù)調(diào)度器,將任務(wù)從掛起就緒列表移到就緒列表中*/
                if( xTaskResumeAll() == pdFALSE )
                {
                    portYIELD_WITHIN_API();
                }
            }
            else
            {
                /* 隊列有空閑,重試 */
                prvUnlockQueue( pxQueue );
                ( void ) xTaskResumeAll();
            }
        }
        else
        {
            /* 超時時間到期,返回隊列滿錯誤碼*/
            prvUnlockQueue( pxQueue );
            ( void ) xTaskResumeAll();
            traceQUEUE_SEND_FAILED( pxQueue );
            return errQUEUE_FULL;
        }
    }
}

BaseType_t xQueueGenericSendFromISR
				( 
						QueueHandle_t xQueue, 
						const void * const pvItemToQueue, 
						BaseType_t * const pxHigherPriorityTaskWoken, 
						const BaseType_t xCopyPosition 
				)

BaseType_t xQueueGenericSendFromISR(
 				QueueHandle_t xQueue, 
				const void * const pvItemToQueue, 
				BaseType_t * const pxHigherPriorityTaskWoken, 
				const BaseType_t xCopyPosition )
{
BaseType_t xReturn;
UBaseType_t uxSavedInterruptStatus;
Queue_t * const pxQueue = ( Queue_t * ) xQueue;
    uxSavedInterruptStatus = portSET_INTERRUPT_MASK_FROM_ISR();
    {
        if( ( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) || ( xCopyPosition == queueOVERWRITE ) )
        {
            traceQUEUE_SEND_FROM_ISR( pxQueue );
            /*完成數(shù)據(jù)拷貝工作,分為從隊列尾入隊,從隊列首入隊和覆蓋式入隊*/
            ( void ) prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition );
            /*檢查隊列是否上鎖,如果上鎖,則隊列事件列表不能被改變 */
            if( pxQueue->xTxLock == queueUNLOCKED )
            {   /*隊列沒有上鎖*/
                if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE )
                {
                    if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE )
                    {
                        /* 解除阻塞的任務(wù)優(yōu)先級比當(dāng)前任務(wù)高,記錄上下文切換請求,等返回中斷服務(wù)程序后,可以顯示的強制上下文切換 */
                        if( pxHigherPriorityTaskWoken != NULL )
                        {
                            *pxHigherPriorityTaskWoken = pdTRUE;
                        }
                    }
                }
            }
            else
            {
                /* 隊列上鎖,增加鎖計數(shù)器,等到任務(wù)解除隊列鎖時,使用這個計數(shù)器就可以知道有多少數(shù)據(jù)入隊,可以最多解除多少個因等待從隊列讀數(shù)據(jù)而阻塞的任務(wù) */
                ++( pxQueue->xTxLock );
            }
            xReturn = pdPASS;
        }
        else
        {
            xReturn = errQUEUE_FULL;
        }
    }
    portCLEAR_INTERRUPT_MASK_FROM_ISR( uxSavedInterruptStatus );
    return xReturn;
}