#include <Arduino.h>
#include <WiFi.h>

// 任务函数原型
void task0(void *pvParam);
void task1(void *pvParam);

void setup() {
  Serial.begin(115200);
  // 创建核心0任务
  xTaskCreatePinnedToCore(
    task0,    // 任务函数
    "Core0_Task",   // 任务名称
    10000,          // 堆栈大小(字节)
    NULL,           // 参数
    1,              // 优先级
    NULL,           // 任务句柄
    0               // 核心编号
  );

  // 创建核心1任务
  xTaskCreatePinnedToCore(
    task1,    
    "Core1_Task",   
    10000,          
    NULL,           
    1,              
    NULL,           
    1               
  );
}

void loop() {
  // ...
  vTaskDelay(10 / portTICK_PERIOD_MS);
} 

void task0(void *pvParam) {
  while(1) {
    Serial.printf("[Core0] WiFi信号强度: %d dBm\n", WiFi.RSSI());
    vTaskDelay(2000 / portTICK_PERIOD_MS);
  }
}

void task1(void *pvParam) {
  while(1) {
    Serial.println("[Core1] 执行");
    digitalWrite(4, HIGH);
    vTaskDelay(500 / portTICK_PERIOD_MS);
    digitalWrite(4, LOW);
    vTaskDelay(500 / portTICK_PERIOD_MS);
  }
}

// 消息队列
QueueHandle_t xQueue = xQueueCreate(5, sizeof(int));

void task0(void *pvParam) {
  int data = 0;
  while(1) {
    data = (data==1 ? 0 : 1);
    // 发送数据到队列
    xQueueSend(xQueue, &data, portMAX_DELAY);
    vTaskDelay(500 / portTICK_PERIOD_MS);
  }
}

void task1(void *pvParam) {
  while(1) {
    int received;
    // 从队列接收数据
    if(xQueueReceive(xQueue, &received, 100/portTICK_PERIOD_MS) == pdTRUE){
        Serial.printf("接收到数据: %d\n", received);
        digitalWrite(4, received);
    }
  }
}