devbox
小舞很执着
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

ESP32-S3-FreeRTOS_esp32freertos配置

作者：小舞很执着 | 2024-07-24 17:27:23

赞

踩

esp32freertos配置

目录

1、3个核心文件

2、Task四种输入参数

2.1 整数形

2.2 整数形数组

2.3 结构体

2.4 字符串

3、Task优先级

3.1 最大优先级

3.2 同等优先级任务

3.3 不等优先级任务

3.4 修改优先级别

4、Task挂起和恢复

4.1 任务的四态

 4.2 任务挂起恢复

4.3 挂起全部任务 

5、Task系统信息显示

6、Task堆栈设置和调试

7、Task看门狗

7.1 中断看门狗

7.2 Task看门狗

7.3 将自己的任务加到监控列表

8、队列的三种数据传递

8.1 整形

8.2 结构体

8.3 指针

9、 队列模型

9.1 队列的多进单出

9.2 队列集合

9.3 队列邮箱

10 、软件定时器

11、 信号量

11.1 二进制信号量

11.2 计数型信号量 

12、互斥量 

13 、递归互斥量

14、 事件组

14.1 事件组的等待

14.2 事件组的同步

 15、通知

15.1 通知同步

15.2 通知值

16、流数据缓冲区

16.1 数据流缓冲区

16.2 确定数据流缓冲区的大小

17、 消息缓冲区

17.1 与数据流的区别1

17.1 与数据流的区别2 

1、3个核心文件

2、Task四种输入参数

2.1 整数形

  1. #include <stdio.h>
  2. #include <inttypes.h>
  3. #include "sdkconfig.h"
  4. #include "freertos/FreeRTOS.h"
  5. #include "freertos/task.h"
  6. #include "esp_chip_info.h"
  7. #include "esp_flash.h"
  8.  
  9. void myTask(void * pvParam)
  10. {
  11.     int *pInt;
  12.     pInt = (int *)pvParam;
  13.     while (1)
  14.     {
  15.         printf("i got a %d\r\n",*pInt);
  16.         vTaskDelay(1000 / portTICK_PERIOD_MS);
  17.     }
  18. }
  19. int testNum = 1;
  20. void app_main(void)
  21. {
  22.      
  23.     xTaskCreate(myTask,"myTask",2048,(void *)&testNum,1,NULL);
  24. }

2.2 整数形数组

  1. void myTask(void *pvParam)
  2. {
  3.     int *pArrayAddr;
  4.     pArrayAddr = (int *)pvParam;
  5.     while (1)
  6.     {
  7.         printf("i got a %d,%d,%d\r\n", *pArrayAddr, *(pArrayAddr + 1), *(pArrayAddr + 2));
  8.         vTaskDelay(1000 / portTICK_PERIOD_MS);
  9.     }
  10. }
  11. int testNum[] = {1, 2, 3};
  12. void app_main(void)
  13. {
  14.  
  15.     xTaskCreate(myTask, "myTask", 2048, (void *)testNum, 1, NULL);
  16. }

2.3 结构体

  1. typedef struct A_STRUCT
  2. {
  3.     int iMem1;
  4.     int iMem2;
  5. } xStruct;
  6. xStruct xStrTest = {8, 9};
  7.  
  8. void myTask(void *pvParam)
  9. {
  10.     xStruct *pStrTest;
  11.     pStrTest = (xStruct *)pvParam;
  12.     while (1)
  13.     {
  14.         printf("i got a %d,%d\r\n", pStrTest->iMem1, pStrTest->iMem2);
  15.         vTaskDelay(1000 / portTICK_PERIOD_MS);
  16.     }
  17. }
  18. void app_main(void)
  19. {
  20.  
  21.     xTaskCreate(myTask, "myTask", 2048, (void *)&xStrTest, 1, NULL);
  22. }

2.4 字符串

  1. static const char *pcTxt = "little one";
  2.  
  3. void myTask(void *pvParam)
  4. {
  5.     char *pcTxtInTask;
  6.     pcTxtInTask = (char *)pvParam;
  7.     while (1)
  8.     {
  9.         printf("i got a %s\r\n", pcTxtInTask);
  10.         vTaskDelay(1000 / portTICK_PERIOD_MS);
  11.     }
  12. }
  13. void app_main(void)
  14. {
  15.  
  16.     xTaskCreate(myTask, "myTask", 2048, (void *)pcTxt, 1, NULL);
  17. }

3、Task优先级

3.1 最大优先级

  1.     UBaseType_t ipriority = 0;
  2.     TaskHandle_t pxTask = NULL;
  3.     xTaskCreate(myTask, "myTask", 2048, (void *)pcTxt,5, &pxTask);
  4.     ipriority = uxTaskPriorityGet(pxTask);
  5.     printf("ipriority = %d\r\n", ipriority);
  • ESP32S3 是Xtens核所以配置文件看

3.2 同等优先级任务

  • 谁先创建谁先运行然后时间片轮询
  • 句柄就是任务地址
  1. void myTask1(void *pvParam)
  2. {
  3.     while (1)
  4.     {
  5.         printf("myTask1\r\n");
  6.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  7.     }
  8. }
  9. void myTask2(void *pvParam)
  10. {
  11.     while (1)
  12.     {
  13.         printf("myTask2\r\n");
  14.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  15.     }
  16. }
  17.  
  18. void app_main(void)
  19. {
  20.  
  21.     xTaskCreate(myTask1, "myTask1", 2048,NULL, 5, NULL);
  22.     xTaskCreate(myTask2, "myTask2", 2048,NULL, 5, NULL);
  23. }

3.3 不等优先级任务

  • 高优先级先运行
  • ESP32设置优先级无效，是ESP32双核运行导致的。在SDK配置编辑器(menuconfig)中勾选 "Run FreeRTOS only on first core" 就好了。
  • 上述方法试了还是不管用，解决办法将两个任务都分配到指定内核
  1. void myTask1(void *pvParam)
  2. {
  3.     BaseType_t id;
  4.     while (1)
  5.     {
  6.         id = xPortGetCoreID();
  7.         printf("myTask1-coreID:%d\r\n",id);
  8.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  9.     }
  10. }
  11. void myTask2(void *pvParam)
  12. {
  13.     BaseType_t id;
  14.     while (1)
  15.     {
  16.         id = xPortGetCoreID();
  17.         printf("myTask2-coreID:%d\r\n",id);
  18.         
  19.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  20.     }
  21. }
  22.  
  23. void app_main(void)
  24. {
  25.     UBaseType_t iPriority = 0;
  26.     TaskHandle_t pxTask;
  27.     // xTaskCreate(myTask1, "myTask1", 2048,NULL, 1,&pxTask) ;
  28.     // xTaskCreate(myTask2, "myTask2", 2048,NULL, 2, NULL);
  29.  
  30.     xTaskCreatePinnedToCore(myTask1, "myTask1", 2048,NULL, 1,&pxTask,1) ;
  31.     xTaskCreatePinnedToCore(myTask2, "myTask1", 2048,NULL, 2,&pxTask,1) ;
  32.     vTaskPrioritySet(pxTask,3);
  33.     iPriority = uxTaskPriorityGet(pxTask);
  34.     printf("iPriority = %d\n",iPriority);
  35. }

3.4 修改优先级别

vTaskPrioritySet(pxTask,3);

4、Task挂起和恢复

4.1 任务的四态

  • Runing、Ready、Blocked、Suspended

 4.2 任务挂起恢复

  • 一个任务不能独占CPU运行时间过久，会触发看门狗重启系统。
  1. vTaskSuspend(pxTask);
  2. vTaskResume(pxTask);
  3.  
  4. vTaskSuspened(句柄)  挂起函数
  5. vTaskResume(句柄)    恢复挂起的函数
  6. vTaskSuspenedAll()   挂起所有函数，挂起后不可以执行FreeRTOS自身的函数
  7. vTaskResumeAll  恢复所有挂起函数

4.3 挂起全部任务 

  1. void myTask1(void *pvParam)
  2. {
  3.     printf("Test begin\n");
  4.     vTaskSuspendAll();  //挂起调度器系统所有任务被挂起停止，CPU全部时间在执行下面的for循环
  5.                         //并且在vTaskSuspendAll 与 xTaskResumeAll 之间不不能再调用FreeRTOS的API，自己的函数是可以的。
  6.     for (int i = 0; i < 9999; i++)
  7.     {
  8.         for (int j = 0; j < 5555; j++)
  9.         {
  10.             ;
  11.         }
  12.         
  13.     }
  14.     xTaskResumeAll();
  15.     printf("Test end\n");   //恢复调度器
  16.     vTaskDelete(NULL);      //删除该任务
  17. }
  18. void myTask2(void *pvParam)
  19. {
  20.     BaseType_t id;
  21.     while (1)
  22.     {
  23.         id = xPortGetCoreID();
  24.         printf("myTask2-coreID:%d\r\n",id);
  25.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  26.     }
  27. }
  28.  
  29. void app_main(void)
  30. {
  31.     TaskHandle_t pxTask;
  32.     xTaskCreate(myTask1, "myTask1", 2048,NULL, 1,&pxTask) ;
  33.     xTaskCreate(myTask2, "myTask2", 2048,NULL, 2, NULL);
  34. }

5、Task系统信息显示

  1. void app_main(void)
  2. {
  3.     TaskHandle_t pxTask;
  4.     xTaskCreate(myTask1, "myTask1", 2048,NULL, 1,&pxTask) ;
  5.     xTaskCreate(myTask2, "myTask2", 2048,NULL, 2, NULL);
  6.  
  7.     static char pcWriteBuffer[512] = {0};
  8.  
  9.     while (1)
  10.     {
  11.         vTaskList(pcWriteBuffer);
  12.         printf("------------------------------------------------\n");
  13.         printf("Name    State   Priority    Stack   Num\n");
  14.         printf("%s\n",pcWriteBuffer);
  15.         vTaskDelay(3000 / portTICK_PERIOD_MS); // 1s delay
  16.     } 
  17. }

For example ESP-IDF system tasks (like ipc, timer tasks etc.) will also have that extra stack space allocated. So this feature should be used with care.

在 ESP32 中，IPC0 和 IPC1 分别指代两个不同的 IPC 总线。

IPC0 是 ESP32 的主 IPC 总线，用于连接主处理器（CPU0）与其他辅助处理器（如协处理器 CPU1）之间的通信。主要用于在不同处理器之间传输数据和命令，以实现协同工作和数据交换。

IPC1 是 ESP32 的备用 IPC 总线，也可用于进行处理器之间的通信。它可以与其他外设进行接口连接用于特定的应用。

这两个 IPC 总线可以实现高效的数据交换和通信，帮助 ESP32 在多处理器系统中实现强大的功能和性能。

6、Task堆栈设置和调试

  • 用uxTaskGetStackHighWaterMark()来取得指定Task运行过程中stack剩余的值，相交与上一个方法用到的资源更加少；
  • vxTaskGetStackHighWaterMark(句柄) 可以查看当前函数剩余的内存大小(创建任务时分配) ，如果不够会导致程序不断重启
    分配的数量每+1，内存+4byte
  1. void app_main(void)
  2. {
  3.     TaskHandle_t pxTask;
  4.     xTaskCreate(myTask1, "myTask1", 2048,NULL, 1,&pxTask) ;
  5.     xTaskCreate(myTask2, "myTask2", 2048,NULL, 2, NULL);
  6.  
  7.     UBaseType_t iStack;
  8.  
  9.     while (1)
  10.     {
  11.         iStack = uxTaskGetStackHighWaterMark(pxTask);
  12.         printf("IDLE Stack %d\n",iStack);
  13.         vTaskDelay(3000 / portTICK_PERIOD_MS); // 1s delay
  14.     } 
  15. }

 

7、Task看门狗

7.1 中断看门狗

  • 防止在中断里面运行时间过长，会触发中断看门狗；

7.2 Task看门狗

  • 缺省状态下监控IDLE 任务，如果5s后没被运行会触发看门狗重启系统；

  1. void myTask1(void *pvParam)
  2. {
  3.     BaseType_t id;
  4.     while (1)
  5.     {
  6.     }
  7. }
  8. void app_main(void)
  9. {
  10.     TaskHandle_t pxTask;
  11.     xTaskCreate(myTask1, "myTask1", 2048,NULL, 1,&pxTask) ;
  12.  
  13. }

错误信息中提到的任务 “IDLE (CPU 0)” 意味着CPU 0上的空闲任务（也就是系统任务），未能及时重置任务看门狗。而任务 “myTask1” 则是当前在 CPU 0 上正在运行的任务。

将任务优先级改成和空闲任务一样的优先级0，这样两个任务同等优先级，时间片轮训IDLE任务可以得到运行就不会触发。

7.3 将自己的任务加到监控列表

  1. #include <stdio.h>
  2. #include <inttypes.h>
  3. #include "sdkconfig.h"
  4. #include "freertos/FreeRTOS.h"
  5. #include "freertos/task.h"
  6. #include "esp_chip_info.h"
  7. #include "esp_flash.h"
  8.  
  9. #include "esp_task_wdt.h"
  10.  
  11. void myTask1(void *pvParam)
  12. {
  13.     while (1)
  14.     {
  15.         printf("myTask1\r\n");
  16.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  17.     }
  18. }
  19. void myTask2(void *pvParam)
  20. {
  21.     esp_task_wdt_add(NULL);     //task_handle为NULL表示添加本任务到列表
  22.  
  23.     while (1)
  24.     {
  25.         printf("myTask2\r\n");
  26.         vTaskDelay(6000 / portTICK_PERIOD_MS); // 6s delay
  27.         esp_task_wdt_reset();   //喂狗
  28.         
  29.     }
  30. }
  31. void app_main(void)
  32. {
  33.     TaskHandle_t pxTask;
  34.     xTaskCreate(myTask1, "myTask1", 2048,NULL, 1,&pxTask) ;
  35.     xTaskCreate(myTask2, "myTask2", 2048,NULL, 1,NULL) ;
  36.  
  37. }

系统默认的触发时间为5s，这里延迟了6s后才喂狗，所以会触发看门狗。

8、队列的三种数据传递

8.1 整形

  • freertos的队列是值传递，虽然传进去的指针。
  1. #include <stdio.h>
  2. #include <inttypes.h>
  3. #include "sdkconfig.h"
  4. #include "freertos/FreeRTOS.h"
  5. #include "freertos/task.h"
  6. #include "esp_chip_info.h"
  7. #include "esp_flash.h"
  8.  
  9. #include "freertos/queue.h"
  10.  
  11. void sendTask(void *pvParam)
  12. {
  13.     QueueHandle_t QHandle;
  14.     QHandle = (QueueHandle_t)pvParam;
  15.  
  16.     BaseType_t xStatus;
  17.     int i = 0;
  18.  
  19.     while (1)
  20.     {
  21.         xStatus = xQueueSend(QHandle, &i, 0);
  22.         if (pdPASS == xStatus)
  23.             printf("send done\n");
  24.         else
  25.             printf("send fail\n");
  26.         i++;
  27.         if (i == 8)
  28.             i = 0;
  29.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  30.     }
  31. }
  32. void recTask(void *pvParam)
  33. {
  34.     QueueHandle_t QHandle;
  35.     QHandle = (QueueHandle_t)pvParam;
  36.     BaseType_t xStatus;
  37.     int j = 0;
  38.  
  39.     while (1)
  40.     {
  41.         if (0 != uxQueueMessagesWaiting(QHandle)) // 优化：在读取数据时判断队列中有没有数据,有多少个数据在队列中等待
  42.         {
  43.             xStatus = xQueueReceive(QHandle, &j, 0);
  44.             if (pdPASS == xStatus)
  45.                 printf("rec j = %d\n", j);
  46.             else
  47.                 printf("rec fail\n");
  48.         }
  49.         else
  50.         {
  51.             printf("no data!\n");
  52.         }
  53.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 6s delay
  54.     }
  55. }
  56. void app_main(void)
  57. {
  58.     QueueHandle_t QHandle;
  59.     QHandle = xQueueCreate(5, sizeof(int));
  60.  
  61.     if (NULL != QHandle)
  62.     {
  63.         printf("Create queue successfully\n");
  64.         xTaskCreate(sendTask, "sendTask", 2048, (void *)QHandle, 0, NULL);
  65.         xTaskCreate(recTask, "recTask", 2048, (void *)QHandle, 0, NULL);
  66.     }
  67.     else
  68.     {
  69.         printf("Can't crate queue!\n");
  70.     }
  71. }

8.2 结构体

  1. typedef struct A_STRUCT
  2. {
  3.     char id;
  4.     char data;  
  5. }xStruct;
  6.  
  7.  
  8. void sendTask(void *pvParam)
  9. {
  10.     QueueHandle_t QHandle;
  11.     QHandle = (QueueHandle_t)pvParam;
  12.  
  13.     BaseType_t xStatus;
  14.     xStruct xUSB = {1,55};
  15.     while (1)
  16.     {
  17.         xStatus = xQueueSend(QHandle, &xUSB, 0);
  18.         if (pdPASS == xStatus)
  19.             printf("send done\n");
  20.         else
  21.             printf("send fail\n");
  22.         xUSB.id++;
  23.         if (xUSB.id == 8)
  24.             xUSB.id = 0;
  25.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  26.     }
  27. }
  28. void recTask(void *pvParam)
  29. {
  30.     QueueHandle_t QHandle;
  31.     QHandle = (QueueHandle_t)pvParam;
  32.     BaseType_t xStatus;
  33.     xStruct xUSB = {0,0};
  34.     while (1)
  35.     {
  36.         if (0 != uxQueueMessagesWaiting(QHandle)) // 优化：在读取数据时判断队列中有没有数据,有多少个数据在队列中等待
  37.         {
  38.             xStatus = xQueueReceive(QHandle, &xUSB, 0);
  39.             if (pdPASS == xStatus)
  40.                 printf("rec id = %d data = %d \n", xUSB.id , xUSB.data);
  41.             else
  42.                 printf("rec fail\n");
  43.         }
  44.         else
  45.         {
  46.             printf("no data!\n");
  47.         }
  48.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 6s delay
  49.     }
  50. }
  51. void app_main(void)
  52. {
  53.     QueueHandle_t QHandle;
  54.     QHandle = xQueueCreate(5, sizeof(xStruct));
  55.  
  56.     if (NULL != QHandle)
  57.     {
  58.         printf("Create queue successfully\n");
  59.         xTaskCreate(sendTask, "sendTask", 2048, (void *)QHandle, 0, NULL);
  60.         xTaskCreate(recTask, "recTask", 2048, (void *)QHandle, 0, NULL);
  61.     }
  62.     else
  63.     {
  64.         printf("Can't crate queue!\n");
  65.     }
  66. }

8.3 指针

  1. void sendTask(void *pvParam)
  2. {
  3.     QueueHandle_t QHandle;
  4.     QHandle = (QueueHandle_t)pvParam;
  5.  
  6.     BaseType_t xStatus;
  7.     char *pStrToSend;
  8.     int i=0;
  9.     while (1)
  10.     {
  11.         pStrToSend = (char *)malloc(50);                            // 分配内存，这里在while循环里一直分配内存所以接受任务要收到一个释放一个不然会内存泄漏
  12.         snprintf(pStrToSend, 50, "Todat is a good day %d!\r\n", i); // 给内存赋值
  13.         xStatus = xQueueSend(QHandle, &pStrToSend, 0);              //如果是pStrToSend传递的是指针的值 &pStrToSend传递是指向数据指针的指针
  14.         if (pdPASS == xStatus)                                      //
  15.             printf("send done\n");
  16.         else
  17.             printf("send fail\n");
  18.         i++;
  19.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  20.     }
  21. }
  22. void recTask(void *pvParam)
  23. {
  24.     QueueHandle_t QHandle;
  25.     QHandle = (QueueHandle_t)pvParam;
  26.     BaseType_t xStatus;
  27.     char *pStrToRec;
  28.     while (1)
  29.     {
  30.         if (0 != uxQueueMessagesWaiting(QHandle)) // 优化：在读取数据时判断队列中有没有数据,有多少个数据在队列中等待
  31.         {
  32.             xStatus = xQueueReceive(QHandle, &pStrToRec, 0);
  33.             if (pdPASS == xStatus)
  34.                 printf("rec str %s\n", pStrToRec);
  35.             else
  36.                 printf("rec fail\n");
  37.             free(pStrToRec);       //内存释放
  38.         }
  39.         else
  40.         {
  41.             printf("no data!\n");
  42.         }
  43.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 6s delay
  44.     }
  45. }
  46. void app_main(void)
  47. {
  48.     QueueHandle_t QHandle;
  49.     QHandle = xQueueCreate(5, sizeof(char *));
  50.  
  51.     if (NULL != QHandle)
  52.     {
  53.         printf("Create queue successfully\n");
  54.         xTaskCreate(sendTask, "sendTask", 2048, (void *)QHandle, 0, NULL);
  55.         xTaskCreate(recTask, "recTask", 2048, (void *)QHandle, 0, NULL);
  56.     }
  57.     else
  58.     {
  59.         printf("Can't crate queue!\n");
  60.     }
  61. }

  • `&pStrToSend` 是将 `pStrToSend` 的地址传递给 `xQueueSend` 函数，以便函数能够在队列中发送 `pStrToSend` 所指向的数据。在这种情况下，`xQueueSend` 函数期望接收一个指向数据的指针的指针（即指向指针的指针），因此需要使用 `&` 操作符获取指针的地址。
  • 如果传递的是 `pStrToSend`，则实际上是将指针的值（内存地址）传递给 `xQueueSend` 函数，而不是指向 `pStrToSend` 所指向的数据。这可能会导致函数无法正确地访问和发送数据。所以需要使用 `&` 操作符获取指针的地址，以便函数能够正确地操作数据。

9、 队列模型

9.1 队列的多进单出

  1. void sendTask1(void *pvParam)
  2. {
  3.     QueueHandle_t QHandle;
  4.     QHandle = (QueueHandle_t)pvParam;
  5.  
  6.     BaseType_t xStatus;
  7.     int i=111;
  8.     while (1)
  9.     {
  10.         xStatus = xQueueSend(QHandle, &i, 0);              
  11.         if (pdPASS == xStatus)                                      
  12.             printf("Task1 send done\n");
  13.         else
  14.             printf("Task1 send fail\n");
  15.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  16.     }
  17. }
  18. void sendTask2(void *pvParam)
  19. {
  20.     QueueHandle_t QHandle;
  21.     QHandle = (QueueHandle_t)pvParam;
  22.  
  23.     BaseType_t xStatus;
  24.     int i=222;
  25.     while (1)
  26.     {
  27.         xStatus = xQueueSend(QHandle, &i, 0);              
  28.         if (pdPASS == xStatus)                                      
  29.             printf("Task2 send done\n");
  30.         else
  31.             printf("Task2 send fail\n");
  32.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  33.     }
  34. }
  35. void recTask(void *pvParam)
  36. {
  37.     QueueHandle_t QHandle;
  38.     QHandle = (QueueHandle_t)pvParam;
  39.     BaseType_t xStatus;
  40.     int i = 0;
  41.     while (1)
  42.     {
  43.      
  44.             xStatus = xQueueReceive(QHandle, &i, portMAX_DELAY);
  45.             if (pdPASS == xStatus)
  46.                 printf("rec str %d\n", i);
  47.             else
  48.                 printf("rec fail\n");
  49.             //vTaskDelay(1000 / portTICK_PERIOD_MS); // 6s delay 此处不能有延时可能会导致另外一个任务发送失败，
  50.                                                                 //因为两个发送任务的优先级一样，轮训发送这里再延迟的话会导致另外一个发送失败
  51.     }
  52. }
  53. void app_main(void)
  54. {
  55.     QueueHandle_t QHandle;
  56.     QHandle = xQueueCreate(5, sizeof(int));
  57.  
  58.     if (NULL != QHandle)
  59.     {
  60.         printf("Create queue successfully\n");
  61.         xTaskCreate(sendTask1, "sendTask1", 2048, (void *)QHandle, 1, NULL);
  62.         xTaskCreate(sendTask2, "sendTask2", 2048, (void *)QHandle, 1, NULL);
  63.         xTaskCreate(recTask, "recTask", 2048, (void *)QHandle, 2, NULL);
  64.     }
  65.     else
  66.     {
  67.         printf("Can't crate queue!\n");
  68.     }
  69. }

9.2 队列集合

  1. void sendTask1(void *pvParam)
  2. {
  3.     QueueHandle_t QHandle;
  4.     QHandle = (QueueHandle_t)pvParam;
  5.  
  6.     BaseType_t xStatus;
  7.     int i = 111;
  8.     while (1)
  9.     {
  10.         xStatus = xQueueSend(QHandle, &i, 0);
  11.         if (pdPASS == xStatus)
  12.             printf("Task1 send done\n");
  13.         else
  14.             printf("Task1 send fail\n");
  15.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  16.     }
  17. }
  18. void sendTask2(void *pvParam)
  19. {
  20.     QueueHandle_t QHandle;
  21.     QHandle = (QueueHandle_t)pvParam;
  22.  
  23.     BaseType_t xStatus;
  24.     int i = 222;
  25.     while (1)
  26.     {
  27.         xStatus = xQueueSend(QHandle, &i, 0);
  28.         if (pdPASS == xStatus)
  29.             printf("Task2 send done\n");
  30.         else
  31.             printf("Task2 send fail\n");
  32.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  33.     }
  34. }
  35. void recTask(void *pvParam)
  36. {
  37.     QueueSetHandle_t QueueSet;
  38.     QueueSet = (QueueHandle_t)pvParam;
  39.     QueueSetMemberHandle_t QueueDate;
  40.     BaseType_t xStatus;
  41.     int i = 0;
  42.     while (1)
  43.     {
  44.         QueueDate = xQueueSelectFromSet(QueueSet,portMAX_DELAY);    //获得queueSet中有数据的队列
  45.         xStatus = xQueueReceive(QueueDate, &i, portMAX_DELAY);
  46.         if (pdPASS == xStatus)
  47.             printf("rec str %d\n", i);
  48.         else
  49.             printf("rec fail\n");
  50.         
  51.     }
  52. }
  53. void app_main(void)
  54. {
  55.     QueueHandle_t QHandle1;
  56.     QueueHandle_t QHandle2;
  57.     QHandle1 = xQueueCreate(5, sizeof(int));
  58.     QHandle2 = xQueueCreate(5, sizeof(int));
  59.  
  60.     QueueSetHandle_t QueueSet;
  61.     QueueSet = xQueueCreateSet(10);     // 创建Queue
  62.     xQueueAddToSet(QHandle1, QueueSet); // 加入Queue
  63.     xQueueAddToSet(QHandle2, QueueSet);
  64.  
  65.     if ((NULL != QHandle1) && (NULL != QHandle2) && (NULL != QueueSet))
  66.     {
  67.         printf("Create queue successfully\n");
  68.         xTaskCreate(sendTask1, "sendTask1", 2048, (void *)QHandle1, 1, NULL);
  69.         xTaskCreate(sendTask2, "sendTask2", 2048, (void *)QHandle2, 1, NULL);
  70.         xTaskCreate(recTask, "recTask", 2048, (void *)QueueSet, 2, NULL);
  71.     }
  72.     else
  73.     {
  74.         printf("Can't crate queue!\n");
  75.     }
  76. }

9.3 队列邮箱

  1. void writeTask(void *pvParam)
  2. {
  3.     QueueHandle_t Mailbox;
  4.     Mailbox = (QueueHandle_t)pvParam;
  5.  
  6.     BaseType_t xStatus;
  7.     int i = 0;
  8.     while (1)
  9.     {
  10.         xStatus = xQueueOverwrite(Mailbox,&i);
  11.         if (pdPASS == xStatus)
  12.             printf("writeTask send done\n");
  13.         else
  14.             printf("writeTask send fail\n");
  15.         i++;
  16.         vTaskDelay(6000 / portTICK_PERIOD_MS); // 6s delay
  17.     }
  18. }
  19. void readTask(void *pvParam)
  20. {
  21.     QueueHandle_t Mailbox;
  22.     Mailbox = (QueueHandle_t)pvParam;
  23.     BaseType_t xStatus;
  24.     int i = 0;
  25.     while (1)
  26.     {
  27.         xStatus = xQueuePeek(Mailbox, &i,0);
  28.         if (pdPASS == xStatus)
  29.             printf("read %d\n", i);
  30.         else
  31.             printf("read fail\n");   
  32.  
  33.         vTaskDelay(1000 / portTICK_PERIOD_MS); // 1s delay
  34.     }
  35. }
  36. void app_main(void)
  37. {
  38.     QueueHandle_t Mailbox;
  39.  
  40.     Mailbox = xQueueCreate(1, sizeof(int));
  41.   
  42.     if (NULL != Mailbox) 
  43.     {
  44.         printf("Create queue successfully\n");
  45.         xTaskCreate(writeTask, "writeTask", 2048, (void *)Mailbox, 1, NULL);
  46.         xTaskCreate(readTask, "readTask1", 2048, (void *)Mailbox, 2, NULL);
  47.         xTaskCreate(readTask, "readTask2", 2048, (void *)Mailbox, 2, NULL);
  48.         xTaskCreate(readTask, "readTask3", 2048, (void *)Mailbox, 2, NULL);
  49.     }
  50.     else
  51.     {
  52.         printf("Can't crate queue!\n");
  53.     }
  54. }

10 、软件定时器

  1. #include "freertos/timers.h"
  2.  
  3. void TimerCallBack(TimerHandle_t xTimer)
  4. {
  5.     const char *strName;
  6.     int *id;
  7.     strName = pcTimerGetName(xTimer);
  8.     id = (int *)pvTimerGetTimerID(xTimer);
  9.     printf("Timer Name %s ID is %d!\n", strName, *id);
  10. }
  11.  
  12. void app_main(void)
  13. {
  14.     static int id1 = 1; // 这里要注意ID值，如果直接传入的是数字(void *)1，这里是报地址1传过去，任务中是(uint32_t)pvTimerGetTimerID(xTimer);
  15.     static int id2 = 2; // 如果是先定义ID号再去ID地址(void *)&id1传入这里出入的就是ID号的地址，但是这个ID号不能是局部变量会被销毁，要是全局变量或者是用static修饰
  16.  
  17.     TimerHandle_t xTimer1;
  18.     TimerHandle_t xTimer2;
  19.  
  20.     xTimer1 = xTimerCreate("Timer1", pdMS_TO_TICKS(1000), pdTRUE, (void *)&id1, TimerCallBack);
  21.     xTimer2 = xTimerCreate("Timer2", pdMS_TO_TICKS(2000), pdTRUE, (void *)&id2, TimerCallBack);
  22.     xTimerStart(xTimer1, 0);
  23.     xTimerStart(xTimer2, 0);
  24.  
  25.     vTaskDelay(pdMS_TO_TICKS(4000));
  26.     xTimerChangePeriod(xTimer1, pdMS_TO_TICKS(5000), 0); // 改变运行周期
  27. }

11、 信号量

11.1 二进制信号量

  • 信号量创建以后为空状态，在获取信号量之前首先要释放信号量。
  1. #include "freertos/semphr.h"
  2.  
  3. SemaphoreHandle_t semphrHandle;
  4. int iCont = 0;
  5.  
  6. void myTask1(void *pvParam)
  7. {
  8.     while (1)
  9.     {
  10.         xSemaphoreTake(semphrHandle, portMAX_DELAY);
  11.         for (int i = 0; i < 10; i++)
  12.         {
  13.             iCont++;
  14.             printf("my task1 iCont = %d\n", iCont);
  15.             vTaskDelay(pdMS_TO_TICKS(1000));
  16.         }
  17.         xSemaphoreGive(semphrHandle);
  18.         vTaskDelay(pdMS_TO_TICKS(1000));
  19.     }
  20. }
  21. void myTask2(void *pvParam)
  22. {
  23.     while (1)
  24.     {
  25.         xSemaphoreTake(semphrHandle, portMAX_DELAY);
  26.         for (int i = 0; i < 10; i++)
  27.         {
  28.             iCont++;
  29.             printf("my task2 iCont = %d\n", iCont);
  30.             vTaskDelay(pdMS_TO_TICKS(1000));
  31.         }
  32.         xSemaphoreGive(semphrHandle);
  33.         vTaskDelay(pdMS_TO_TICKS(1000));
  34.     }
  35. }
  36.  
  37. void app_main(void)
  38. {
  39.     semphrHandle = xSemaphoreCreateBinary();
  40.     xSemaphoreGive(semphrHandle);
  41.     xTaskCreate(myTask1, "myTask1", 2048, NULL, 1, NULL);
  42.     xTaskCreate(myTask2, "myTask2", 2048, NULL, 1, NULL);
  43. }

不用信号量

11.2 计数型信号量 

  1. SemaphoreHandle_t semphrHandle;
  2. int iCont = 0;
  3.  
  4. void carInTask(void *pvParam)
  5. {
  6.     int emptySpace = 0;
  7.     BaseType_t iResult;
  8.  
  9.     while (1)
  10.     {
  11.         emptySpace = uxSemaphoreGetCount(semphrHandle); //检测是否有空的车位
  12.         printf("emptySpace = %d\n", emptySpace);
  13.         iResult = xSemaphoreTake(semphrHandle, 0);  //获取一个空车位
  14.  
  15.         if (pdTRUE == iResult)
  16.         {
  17.             printf("One car in!\n");
  18.         }
  19.         else
  20.         {
  21.             printf("No Space!\n");
  22.         }
  23.         vTaskDelay(pdMS_TO_TICKS(1000));
  24.     }
  25. }
  26. void carOutTask(void *pvParam)
  27. {
  28.     while (1)
  29.     {
  30.         vTaskDelay(pdMS_TO_TICKS(6000));
  31.         xSemaphoreGive(semphrHandle);   //释放一个车位
  32.         printf("One car out!\n");
  33.     }
  34. }
  35.  
  36. void app_main(void)
  37. {
  38.     semphrHandle = xSemaphoreCreateCounting(5,5);
  39.     xSemaphoreGive(semphrHandle);
  40.     xTaskCreate(carInTask, "carInTask", 2048, NULL, 1, NULL);
  41.     xTaskCreate(carOutTask, "carOutTask", 2048, NULL, 1, NULL);
  42. }

12、互斥量 

  • 优先级别继承

  • 为什么任务1做耗时操作时有延时，这里延时的时候不会切换到空闲任务，导致触发看门狗

当task1在开始阻塞自身的时候,如果task2, task3还在处于while循环之前的阻塞状态, idle task有机会运行,一旦task2进入while循环, idle task就没有机会运行了,因为task2优先级别比task1和idle的都高, 会优先运行. 周期切换只是在task2和task3之间切换.

  • 为什么任务3获取信号量后任务1还能运行

分配的核心不一样，pintocore api把这任务放到一个核心上

  • xSemaphoreTake(mutexHandle, 1000);的1000意思

1000的tick=10000ms，也就是10s

  • 作为互斥量,不需要give,创建后可以直接拿到.

在task3拿到mutex后, 任务只会在task2和task3之间切换,连task1都不会有机会执行. 因为 task2的while循环中没有阻塞自己,只有高优先级别的task3才可以有机会运行. 空闲任务的优先级别是0, 比task1低, 更加不执行. 不过, 如果不是用mutex, 而是用二进制信号量的时候, 在创建二进制信号量的时候,还应该give释放一下信号量才行. 否则,task1拿不到二进制信号量, 但是, 作为互斥量,不需要give,创建后可以直接拿到.

  1. SemaphoreHandle_t mutexHandle;
  2.  
  3. void Task1(void *pvParam)
  4. {
  5.     BaseType_t iRet;
  6.     while (1)
  7.     {
  8.         printf("Task1 begin!\n");
  9.         iRet = xSemaphoreTake(mutexHandle,1000);
  10.         if(iRet == pdPASS)
  11.         {
  12.             printf("Task1 take!\n");
  13.             for (int i = 0; i < 50; i++)
  14.             {
  15.                 printf("Task1 i =%d\n", i);
  16.                 vTaskDelay(pdMS_TO_TICKS(1000));
  17.             }
  18.             xSemaphoreGive(mutexHandle);
  19.             printf("Task1 give!\n");
  20.             vTaskDelay(pdMS_TO_TICKS(5000));
  21.  
  22.         }
  23.         else
  24.         {
  25.             printf("Task1 didn't take!\n");
  26.             vTaskDelay(pdMS_TO_TICKS(1000));
  27.         }
  28.     }
  29.     
  30. }
  31. void Task2(void *pvParam)
  32. {
  33.     printf("Task2 begin!\n");
  34.     vTaskDelay(pdMS_TO_TICKS(1000));    //阻塞Task2让Task1运行
  35.     while (1)
  36.     {
  37.         ;
  38.     }
  39.     
  40. }
  41. void Task3(void *pvParam)
  42. {
  43.     printf("Task3 begin!\n");
  44.     vTaskDelay(pdMS_TO_TICKS(1000));    //阻塞Task3让Task2运行
  45.     BaseType_t iResult;
  46.  
  47.     while (1)
  48.     {
  49.         iResult = xSemaphoreTake(mutexHandle, 1000);//1000的tick=10000ms，也就是10s
  50.         if (pdPASS == iResult)
  51.         {
  52.             printf("Task3 take!\n");
  53.             for (int i = 0; i < 10; i++)
  54.             {
  55.                 printf("Task3 i =%d\n", i);
  56.                 vTaskDelay(pdMS_TO_TICKS(1000));
  57.             }
  58.             xSemaphoreGive(mutexHandle);
  59.             printf("Task3 give!\n");
  60.             vTaskDelay(pdMS_TO_TICKS(5000));
  61.         } 
  62.         else
  63.         {
  64.             printf("Task3 didn't take!\n");
  65.             vTaskDelay(pdMS_TO_TICKS(1000));
  66.         }
  67.     }
  68. }
  69.  
  70. void app_main(void)
  71. {
  72.     mutexHandle = xSemaphoreCreateMutex();
  73.     // mutexHandle = xSemaphoreCreateBinary();
  74.     // xSemaphoreGive(mutexHandle);
  75.  
  76.   
  77.     vTaskSuspendAll(); // 任务调度器挂起
  78.  
  79.     xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL,0);
  80.     xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 2, NULL,0);
  81.     xTaskCreatePinnedToCore(Task3, "Task3", 2048, NULL, 3, NULL,0);
  82.  
  83.     xTaskResumeAll(); // 恢复任务调度器
  84. }

13 、递归互斥量

  1. void Task1(void *pvParam)
  2. {
  3.     BaseType_t iRet;
  4.     while (1)
  5.     {
  6.         printf("-------------\n");
  7.         printf("task1 begin\n");
  8.         xSemaphoreTakeRecursive(mutexHandle, portMAX_DELAY); // 获得一个递归锁\取得资源A
  9.         printf("task1 task A\n");
  10.  
  11.         for (int i = 0; i < 4; i++)
  12.         {
  13.             printf("task1 i =%d for A\n", i);
  14.             vTaskDelay(pdMS_TO_TICKS(1000));
  15.         }
  16.  
  17.         xSemaphoreTakeRecursive(mutexHandle, portMAX_DELAY); // 获得一个递归锁\取得资源B
  18.         printf("task1 task B\n");
  19.         for (int i = 0; i < 4; i++)
  20.         {
  21.             printf("task1 i =%d for B\n", i);
  22.             vTaskDelay(pdMS_TO_TICKS(1000));
  23.         }
  24.  
  25.         printf("task1 give B\n");
  26.         
  27.         xSemaphoreGiveRecursive(mutexHandle); // 释放一个锁
  28.         vTaskDelay(pdMS_TO_TICKS(3000));
  29.  
  30.         printf("task1 give A\n");
  31.         xSemaphoreGiveRecursive(mutexHandle); // 释放一个锁，即要释放两次锁另外一个任务才能得到锁
  32.         vTaskDelay(pdMS_TO_TICKS(3000));
  33.     }
  34. }
  35. void Task2(void *pvParam)
  36. {
  37.  
  38.     vTaskDelay(pdMS_TO_TICKS(1000)); // 阻塞Task2先让Task1运行得到互斥锁
  39.     while (1)
  40.     {
  41.         printf("-------------\n");
  42.         printf("task2 begin\n");
  43.         xSemaphoreTakeRecursive(mutexHandle, portMAX_DELAY); // 获得一个递归锁\取得资源A
  44.         printf("task2 task A\n");
  45.  
  46.         for (int i = 0; i < 4; i++)
  47.         {
  48.             printf("task2 i =%d for A\n", i);
  49.             vTaskDelay(pdMS_TO_TICKS(1000));
  50.         }
  51.         printf("task2 give A\n");
  52.         
  53.         xSemaphoreGiveRecursive(mutexHandle);
  54.         vTaskDelay(pdMS_TO_TICKS(3000));
  55.     }
  56. }
  57. void app_main(void)
  58. {
  59.     mutexHandle = xSemaphoreCreateRecursiveMutex();
  60.  
  61.     vTaskSuspendAll(); // 任务调度器挂起
  62.  
  63.     xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  64.     xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 2, NULL, 0);
  65.  
  66.     xTaskResumeAll(); // 恢复任务调度器
  67. }

14、 事件组

14.1 事件组的等待

  1. #include "freertos/event_groups.h"
  2. #define BIT_0 (1 << 0)
  3. #define BIT_4 (1 << 4)
  4.  
  5. EventGroupHandle_t xCreatedEventGroup;
  6.  
  7. void Task1(void *pvParam)
  8. {
  9.  
  10.     while (1)
  11.     {
  12.         printf("Task1 begin to wait!\n");
  13.         xEventGroupWaitBits(xCreatedEventGroup, BIT_0 | BIT_4, pdTRUE, pdTRUE, portMAX_DELAY);
  14.         printf("Task1 BIT_0 AND BIT_4 is set!\n");
  15.         vTaskDelay(pdMS_TO_TICKS(1000));
  16.     }
  17. }
  18. void Task2(void *pvParam)
  19. {
  20.  
  21.     vTaskDelay(pdMS_TO_TICKS(1000)); // 阻塞Task2先让Task1运行得到互斥锁
  22.     while (1)
  23.     {
  24.         printf("Task2 begin to set bit0!\n");
  25.         xEventGroupSetBits(xCreatedEventGroup,BIT_0);
  26.         vTaskDelay(pdMS_TO_TICKS(5000));
  27.         printf("Task2 begin to set bit4!\n");
  28.         xEventGroupSetBits(xCreatedEventGroup,BIT_4);
  29.         vTaskDelay(pdMS_TO_TICKS(5000));
  30.     }
  31. }
  32. void app_main(void)
  33. {
  34.     xCreatedEventGroup = xEventGroupCreate();
  35.     if (xCreatedEventGroup == NULL)
  36.     {
  37.         printf("Event group creat fail!\n");
  38.     }
  39.     else
  40.     {
  41.         vTaskSuspendAll();
  42.  
  43.         xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  44.         xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 2, NULL, 0);
  45.  
  46.         xTaskResumeAll();
  47.     }
  48. }

14.2 事件组的同步

每个任务设置完自身一个位后进入阻塞态，只有但每个任务都设置完后三个任务才会一起开始运行。事件组的等待中是设置任务设置完后就继续执行自己的任务。

  1. #include "freertos/event_groups.h"
  2. #define TASK_BIT_0 (1 << 0)
  3. #define TASK_BIT_1 (1 << 1)
  4. #define TASK_BIT_2 (1 << 2)
  5.  
  6. #define ALL_SYNC_BITS (TASK_BIT_0 | TASK_BIT_1 | TASK_BIT_2)
  7.  
  8. EventGroupHandle_t xEventBits;
  9.  
  10. void Task0(void *pvParam)
  11. {
  12.     while (1)
  13.     {
  14.         printf("task0 begin\n");
  15.         vTaskDelay(pdMS_TO_TICKS(1000));
  16.         printf("task0 set bit0\n");
  17.         xEventGroupSync(xEventBits, TASK_BIT_0, ALL_SYNC_BITS, portMAX_DELAY);
  18.         printf("task0 sync\n");
  19.         vTaskDelay(pdMS_TO_TICKS(10000));
  20.     }
  21. }
  22. void Task1(void *pvParam)
  23. {
  24.     while (1)
  25.     {
  26.         printf("task1 begin\n");
  27.         vTaskDelay(pdMS_TO_TICKS(3000));
  28.         printf("task1 set bit1\n");
  29.         xEventGroupSync(xEventBits, TASK_BIT_1, ALL_SYNC_BITS, portMAX_DELAY);
  30.         printf("task1 sync\n");
  31.         vTaskDelay(pdMS_TO_TICKS(10000));
  32.     }
  33. }
  34. void Task2(void *pvParam)
  35. {
  36.  
  37.     while (1)
  38.     {
  39.         printf("task2 begin\n");
  40.         vTaskDelay(pdMS_TO_TICKS(5000));
  41.         printf("task2 set bit1\n");
  42.         xEventGroupSync(xEventBits, TASK_BIT_2, ALL_SYNC_BITS, portMAX_DELAY);
  43.         printf("task2 sync\n");
  44.         vTaskDelay(pdMS_TO_TICKS(10000));
  45.     }
  46. }
  47. void app_main(void)
  48. {
  49.     xEventBits = xEventGroupCreate();
  50.     if (xEventBits == NULL)
  51.     {
  52.         printf("Event group create fail\n");
  53.     }
  54.     else
  55.     {
  56.         vTaskSuspendAll();
  57.  
  58.         xTaskCreatePinnedToCore(Task0, "Task0", 2048, NULL, 1, NULL, 0);
  59.         xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  60.         xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  61.         
  62.         xTaskResumeAll();
  63.     }
  64. }

 15、通知

15.1 通知同步

  1. TaskHandle_t xTask1 = NULL;
  2.  
  3. void Task1(void *pvParam)
  4. {
  5.     while (1)
  6.     {
  7.         printf("--------------\n");
  8.         printf("task1 wait notification!\n");
  9.         ulTaskNotifyTake(pdTRUE, portMAX_DELAY);
  10.         printf("--------------\n");
  11.         printf("task1 got notification!\n");
  12.         vTaskDelay(pdMS_TO_TICKS(3000));
  13.     }
  14. }
  15. void Task2(void *pvParam)
  16. {
  17.     while (1)
  18.     {
  19.         vTaskDelay(pdMS_TO_TICKS(5000));
  20.         printf("--------------\n");
  21.         printf("task2 notify task1!\n");
  22.         xTaskNotifyGive(xTask1);
  23.     }
  24. }
  25. void app_main(void)
  26. {
  27.  
  28.     vTaskSuspendAll();
  29.     xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, &xTask1, 0);
  30.     xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  31.     xTaskResumeAll();
  32. }

15.2 通知值

  1. TaskHandle_t xTask1 = NULL;
  2.  
  3. void Task1(void *pvParam)
  4. {
  5.     uint32_t ulNotifiedValue;
  6.     while (1)
  7.     {
  8.         printf("--------------\n");
  9.         printf("task1 wait notification!\n");
  10.         xTaskNotifyWait(0x00, ULONG_MAX, &ulNotifiedValue, portMAX_DELAY); // 进入该函数时不清除任何通知的位,退出该函数时将通知的值全部Reset为0,用于刚保存通知的值,无限循环等待
  11.         if ((ulNotifiedValue & 0x01) != 0)
  12.         {
  13.             printf("task1 process bit0 event!\n");
  14.         }
  15.         if ((ulNotifiedValue & 0x02) != 0)
  16.         {
  17.             printf("task1 process bit1 event!\n");
  18.         }
  19.         if ((ulNotifiedValue & 0x04) != 0)
  20.         {
  21.             printf("task1 process bit2 event!\n");
  22.         }
  23.         printf("--------------\n");
  24.         vTaskDelay(pdMS_TO_TICKS(3000));
  25.     }
  26. }
  27. void Task2(void *pvParam)
  28. {
  29.     while (1)
  30.     {
  31.         vTaskDelay(pdMS_TO_TICKS(5000));
  32.         printf("--------------\n");
  33.         printf("task2 notify task1 bit0!\n");
  34.         xTaskNotify(xTask1, 0x01, eSetValueWithoutOverwrite);
  35.         vTaskDelay(pdMS_TO_TICKS(5000));
  36.         printf("--------------\n");
  37.         printf("task2 notify task1 bit1!\n");
  38.         xTaskNotify(xTask1, 0x02, eSetValueWithoutOverwrite);
  39.         vTaskDelay(pdMS_TO_TICKS(5000));
  40.         printf("--------------\n");
  41.         printf("task2 notify task1 bit2!\n");
  42.         xTaskNotify(xTask1, 0x04, eSetValueWithoutOverwrite);
  43.         vTaskDelay(pdMS_TO_TICKS(5000));
  44.     }
  45. }
  46. void app_main(void)
  47. {
  48.  
  49.     vTaskSuspendAll();
  50.     xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, &xTask1, 0);
  51.     xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  52.     xTaskResumeAll();
  53. }

16、流数据缓冲区

16.1 数据流缓冲区

  • 如果把vTaskDelay(pdMS_TO_TICKS(3000));放后面  一发送就会接收到数据，不是等超过100个；

因为在第一次发送数据的时候接收数据任务并没有进入阻塞状态，任务一优先运行把数据发送到StreamBuff中，任务二还没有进入阻塞状态一调用xStreamBufferReceive就会把所有数据接收下来，然后再进入阻塞状态等待发送数据超过100个字节解除阻塞。 把 vTaskDelay(pdMS_TO_TICKS(3000))提前就会让接收数据任务提前运行此时发送任务并还没有发送数据没有要在进入阻塞状态前要接收的数据，然后接收任务进入阻塞态。

16.2 确定数据流缓冲区的大小

  • 用一个任务监测空闲buff的大小

  1. void Task1(void *pvParam)
  2. {
  3.     char tx_buf[50];
  4.     int i = 0;
  5.     int srt_len = 0;
  6.     int send_bytes = 0;
  7.     while (1)
  8.     {
  9.         vTaskDelay(pdMS_TO_TICKS(3000));
  10.         i++;
  11.         srt_len = sprintf(tx_buf, "Hello,I am LittleOne %d!", i);
  12.         send_bytes = xStreamBufferSend(StreamBuff, (void *)tx_buf, srt_len, portMAX_DELAY);
  13.         printf("--------------\n");
  14.         printf("Send: srt_len = %d,send_bytes = %d!\n", srt_len, send_bytes);
  15.     }
  16. }
  17. void Task2(void *pvParam)
  18. {
  19.     char rx_buf[50];
  20.     int rec_bytes = 0;
  21.     while (1)
  22.     {
  23.         memset(rx_buf, 0, sizeof(rx_buf)); // 初始化数组内容为0
  24.         rec_bytes = xStreamBufferReceive(StreamBuff, (void *)rx_buf, sizeof(rx_buf), portMAX_DELAY);
  25.         printf("--------------\n");
  26.         printf("Receive:%s,rec_bytes = %d!\n", rx_buf, rec_bytes);
  27.     }
  28. }
  29. void Task3(void *pvParam)
  30. {
  31.     int buf_space = 0;
  32.     int min_space = 1000;
  33.     while (1)
  34.     {
  35.         buf_space = xStreamBufferSpacesAvailable(StreamBuff);
  36.         if (buf_space < min_space )
  37.             min_space = buf_space;
  38.         printf("--------------\n");
  39.         printf("buf_space %d,min_space %d!\n", buf_space, min_space);
  40.         vTaskDelay(pdMS_TO_TICKS(3000));
  41.     }
  42. }
  43. void app_main(void)
  44. {
  45.     StreamBuff = xStreamBufferCreate(1000, 100); // 接收字节超过100个就会解除接收数据的阻塞。
  46.     if (NULL != StreamBuff)
  47.     {
  48.         vTaskSuspendAll();
  49.         xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  50.         xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  51.         xTaskCreatePinnedToCore(Task3, "Task3", 2048, NULL, 1, NULL, 0);
  52.         xTaskResumeAll();
  53.     }
  54.     else
  55.     {
  56.         printf("Fail to creat buff fail!\n");
  57.     }
  58. }

17、 消息缓冲区

17.1 与数据流的区别1

  • 一次只能接收一条完整的Message,没有流数据中触发阈值的概念，尽管接收buff很大一次也只能接收一条Message;
  1. #include "freertos/message_buffer.h"
  2. #include <string.h>
  3.  
  4. TaskHandle_t xTask1 = NULL;
  5. MessageBufferHandle_t MessageBufferHandle = NULL;
  6.  
  7. void Task1(void *pvParam)
  8. {
  9.     char tx_buf[50];
  10.     int srt_len = 0;
  11.     int send_bytes = 0;
  12.     for (int i = 0; i < 3; i++)
  13.     {
  14.         srt_len = sprintf(tx_buf, "Hello,I am Message %d!", i);
  15.         send_bytes = xMessageBufferSend(MessageBufferHandle, (void *)tx_buf, srt_len, portMAX_DELAY);
  16.         printf("--------------\n");
  17.         printf("Send: i = %d,send_bytes = %d!\n", i, send_bytes);
  18.     }
  19.     vTaskDelete(NULL);
  20. }
  21. void Task2(void *pvParam)
  22. {
  23.     char rx_buf[100];
  24.     int rec_bytes = 0;
  25.  
  26.     vTaskDelay(pdMS_TO_TICKS(3000));
  27.     while (1)
  28.     {
  29.         memset(rx_buf, 0, sizeof(rx_buf)); // 初始化数组内容为0
  30.         rec_bytes = xMessageBufferReceive(MessageBufferHandle, (void *)rx_buf, sizeof(rx_buf), portMAX_DELAY);
  31.         printf("--------------\n");
  32.         printf("Receive:%s,rec_bytes = %d!\n", rx_buf, rec_bytes);
  33.         vTaskDelay(pdMS_TO_TICKS(1000));
  34.     }
  35. }
  36.  
  37. void app_main(void)
  38. {
  39.     MessageBufferHandle = xMessageBufferCreate(1000);
  40.     if (NULL != MessageBufferHandle)
  41.     {
  42.         vTaskSuspendAll();
  43.         xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  44.         xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  45.         xTaskResumeAll();
  46.     }
  47.     else
  48.     {
  49.         printf("Fail to creat buff fail!\n");
  50.     }
  51. }

17.1 与数据流的区别2 

  • 流数据缓冲区的接收buff即使小于一条消息的数据长度也能打印出接收buff大小的数据，而消息缓冲区会是返回0；

  • 流数据
  1. #include "freertos/stream_buffer.h"
  2. #include <string.h>
  3.  
  4. TaskHandle_t xTask1 = NULL;
  5.  
  6. StreamBufferHandle_t StreamBufferHandle = NULL;
  7.  
  8. void Task1(void *pvParam)
  9. {
  10.     char tx_buf[50];
  11.     int srt_len = 0;
  12.     int send_bytes = 0;
  13.     for (int i = 0; i < 3; i++)
  14.     {
  15.         srt_len = sprintf(tx_buf, "Hello,I am Stream %d!", i);
  16.         send_bytes = xStreamBufferSend(StreamBufferHandle, (void *)tx_buf, srt_len, portMAX_DELAY);
  17.         printf("--------------\n");
  18.         printf("Send: i = %d,send_bytes = %d!\n", i, send_bytes);
  19.     }
  20.     vTaskDelete(NULL);
  21. }
  22. void Task2(void *pvParam)
  23. {
  24.     char rx_buf[10];
  25.     int rec_bytes = 0;
  26.  
  27.     vTaskDelay(pdMS_TO_TICKS(3000));
  28.     while (1)
  29.     {
  30.         memset(rx_buf, 0, sizeof(rx_buf)); // 初始化数组内容为0
  31.         rec_bytes = xStreamBufferReceive(StreamBufferHandle, (void *)rx_buf, sizeof(rx_buf), portMAX_DELAY);
  32.         printf("--------------\n");
  33.         printf("Receive:%s,rec_bytes = %d!\n", rx_buf, rec_bytes);
  34.         vTaskDelay(pdMS_TO_TICKS(1000));
  35.     }
  36. }
  37.  
  38. void app_main(void)
  39. {
  40.     StreamBufferHandle = xStreamBufferCreate(1000,10);
  41.     if (NULL != StreamBufferHandle)
  42.     {
  43.         vTaskSuspendAll();
  44.         xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  45.         xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  46.         xTaskResumeAll();
  47.     }
  48.     else
  49.     {
  50.         printf("Fail to creat buff fail!\n");
  51.     }
  52. }

  • 消息缓冲
  1. #include "freertos/message_buffer.h"
  2. #include <string.h>
  3.  
  4. TaskHandle_t xTask1 = NULL;
  5. MessageBufferHandle_t MessageBufferHandle = NULL;
  6.  
  7. void Task1(void *pvParam)
  8. {
  9.     char tx_buf[50];
  10.     int srt_len = 0;
  11.     int send_bytes = 0;
  12.     for (int i = 0; i < 3; i++)
  13.     {
  14.         srt_len = sprintf(tx_buf, "Hello,I am Message %d!", i);
  15.         send_bytes = xMessageBufferSend(MessageBufferHandle, (void *)tx_buf, srt_len, portMAX_DELAY);
  16.         printf("--------------\n");
  17.         printf("Send: i = %d,send_bytes = %d!\n", i, send_bytes);
  18.     }
  19.     vTaskDelete(NULL);
  20. }
  21. void Task2(void *pvParam)
  22. {
  23.     char rx_buf[10];
  24.     int rec_bytes = 0;
  25.  
  26.     vTaskDelay(pdMS_TO_TICKS(3000));
  27.     while (1)
  28.     {
  29.         memset(rx_buf, 0, sizeof(rx_buf)); // 初始化数组内容为0
  30.         rec_bytes = xMessageBufferReceive(MessageBufferHandle, (void *)rx_buf, sizeof(rx_buf), portMAX_DELAY);
  31.         printf("--------------\n");
  32.         printf("Receive:%s,rec_bytes = %d!\n", rx_buf, rec_bytes);
  33.         vTaskDelay(pdMS_TO_TICKS(1000));
  34.     }
  35. }
  36.  
  37. void app_main(void)
  38. {
  39.     MessageBufferHandle = xMessageBufferCreate(1000);
  40.     if (NULL != MessageBufferHandle)
  41.     {
  42.         vTaskSuspendAll();
  43.         xTaskCreatePinnedToCore(Task1, "Task1", 2048, NULL, 1, NULL, 0);
  44.         xTaskCreatePinnedToCore(Task2, "Task2", 2048, NULL, 1, NULL, 0);
  45.         xTaskResumeAll();
  46.     }
  47.     else
  48.     {
  49.         printf("Fail to creat buff fail!\n");
  50.     }
  51. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小舞很执着/article/detail/875997
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号