|
程序架构重要性 Demo #include <thread>#include <stdio.h>#include <windows.h>#include 'timeslice.h'// 创建5个任务对象TimesilceTaskObj task_1, task_2, task_3, task_4, task_5;// 具体的任务函数void task1_hdl(){ printf('>> task 1 is running ...\n');}void task2_hdl(){ printf('>> task 2 is running ...\n');}void task3_hdl(){ printf('>> task 3 is running ...\n');}void task4_hdl(){ printf('>> task 4 is running ...\n');}void task5_hdl(){ printf('>> task 5 is running ...\n');}// 初始化任务对象,并且将任务添加到时间片轮询调度中void task_init(){ timeslice_task_init(&task_1, task1_hdl, 1, 10); timeslice_task_init(&task_2, task2_hdl, 2, 20); timeslice_task_init(&task_3, task3_hdl, 3, 30); timeslice_task_init(&task_4, task4_hdl, 4, 40); timeslice_task_init(&task_5, task5_hdl, 5, 50); timeslice_task_add(&task_1); timeslice_task_add(&task_2); timeslice_task_add(&task_3); timeslice_task_add(&task_4); timeslice_task_add(&task_5);}// 开两个线程模拟在单片机上的运行过程void timeslice_exec_thread(){ while (true) { timeslice_exec(); }}void timeslice_tick_thread(){ while (true) { timeslice_tick(); Sleep(10); }}int main(){ task_init(); printf('>> task num: %d\n', timeslice_get_task_num()); printf('>> task len: %d\n', timeslice_get_task_timeslice_len(&task_3)); timeslice_task_del(&task_2); printf('>> delet task 2\n'); printf('>> task 2 is exist: %d\n', timeslice_task_isexist(&task_2)); printf('>> task num: %d\n', timeslice_get_task_num()); timeslice_task_del(&task_5); printf('>> delet task 5\n'); printf('>> task num: %d\n', timeslice_get_task_num()); printf('>> task 3 is exist: %d\n', timeslice_task_isexist(&task_3)); timeslice_task_add(&task_2); printf('>> add task 2\n'); printf('>> task 2 is exist: %d\n', timeslice_task_isexist(&task_2)); timeslice_task_add(&task_5); printf('>> add task 5\n'); printf('>> task num: %d\n', timeslice_get_task_num()); printf('\n\n========timeslice running===========\n'); std::thread thread_1(timeslice_exec_thread); std::thread thread_2(timeslice_tick_thread); thread_1.join(); thread_2.join(); return 0;}运行结果如下: 时间片轮询架构 其实该部分主要使用了面向对象的思维,使用结构体作为对象,并使用结构体指针作为参数传递,这样作可以节省资源,并且有着极高的运行效率。
#include './timeslice.h'static LIST_HEAD(timeslice_task_list);void timeslice_exec(){ ListObj* node; TimesilceTaskObj* task; list_for_each(node, ×lice_task_list) { task = list_entry(node, TimesilceTaskObj, timeslice_task_list); if (task->is_run == TASK_RUN) { task->task_hdl(); task->is_run = TASK_STOP; } }}void timeslice_tick(){ ListObj* node; TimesilceTaskObj* task; list_for_each(node, ×lice_task_list) { task = list_entry(node, TimesilceTaskObj, timeslice_task_list); if (task->timer != 0) { task->timer--; if (task->timer == 0) { task->is_run = TASK_RUN; task->timer = task->timeslice_len; } } }}unsigned int timeslice_get_task_num(){ return list_len(×lice_task_list);}void timeslice_task_init(TimesilceTaskObj* obj, void (*task_hdl)(void), unsigned int id, unsigned int timeslice_len){ obj->id = id; obj->is_run = TASK_STOP; obj->task_hdl = task_hdl; obj->timer = timeslice_len; obj->timeslice_len = timeslice_len;}void timeslice_task_add(TimesilceTaskObj* obj){ list_insert_before(×lice_task_list, &obj->timeslice_task_list);}void timeslice_task_del(TimesilceTaskObj* obj){ if (timeslice_task_isexist(obj)) list_remove(&obj->timeslice_task_list); else return;}unsigned char timeslice_task_isexist(TimesilceTaskObj* obj){ unsigned char isexist = 0; ListObj* node; TimesilceTaskObj* task; list_for_each(node, ×lice_task_list) { task = list_entry(node, TimesilceTaskObj, timeslice_task_list); if (obj->id == task->id) isexist = 1; } return isexist;}unsigned int timeslice_get_task_timeslice_len(TimesilceTaskObj* obj){ return obj->timeslice_len;}底层侵入式双向链表
#include 'list.h'void list_init(ListObj* list){ list->next = list->prev = list;}void list_insert_after(ListObj* list, ListObj* node){ list->next->prev = node; node->next = list->next; list->next = node; node->prev = list;}void list_insert_before(ListObj* list, ListObj* node){ list->prev->next = node; node->prev = list->prev; list->prev = node; node->next = list;}void list_remove(ListObj* node){ node->next->prev = node->prev; node->prev->next = node->next; node->next = node->prev = node;}int list_isempty(const ListObj* list){ return list->next == list;}unsigned int list_len(const ListObj* list){ unsigned int len = 0; const ListObj* p = list; while (p->next != list) { p = p->next; len++; } return len;} |
|
|