在FreeRTOS中，隊列是實現任務之間同步、互斥和通信的一種重要方法（其他的實現方法有：任務通知、事件組、信號量、互斥量）。

任何任務都可以向隊列里存放任何數據，任何任務也可以從隊列里讀取數據，實現不同任務之間的通信。

1

隊列特性

隊列的數據的操作采用先進先出的方法(FIFO，First In First Out)：寫數據時放到尾部，讀數據時從頭部讀，邏輯順序如下圖所示。

使用隊列傳輸數據時有兩種方法：

拷貝：把數據、把變量的值復制進隊列里

引用：把數據、把變量的地址復制進隊列里

FreeRTOS中的隊列一般都使用拷貝的方式傳輸數據，局部變量的值可以發送到隊列中，后續即使函數退出、局部變量被回收，也不會影響隊列中的數據，發送任務、接收任務解耦時，接收任務不需要知道這數據是誰的、也不需要發送任務來釋放數據。

如果數據實在太大，還是可以使用隊列傳輸它的地址。

2

隊列函數

1.創建

隊列的創建有兩種方法：動態分配內存、靜態分配內存。

一般都用動態分配內存的方法，使用函數：xQueueCreate()

QueueHandle_t xQueueCreate( UBaseType_t uxQueueLength, UBaseType_t uxItemSize );

參數解釋：

uxQueueLength ：隊列長度

uxItemSize：每個數據的大小，以字節為單位

返回值：非0：成功，返回句柄，以后使用句柄來操作隊列；NULL：失敗，因為內存不足

2.刪除

刪除隊列的函數為 vQueueDelete() ，只能刪除使用動態方法創建的隊列，它會釋放內存。

void vQueueDelete( QueueHandle_t xQueue );

參數解釋：

xQueue：隊列句柄

3.寫隊列

可以把數據寫到隊列頭部，也可以寫到尾部，這些函數有兩個版本：在任務中使用、在 ISR 中使用。

在任務中使用：

BaseType_t xQueueSend( QueueHandle_t xQueue,const void *pvItemToQueue,TickType_t xTicksToWait );

在ISR中使用：

BaseType_t xQueueSendToBackFromISR( QueueHandle_t xQueue,const void *pvItemToQueue,BaseType_t *pxHigherPriorityTaskWoken );

參數解釋：

xQueue ：隊列句柄，要寫哪個隊列

pvItemToQueue ： 數據指針，這個數據的值會被復制進隊列

xTicksToWait ：如果隊列滿則無法寫入新數據，可以讓任務進入阻塞狀態，xTicksToWait表示阻塞的最大時間(Tick Count)。如果被設為0，無法寫入數據時函數會立刻返回；如果被設為portMAX_DELAY，則會一直阻塞直到有空間可寫

返回值：pdPASS：數據成功寫入了隊列；errQUEUE_FULL：寫入失敗，因為隊列滿了。

4.讀隊列

使用 xQueueReceive() 函數讀隊列，讀到一個數據后，隊列中該數據會被移除。這個函數有兩個版 本：在任務中使用、在ISR 中使用。

BaseType_t xQueueReceive( QueueHandle_t xQueue, void * const pvBuffer, TickType_t xTicksToWait );

BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue, void *pvBuffer, BaseType_t *pxTaskWoken );

參數解釋：

xQueue ：隊列句柄，要寫哪個隊列

pvBuffffer： bufer 指針，隊列的數據會被復制到這個 buffer

xTicksToWait ：如果隊列空則無法讀出數據，可以讓任務進入阻塞狀態，xTicksToWait表示阻塞的最大時間(Tick Count)。如果被設為0，無法讀出數據時函數會立刻返回；如果被設為portMAX_DELAY，則會一直阻塞直到有數據可寫

返回值：pdPASS：從隊列讀出數據入；errQUEUE_EMPTY：讀取失敗，因為隊列空了。

5.其他

復位：隊列剛被創建時，里面沒有數據；使用過程中可以調用 xQueueReset() 把隊列恢復為初始狀態。

/* 

pxQueue : 復位哪個隊列; 

 * 返回值: pdPASS(必定成功)

 */ 

BaseType_t xQueueReset( QueueHandle_t pxQueue);

查詢：可以查詢隊列中有多少個數據、有多少空余空間。

/** 返回隊列中可用數據的個數 */ 

UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue ); 

/** 返回隊列中可用空間的個數 */ 

UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue );

覆蓋：當隊列長度為 1 時，可以使用 xQueueOverwrite() 或 xQueueOverwriteFromISR() 來覆蓋數據。注意，隊列長度必須為1。當隊列滿時，這些函數會覆蓋里面的數據，這也以為著這些函數不會被阻塞。

/* 覆蓋隊列

 * xQueue: 寫哪個隊列

 * pvItemToQueue: 數據地址

 * 返回值: pdTRUE表示成功, pdFALSE表示失敗

 */ 

BaseType_t xQueueOverwrite(QueueHandle_t xQueue, const void * pvItemToQueue ); 

BaseType_t xQueueOverwriteFromISR( QueueHandle_t xQueue, const void * pvItemToQueue, BaseType_t *pxHigherPriorityTaskWoken );

偷看：如果想讓隊列中的數據供多方讀取，也就是說讀取時不要移除數據，要留給后來人。那么可以使用' 窺 視' ，也就是 xQueuePeek() 或 xQueuePeekFromISR() 。這些函數會從隊列中復制出數據，但是不移除數據。這也意味著，如果隊列中沒有數據，那么' 偷看 ' 時會導致阻塞；一旦隊列中有數據，以后每次 ' 偷看' 都會成功。

/* 偷看隊列

 * xQueue: 偷看哪個隊列

 * pvItemToQueue: 數據地址, 用來保存復制出來的數據

 * xTicksToWait: 沒有數據的話阻塞一會

 * 返回值: pdTRUE表示成功, pdFALSE表示失敗

 */ 

BaseType_t xQueuePeek( QueueHandle_t xQueue, void * const pvBuffer, TickType_t xTicksToWait );

BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue, void *pvBuffer, );

3

隊列實驗

代碼：

/* vSenderTask被用來創建2個任務，用于寫隊列

 * vReceiverTask被用來創建1個任務，用于讀隊列

 */

static void vSenderTask( void *pvParameters );

static void vReceiverTask( void *pvParameters );

/*-----------------------------------------------------------*/

/* 隊列句柄, 創建隊列時會設置這個變量 */

QueueHandle_t xQueue;

int main( void )

{

  prvSetupHardware();

    /* 創建隊列: 長度為5，數據大小為4字節(存放一個整數) */

    xQueue = xQueueCreate( 5, sizeof( int32_t ) );

  if( xQueue != NULL )

  {

    /* 創建2個任務用于寫隊列, 傳入的參數分別是100、200

     * 任務函數會連續執行，向隊列發送數值100、200

     * 優先級為1

     */

    xTaskCreate( vSenderTask, 'Sender1', 1000, ( void * ) 100, 1, NULL );

    xTaskCreate( vSenderTask, 'Sender2', 1000, ( void * ) 200, 1, NULL );

    /* 創建1個任務用于讀隊列

     * 優先級為2, 高于上面的兩個任務

     * 這意味著隊列一有數據就會被讀走

     */

    xTaskCreate( vReceiverTask, 'Receiver', 1000, NULL, 2, NULL );

    /* 啟動調度器 */

    vTaskStartScheduler();

  }

  else

  {

    /* 無法創建隊列 */

  }

  /* 如果程序運行到了這里就表示出錯了, 一般是內存不足 */

  return 0;

}

/*-----------------------------------------------------------*/

/*-----------------------------------------------------------*/

static void vSenderTask( void *pvParameters )

{

  int32_t lValueToSend;

  BaseType_t xStatus;

  /* 我們會使用這個函數創建2個任務

   * 這些任務的pvParameters不一樣

    */

  lValueToSend = ( int32_t ) pvParameters;

  /* 無限循環 */

  for( ;; )

  {

    /* 寫隊列

     * xQueue: 寫哪個隊列

     * &lValueToSend: 寫什么數據? 傳入數據的地址, 會從這個地址把數據復制進隊列

     * 0: 不阻塞, 如果隊列滿的話, 寫入失敗, 立刻返回

     */

    xStatus = xQueueSendToBack( xQueue, &lValueToSend, 0 );

    if( xStatus != pdPASS )

    {

      printf( 'Could not send to the queue.rn' );

    }

  }

}

/*-----------------------------------------------------------*/

static void vReceiverTask( void *pvParameters )

{

  /* 讀取隊列時, 用這個變量來存放數據 */

  int32_t lReceivedValue;

  BaseType_t xStatus;

  const TickType_t xTicksToWait = pdMS_TO_TICKS( 100UL );

  /* 無限循環 */

  for( ;; )

  {

    /* 讀隊列

     * xQueue: 讀哪個隊列

     * &lReceivedValue: 讀到的數據復制到這個地址

     * xTicksToWait: 如果隊列為空, 阻塞一會

     */

    xStatus = xQueueReceive( xQueue, &lReceivedValue, xTicksToWait );

    if( xStatus == pdPASS )

    {

      /* 讀到了數據 */

      printf( 'Received = %drn', lReceivedValue );

    }

    else

    {

      /* 沒讀到數據 */

      printf( 'Could not receive from the queue.rn' );

    }

  }

}

在這個程序中，有一個接收隊列數據的任務，兩個發送隊列數據的任務，接收隊列數據的任務優先級高，先執行，但是這時隊列為空，觸發該任務阻塞，這時低優先級的任務交替執行，向隊列中發送數據，接收任務發現隊列不為空后（解除觸發的事件），立刻被喚醒從隊列中讀取數據并打印出來，實驗結果和邏輯圖如下：