FreeRTOS简单内核实现7 阻塞链表

freertos · 浏览次数 : 0

小编点评

思考一:为了处理进入阻塞状态的任务,我们可以采取以下措施: 1. 创建多个就绪链表,每个就绪链表代表一个优先级。 2. 对于阻塞状态的任务,需要将其从就绪链表中移除。 3. 阻塞状态的任务在一段时间内可能恢复,因此需要创建一个阻塞链表来存放这些任务。 4. 当滴答定时器计数值发生溢出时,需要切换到溢出阻塞链表,以保证处理的是正确的阻塞链表。 思考二:为了处理xTicksToDelay变量的溢出问题,我们可以采取以下措施: 1. 定义一个32位的变量xNextTaskUnblockTime,用于表示任务下次解除阻塞的时间。 2. 使用xNextTaskUnblockTime变量来计算任务的下次解除阻塞时间,如下所示:xNextTaskUnblockTime = xConstTickCount + xTicksToWait; 3. 为了避免溢出,我们需要再定义一个溢出阻塞链表,用于存放所有下次解除阻塞时间溢出的任务。 4. 在滴答定时器中断服务函数中,如果发现滴答定时器计数值全局变量溢出,就通过链表指针将两个链表交换,保证永远处理的是正确的阻塞链表。 通过以上措施,我们可以实现在支持多优先级的RTOS中正确处理进入阻塞状态的任务和避免xTicksToDelay变量的溢出问题。

正文

0、思考与回答

0.1、思考一

如何处理进入阻塞状态的任务?

为了让 RTOS 支持多优先级,我们创建了多个就绪链表(数组形式),用每一个就绪链表表示一个优先级,对于阻塞状态的任务显然要从就绪链表中移除,但是阻塞状态的任务并不是永久阻塞了,等待一段时间后应该从阻塞状态恢复,所以我们需要创建一个阻塞链表用来存放进入阻塞状态的任务

0.2、思考二

还有一个问题,xTicksToDelay 是一个 32 位的变量,如何处理其潜在的溢出问题?

假设使用一个 32 位的 xNextTaskUnblockTime 变量表示任务下次解除阻塞的时间,其一般应该由如下所示的程序代码计算

// 任务下次解除阻塞的时间 = 当前滴答定时器计数值 + 要延时的滴答次数
xNextTaskUnblockTime = xConstTickCount + xTicksToWait;

可以看出 xNextTaskUnblockTime 变量随着运行时间流逝存在溢出风险,因此我们需要再定义一个溢出阻塞链表用来存放所有下次解除阻塞的时间溢出的任务,这样我们就拥有两个阻塞链表,在滴答定时器中断服务函数中如果一旦发现滴答定时器计数值全局变量溢出,就通过链表指针将这两个链表交换,保证永远处理的是正确的阻塞链表

1、阻塞链表

1.1、定义

/* task.c */
// 阻塞链表和其指针
static List_t xDelayed_Task_List1;
static List_t volatile *pxDelayed_Task_List;
// 溢出阻塞链表和其指针
static List_t xDelayed_Task_List2;
static List_t volatile *pxOverflow_Delayed_Task_List;

1.2、prvInitialiseTaskLists( )

由于新增加了阻塞链表和溢出阻塞链表,因此在链表初始化函数中除了需要初始化就绪链表数组外,还需要增加对阻塞链表和溢出阻塞链表的初始化操作,如下所示

/* task.c */
// 就绪列表初始化函数
void prvInitialiseTaskLists(void)
{
	// 省略未修改部分
	......
	// 初始化延时阻塞链表
	vListInitialise(&xDelayed_Task_List1);
	vListInitialise(&xDelayed_Task_List2);
	
	// 初始化指向延时阻塞链表的指针
	pxDelayed_Task_List = &xDelayed_Task_List1;
	pxOverflow_Delayed_Task_List = &xDelayed_Task_List2;
}

1.3、taskSWITCH_DELAYED_LISTS( )

为什么需要阻塞链表和溢出阻塞链表需要交换?

阅读 ” 0.2、思考二“ 小节内容

阻塞链表和溢出阻塞链表是如何实现交换的?

利用两个指针进行交换

/* task.c */
// 记录溢出次数
static volatile BaseType_t xNumOfOverflows = (BaseType_t)0;

// 延时阻塞链表和溢出延时阻塞链表交换
#define taskSWITCH_DELAYED_LISTS()\
{\
	List_t volatile *pxTemp;\
	pxTemp = pxDelayed_Task_List;\
	pxDelayed_Task_List = pxOverflow_Delayed_Task_List;\
	pxOverflow_Delayed_Task_List = pxTemp;\
	xNumOfOverflows++;\
	prvResetNextTaskUnblockTime();\
}

1.4、prvResetNextTaskUnblockTime( )

由于将任务插入溢出阻塞链表时不会更新 xNextTaskUnblockTime 变量,只有在将任务插入阻塞链表中时才会更新xNextTaskUnblockTime 变量,所以对于溢出阻塞链表中存在的任务没有对应的唤醒时间,因此当心跳溢出切换阻塞链表时候,需要重设 xNextTaskUnblockTime 变量的值

/* task.c */
// 记录下个任务解除阻塞时间
static volatile TickType_t xNextTaskUnblockTime = (TickType_t)0U;
// 函数声明
static void prvResetNextTaskUnblockTime(void);

// 重设 xNextTaskUnblockTime 变量值
static void prvResetNextTaskUnblockTime(void)
{
	TCB_t *pxTCB;
	// 切换阻塞链表后,阻塞链表为空
	if(listLIST_IS_EMPTY(pxDelayed_Task_List) != pdFALSE)
	{
		// 下次解除延时的时间为可能的最大值
		xNextTaskUnblockTime = portMAX_DELAY;
	}
	else
	{
		// 如果阻塞链表不为空,下次解除延时的时间为链表头任务的阻塞时间
		(pxTCB) = (TCB_t *)listGET_OWNER_OF_HEAD_ENTRY(pxDelayed_Task_List);
		xNextTaskUnblockTime=listGET_LIST_ITEM_VALUE(&((pxTCB)->xStateListItem));
	}
}

1.5、prvAddCurrentTaskToDelayedList( )

将当前任务加入到阻塞链表中,具体流程可以参看程序注释,对于延时到期时间未溢出的任务会插入到阻塞链表中,而对于延时到期时间溢出的任务会插入溢出阻塞链表中

/* task.c */
// 将当前任务添加到阻塞链表中
static void prvAddCurrentTaskToDelayedList(TickType_t xTicksToWait)
{
	TickType_t xTimeToWake;
	// 当前滴答定时器中断次数
	const TickType_t xConstTickCount = xTickCount;
	// 成功从就绪链表中移除该阻塞任务
	if(uxListRemove((ListItem_t *)&(pxCurrentTCB->xStateListItem)) == 0)
	{
		// 将当前任务的优先级从优先级位图中删除
		portRESET_READY_PRIORITY(pxCurrentTCB->uxPriority, uxTopReadyPriority);
	}
	// 计算延时到期时间
	xTimeToWake = xConstTickCount + xTicksToWait;
	// 将延时到期值设置为阻塞链表中节点的排序值
	listSET_LIST_ITEM_VALUE(&(pxCurrentTCB->xStateListItem), xTimeToWake);
	// 如果延时到期时间会溢出
	if(xTimeToWake < xConstTickCount)
	{
		// 将其插入溢出阻塞链表中
		vListInsert((List_t *)pxOverflow_Delayed_Task_List,
		           (ListItem_t *)&(pxCurrentTCB->xStateListItem));
	}
	// 没有溢出
	else
	{
		// 插入到阻塞链表中
		vListInsert((List_t *)pxDelayed_Task_List,
		           (ListItem_t *) &( pxCurrentTCB->xStateListItem));
		
		// 更新下一个任务解锁时刻变量 xNextTaskUnblockTime 的值
		if(xTimeToWake < xNextTaskUnblockTime)
		{
			xNextTaskUnblockTime = xTimeToWake;
		}
	}
}

2、修改内核程序

2.1、vTaskStartScheduler( )

/* task.c */
void vTaskStartScheduler(void)
{
	// 省略创建空闲任务函数
	......
	
	// 初始化滴答定时器计数值,感觉有点儿多余?全局变量定义时候已被初始化为 0
	xTickCount = (TickType_t)0U;
	
	if(xPortStartScheduler() != pdFALSE){}
}

2.2、vTaskDelay( )

阻塞延时函数,当任务调用阻塞延时函数时会将任务从就绪链表中删除,然后加入到阻塞链表中

/* task.c */
// 阻塞延时函数
void vTaskDelay(const TickType_t xTicksToDelay)
{
	// 将当前任务加入到阻塞链表
	prvAddCurrentTaskToDelayedList(xTicksToDelay);
	
	// 任务切换
	taskYIELD();
}

2.3、xTaskIncrementTick( )

利用 RTOS 的心跳(滴答定时器中断服务函数)对阻塞任务进行处理,具体流程如下所示

/* task.c */
// 任务阻塞延时处理
BaseType_t xTaskIncrementTick(void)
{
	TCB_t *pxTCB = NULL;
	TickType_t xItemValue;
	BaseType_t xSwitchRequired = pdFALSE;
	
	// 更新系统时基计数器 xTickCount
	const TickType_t xConstTickCount = xTickCount + 1;
	xTickCount = xConstTickCount;

	// 如果 xConstTickCount 溢出,则切换延时列表
	if(xConstTickCount == (TickType_t)0U)
	{
		taskSWITCH_DELAYED_LISTS();
	}
	
	// 最近的延时任务延时到期
	if(xConstTickCount >= xNextTaskUnblockTime)
	{
		for(;;)
		{
			// 延时阻塞链表为空则跳出 for 循环
			if(listLIST_IS_EMPTY(pxDelayed_Task_List) != pdFALSE)
			{
				// 设置下个任务解除阻塞时间为最大值,也即永不解除阻塞
				xNextTaskUnblockTime = portMAX_DELAY;
				break;
			}
			else
			{
				// 依次获取延时阻塞链表头节点
				pxTCB=(TCB_t *)listGET_OWNER_OF_HEAD_ENTRY(pxDelayed_Task_List);
				// 依次获取延时阻塞链表中所有节点解除阻塞的时间
				xItemValue = listGET_LIST_ITEM_VALUE(&(pxTCB->xStateListItem));
				
				// 当阻塞链表中所有延时到期的任务都被移除则跳出 for 循环
				if(xConstTickCount < xItemValue)
				{
					xNextTaskUnblockTime = xItemValue;
					break;
				}
				
				// 将任务从延时列表移除,消除等待状态
				(void)uxListRemove(&(pxTCB->xStateListItem));
				
				// 将解除等待的任务添加到就绪列表
				prvAddTaskToReadyList(pxTCB);
#if(configUSE_PREEMPTION == 1)
				// 如果解除阻塞状态的任务优先级比当前任务优先级高,则需要进行任务调度
				if(pxTCB->uxPriority >= pxCurrentTCB->uxPriority)
				{
					xSwitchRequired = pdTRUE;
				}
#endif
			}
		}
	}
	return xSwitchRequired;
}

/* task.h */
// 修改函数声明
BaseType_t xTaskIncrementTick(void);
/* FreeRTOSConfig.h */
// 支持抢占优先级
#define configUSE_PREEMPTION                    1

2.4、xPortSysTickHandler( )

无其他变化,只是将任务切换从函数体内修改到函数体外

/* port.c */
// SysTick 中断
void xPortSysTickHandler(void)
{
	// 关中断
	vPortRaiseBASEPRI();
	// 更新系统时基
	if(xTaskIncrementTick() != pdFALSE)
	{
		taskYIELD();
	}
	// 开中断
	vPortSetBASEPRI(0);
}

3、实验

3.1、测试

FreeRTOS简单内核实现6 优先级 文章中 "3.1、测试" 小节内容一致

如果使用的开发环境为 Keil 且程序工作不正常,可以勾选 Use MicroLIB 试试,如下图所示

3.2、待改进

当前 RTOS 简单内核已实现的功能有

  1. 静态方式创建任务
  2. 手动切换任务
  3. 临界段保护
  4. 任务阻塞延时
  5. 支持任务优先级
  6. 阻塞链表

当前 RTOS 简单内核存在的缺点有

  1. 不支持时间片轮询

与FreeRTOS简单内核实现7 阻塞链表相似的内容:

FreeRTOS简单内核实现7 阻塞链表

0、思考与回答 0.1、思考一 如何处理进入阻塞状态的任务? 为了让 RTOS 支持多优先级,我们创建了多个就绪链表(数组形式),用每一个就绪链表表示一个优先级,对于阻塞状态的任务显然要从就绪链表中移除,但是阻塞状态的任务并不是永久阻塞了,等待一段时间后应该从阻塞状态恢复,所以我们需要创建一个阻塞链

FreeRTOS简单内核实现6 优先级

0、思考与回答 0.1、思考一 如何实现 RTOS 内核支持多优先级? 因为不支持优先级,所以所有的任务都插入了一个名为 pxReadyTasksLists 的就绪链表中,相当于所有任务的优先级都是一致的,那如果我们创建一个就绪链表数组,数组下标代表优先级,优先级为 x 的任务就插入到 pxRead

FreeRTOS简单内核实现5 阻塞延时

0、思考与回答 0.1、思考一 为什么 FreeRTOS简单内核实现3 任务管理 文章中实现的 RTOS 内核不能看起来并行运行呢? Task1 延时 100ms 之后执行 taskYIELD() 切换到 Task2,Task2 延时 500ms 之后执行 taskYIELD() 再次切换 Task

FreeRTOS简单内核实现3 任务管理

0、思考与回答 0.1、思考一 对于 Cotex-M4 内核的 MCU 在发生异常/中断时,哪些寄存器会自动入栈,哪些需要手动入栈? 会自动入栈的寄存器如下 R0 - R3:通用寄存器 R12:通用寄存器 LR (Link Register):链接寄存器,保存返回地址 PC (Program Cou

FreeRTOS简单内核实现2 双向链表

FreeRTOS 的 list.c / list.h 文件中有 3 个数据结构、2 个初始化函数、2 个插入函数、1 个移除函数和一些宏函数,链表是 FreeRTOS 中的重要数据结构