This program creates a queue with space for 1 integer. The receiver task waits up to 300 ticks for data. The sender task tries to send data with a 200 tick timeout. The receiver starts first and waits, then the sender sends data. The output shows the blocking behavior with timeout.
#include "FreeRTOS.h"
#include "task.h"
#include "queue.h"
#include <stdio.h>
QueueHandle_t xQueue;
void vSenderTask(void *pvParameters) {
int data_to_send = 100;
BaseType_t send_result;
printf("Sender: Trying to send data %d with 200 tick timeout...\n", data_to_send);
send_result = xQueueSend(xQueue, &data_to_send, 200);
if (send_result == pdTRUE) {
printf("Sender: Data sent successfully.\n");
} else {
printf("Sender: Failed to send data (timeout).\n");
}
vTaskDelete(NULL);
}
void vReceiverTask(void *pvParameters) {
int received_data = 0;
BaseType_t receive_result;
printf("Receiver: Waiting to receive data with 300 tick timeout...\n");
receive_result = xQueueReceive(xQueue, &received_data, 300);
if (receive_result == pdTRUE) {
printf("Receiver: Received data: %d\n", received_data);
} else {
printf("Receiver: Failed to receive data (timeout).\n");
}
vTaskDelete(NULL);
}
int main(void) {
xQueue = xQueueCreate(1, sizeof(int));
if (xQueue == NULL) {
printf("Failed to create queue.\n");
return 1;
}
printf("Queue created with length 1.\n");
xTaskCreate(vReceiverTask, "Receiver", configMINIMAL_STACK_SIZE, NULL, 1, NULL);
vTaskDelay(50); // Delay to ensure receiver starts first
xTaskCreate(vSenderTask, "Sender", configMINIMAL_STACK_SIZE, NULL, 1, NULL);
vTaskStartScheduler();
// Should never reach here
printf("Scheduler ended unexpectedly.\n");
return 0;
}
