[FreeRTOS 功能应用] 事件组功能应用

news2024/9/22 9:40:04

文章目录

- 一、基础知识点
- 二、代码讲解
- 三、结果演示
- 四、代码下载

一、基础知识点

[FreeRTOS 基础知识] 事件组概念
[FreeRTOS 内部实现] 事件组

本实验是基于STM32F103开发移植FreeRTOS实时操作系统，事件组实战操作。(当task1和task2同时完成，才执行task3)
使用工具：Keil、串口工具

二、代码讲解

1、使用xEventGroupCreate函数创建事件组

// 路径：项目\Core\Src\freertos.c
// 全局变量
EventGroupHandle_t g_EventGroup;
g_EventGroup = xEventGroupCreate ( );

2、使用osThreadCreate创建三个任务

// 创建两个任务
osThreadDef(Task1, vTask_a, osPriorityHigh, 0, 1000);
Task1_Handle = osThreadCreate(osThread(Task1), NULL);
if( Task1_Handle != NULL )
{
	printf("Succeeded in creating Sender1_Handle Queue. Procedure!\n\r");
}
else
{
	printf("Fail in creating Sender1_Handle Queue. Procedure!\n\r");
}

osThreadDef(Task2, vTask_b, osPriorityNormal, 0, 1000);
Task2_Handle = osThreadCreate(osThread(Task2), NULL);		
if( Task2_Handle != NULL )
{
	printf("Succeeded in creating Seceiver_Handle Queue. Procedure!\n\r");
}
else
{
	printf("Fail in creating Seceiver_Handle Queue. Procedure!\n\r");
}		

osThreadDef(Task3, vTask_c, osPriorityNormal, 0, 1000);
Task3_Handle = osThreadCreate(osThread(Task3), NULL);		
if( Task3_Handle != NULL )
{
	printf("Succeeded in creating Seceiver_Handle Queue. Procedure!\n\r");
}
else
{
	printf("Fail in creating Seceiver_Handle Queue. Procedure!\n\r");
}

函数中通过osThreadDef 宏构建osThreadDef_t 结构体，名称os_thread_def_##name（## 表示字符拼接），结构体成员包括：#name 任务名称；thread 任务处理函数；priority 任务优先级；instances 实例； stacksz 栈大小；

#define osThreadDef(name, thread, priority, instances, stacksz)  \
const osThreadDef_t os_thread_def_##name = \
{ #name, (thread), (priority), (instances), (stacksz), NULL, NULL }

将构建的osThreadDef_t 结构体传入osThreadCreate函数中，实际调用xTaskCreate函数创建任务。

osThreadId osThreadCreate (const osThreadDef_t *thread_def, void *argument)
{
  	TaskHandle_t handle;
    if (xTaskCreate((TaskFunction_t)thread_def->pthread,(const portCHAR *)thread_def->name,
              thread_def->stacksize, argument, makeFreeRtosPriority(thread_def->tpriority),
              &handle) != pdPASS)  {
      return NULL;
    } 
    return handle;
}

任务实现：task1完成后执行task2；当task1和task2都完成后执行task3

3、task1任务函数vTask_a实现

void vTask_a(void const * argument)
{
  for(;;)
  {
		xEventGroupSetBits(g_EventGroup, EVENT_A);
		printf("DWB -- vTask_a \n\r");
		xEventGroupWaitBits(g_EventGroup, EVENT_C, TRUE, TRUE, pdMS_TO_TICKS(10));
		vTaskDelay(pdMS_TO_TICKS(250));   // 延时250ms
	}	
}

通过xEventGroupSetBits函数，设置 g_EventGroup 结构体中的事件状态标志位，表示task1执行完成。
通过xEventGroupWaitBits函数，等待task3完成后清除标志位并执行。（EVENT_C）

4、task2任务函数vTask_b实现

void vTask_b(void const * argument)
{
  for(;;)
  {
		xEventGroupWaitBits(g_EventGroup, EVENT_A, FAILED, TRUE, pdMS_TO_TICKS(10));
		xEventGroupSetBits(g_EventGroup, EVENT_B);
		printf("DWB -- vTask_b \n\r");
		vTaskDelay(pdMS_TO_TICKS(300));   // 延时300ms
	}	
}

通过xEventGroupWaitBits函数，等待task1完成后不清除标志位并执行。（EVENT_A）
通过xEventGroupSetBits函数，设置 g_EventGroup 结构体中的事件状态标志位，表示task2执行完成。

5、task3任务函数vTask_c实现

void vTask_c(void const * argument)
{
  for(;;)
  {
		xEventGroupWaitBits(g_EventGroup, EVENT_A|EVENT_B, TRUE, TRUE, pdMS_TO_TICKS(10));
		xEventGroupSetBits(g_EventGroup, EVENT_C);
		printf("DWB -- vTask_c \n\r");
		vTaskDelay(pdMS_TO_TICKS(300));   // 延时300ms
	}	
}