ESP32: ESP32_xQueue.ino

#include<Arduino.h>
# To make it work, we need to 
# 1. change Line 34 & 35 to increase stack from 1024 to 1500
# 2. change Line 24 Queue size from 10 to 50 


QueueHandle_t     qu_task;
TaskHandle_t xHandle = NULL;

void vGetQueueTask(void *pvParameters){
  int getvalue = 0;
  while(true){
    if (xQueueReceive(qu_task, &getvalue, 0)) {
       Serial.println("Queue get: " + String(getvalue));
    }
    vTaskDelay(2000 / portTICK_PERIOD_MS);
  }
}
void vPutQueueTask(void * pvParameters){
   int value = 0;
   while(true){
       xQueueSend(qu_task, &value, 0);
       Serial.println("Queue put: " + String(value));
       if (value == 10) {
         break;
       }
       value++;
       vTaskDelay(500 / portTICK_PERIOD_MS);
   }
   vTaskDelete(xHandle);
}

void setup() {
  Serial.begin(115200);
  qu_task = xQueueCreate(10, sizeof(int));
  xTaskCreate(vGetQueueTask, "vGetQueueTask", 1024, NULL, tskIDLE_PRIORITY - 1, NULL);
  xTaskCreate(vPutQueueTask, "vPutQueueTask", 1024, NULL, tskIDLE_PRIORITY - 2, &xHandle);
}

void loop() {}