#include "FreeRTOS.h"
#include "task.h"
#include "queue.h"

// 定义一个消息类型
typedef struct aMessage {
    int value;
} Message;

// 定义消息队列
QueueHandle_t xQueue;

// 任务1: 发送消息到队列
void vTaskOne(void *pvParameters) {
    Message xMessage;
    int xValue = 0;

    for (;;) {
        // 创建一个消息
        xMessage.value = xValue++;

        // 发送消息到队列
        if (xQueueSend(xQueue, &xMessage, (TickType_t)10) != pdPASS) {
            // 发送失败
            printf("Failed to send message.\n");
        }
        vTaskDelay(pdMS_TO_TICKS(100));
    }
}

// 任务2: 从队列中接收消息
void vTaskTwo(void *pvParameters) {
    Message xMessage;

    for (;;) {
        // 从队列中接收消息
        if (xQueueReceive(xQueue, &xMessage, (TickType_t)10) == pdTRUE) {
            // 处理消息
            printf("Received message: %d\n", xMessage.value);
        } else {
            // 接收失败
            printf("Failed to receive message.\n");
        }
    }
}

// 主函数
int main(void) {
    // 创建消息队列
    xQueue = xQueueCreate(10, sizeof(Message));
    configASSERT(xQueue);

    // 创建任务
    xTaskCreate(vTaskOne, "Task One", configMINIMAL_STACK_SIZE + 100, NULL, tskIDLE_PRIORITY + 1, NULL);
    xTaskCreate(vTaskTwo, "Task Two", configMINIMAL_STACK_SIZE + 100, NULL, tskIDLE_PRIORITY + 2, NULL);

    // 启动FreeRTOS内核
    vTaskStartScheduler();

    // 如果vTaskStartScheduler()无法启动内核，则无限循环
    for (;;) {}
}