第四章队列

以你之姓@ 2024-04-17 16:28 71阅读 0赞

队列是任务间通信的主要形式。它们可用于在任务之间以及中断和任务之间发送消息。在大多数情况下，它们被用作线程安全FIFO（先进先出）缓冲区。  
\`\`\`  
uint8\_t FifoMessage\[10\] = "hello";  
QueueHandle\_t TmpQueueHandle;

//第一步 ： 创建队列  
TmpQueueHandle = xQueueCreate( 10 , sizeof(FifoMessage) );  
if(NULL != TmpQueueHandle) //创建队列成功  
\{  
     printf("create queue successfully\\r\\n");          
\}

/\*第二步：发生消息  
注意项： xQueueSend( xQueue, pvItemToQueue, xTicksToWait ) xTicksToWait项，阻塞时间，指示当队列满的时候，任务进入阻塞态，等待队列空闲的最大时间。  
如果值给0的话，当队列满的时候，就立即返回，  
当值为portMAX\_DELAY (INCLUDE\_vTaskSuspend需为1)的时候，程序就会一直死等，相当于while\{\}；直到队列有空闲的队列项。  
当为0，队列满的时候，则执行printf("queue send data fail\\r\\n");  
当值为portMAX\_DELAY，队列满的时候，程序阻塞，不执行任何语句，也就不执行printf("queue send data fail\\r\\n");  
\*/  
A:       
    led1\_task\_cnt++;

if(led1\_task\_cnt < 24)  
    \{  
        FifoMessage\[5\] = 0x31+led1\_task\_cnt;  
        if( pdPASS ==  xQueueSend( TmpQueueHandle, FifoMessage, (TickType\_t)0 ) ) //portMAX\_DELAY  
        \{  
            printf("queue send successfully,send data is %s\\r\\n",FifoMessage);  
        \}  
        else //队列已满，消息发生失败。  
        \{  
            printf("queue send data fail\\r\\n");  
        \}  
    \}  
    else  
    \{  
        vTaskDelay(500);  
    \}  
      
B：  
    覆盖写  
    xQueueOverwrite（）旨在用于长度为1的队列，这意味着队列为空或完整。创建队列的时候，长度只能为1.  
      
    TmpQueueHandle = xQueueCreate( 1 , sizeof(FifoMessage) );  
    if( pdPASS ==  xQueueOverwrite(TmpQueueHandle, FifoMessage) ) //返回值只有pdPASS  
    \{  
        printf("queue send successfully,send data is %s\\r\\n",FifoMessage);  
    \}

/\*  
接受数据  
\*/  
A:  
    if( pdTRUE == xQueueReceive( TmpQueueHandle, &tmp, (TickType\_t)10 ) )  
    \{  
        printf("recv data is %s\\r\\n", tmp);  
    \}  
B：  
    从队列中接收项目而不从队列中删除项目。该项目通过复制接收，因此必须提供足够大小的缓冲区。创建队列时定义复制到缓冲区中的字节数。

成功接收的项目仍保留在队列中，因此将在下一次调用或调用xQueueReceive（）时再次返回。

不得在中断服务程序中使用此宏。  
      
    if( pdTRUE == xQueuePeek ( TmpQueueHandle, &tmp, (TickType\_t)10 ) ) //复制队列的数据，不会删除这个数据  
    \{  
        printf("recv data is %s\\r\\n", tmp);  
    \}

\`\`\`