|
#include "os_task.h"
|
#include "os_clock.h"
|
// extern int OS_TickFlag = 0;
|
static OS_TASK_MSG *g_p_task = NULL;
|
static int g_task_cnt = 0;
|
static int g_task_pos = 0;
|
|
/**
|
* @brief
|
*
|
* @param p_task
|
* @param cnt
|
* @return int
|
*/
|
int InitOSTaskQueue(OS_TASK_MSG *p_task, int cnt)
|
{
|
int 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 func
|
* @param tick
|
* @param work_tick
|
* @param par
|
* @return int
|
*/
|
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 GetTick
|
*/
|
void OSSchedule(GETTICK_t 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++;
|
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;
|
}
|
}
|
}
|
}
|
|
void OS_GetTick(void)
|
{
|
while (1 != os_GetTickFlag())
|
;
|
os_ClearTickFlag();
|
}
|
