/**
|
* @file os_task.c
|
* @author your name (you@domain.com)
|
* @brief
|
* @version 0.1
|
* @date 2021-04-05
|
*
|
* @copyright Copyright (c) 2021
|
*
|
*/
|
|
#include "os_task.h"
|
|
static OS_TASK_MSG *g_p_task = NULL; //任务队列
|
static int g_task_cnt = 0; //总任务数量
|
static int g_task_pos = 0; //当前任务个数
|
|
/*!
|
* @brief 初始化任务队列
|
* @param [in] p_task 任务队列保存的数据
|
* @param [in] cnt 设置最多保存cnt个任务
|
* @return int 返回初始化是否成功
|
* @retval 0 成功
|
* @note null
|
*/
|
int InitOSTaskQueue(OS_TASK_MSG *p_task, int cnt)
|
{
|
unsigned char i = 0;
|
g_p_task = p_task;
|
g_task_cnt = cnt;
|
for (i = 0; i < g_task_cnt; i++)
|
{
|
g_p_task[i].func = NULL;
|
}
|
return 0;
|
}
|
|
/*!
|
* @brief 创建一个任务
|
* @param [in] func 执行任务的函数指针
|
* @param [in] tick 执行当前任务需要多少个周期
|
* @param [in] work_tick 在一个周期内具体哪个时间片去执行
|
* @param [in] par 传入任务需要的参数
|
* @return int 返回初始化是否成功
|
* @retval 0 成功
|
* @retval -1 失败
|
* @note null
|
*/
|
int OSTaskCreate(TASK_FUNC func, int tick, int work_tick, void *par)
|
{
|
if (g_task_pos < g_task_cnt)
|
{
|
g_p_task[g_task_pos].func = func;
|
g_p_task[g_task_pos].cycle_tick = tick;
|
g_p_task[g_task_pos].work_tick = work_tick;
|
g_p_task[g_task_pos].par = par;
|
g_task_pos++;
|
return 0;
|
}
|
else
|
{
|
return -1;
|
}
|
}
|
|
/*!
|
* @brief 调度所有任务
|
* @param [in] tick 执行当前任务需要多少个周期
|
* @note null
|
*/
|
void OSSchedule(void (*GetTick)())
|
{
|
int i = 0;
|
|
if (NULL == GetTick)
|
{
|
return;
|
}
|
while (1)
|
{
|
GetTick();
|
for (i = 0; i < g_task_pos; i++)
|
{
|
g_p_task[i].cur_tick++; //当前任务CPU分片
|
if ((g_p_task[i].cur_tick == g_p_task[i].work_tick) && (g_p_task[i].func != NULL))
|
{
|
g_p_task[i].func(g_p_task[i].par);
|
}
|
if (g_p_task[i].cur_tick >= g_p_task[i].cycle_tick)
|
{
|
g_p_task[i].cur_tick = 0;
|
}
|
}
|
}
|
}
|
