嵌入式操作系统内核原理和开发(通用优先级调度)
【 声明:版权所有,欢迎转载,请勿用于商业用途。 联系信箱:feixiaoxing @163.com】
相比较其他调度算法而言,时间片的轮转更多的注重公平性。但是,任务与任务之间也是有先后之分的,有的任务我们希望多安排一些时间片,而有的任务我们则希望少安排一些时间片。比较说,如果我们在上网的话,我们就希望上网的操作响应的更快一些;如果我们在进行GUI操作,我们当然就希望图形响应更快一些。这些都是可以理解的,下面我们就绪要对数据结构进行一些修改。
typedef struct _TASK_INFO
{
UINT32 id;
UINT32* stack;
UINT32 size;
UINT32 context;
UINT32 priority;
UINT32 time_slice;
void (*func)();
}TASK_INFO;
这里的priority就是当前线程的优先级,所以最简单的方法就是根据priority直接分配对应的time_slice。也就是这个函数,
void reset_time_slice ()
{
int index;
for(index = 0; index < THREAD_MAX_NUMBER; index++)
gAllTask[index].time_slice = gAllTask[index].priority + 1;
}
所以,以后每次调度的时候,我们就首先寻找当前最高优先级的任务,看看当前任务安排的时间片是否用完了,没有用完就继续运行。如果当前优先级的任务已经没有时间片了,那么此时就可以安排低优先级的任务进行调度了。
void signal_handler(int m)
{
int index;
start:
index = find_next_thread();
if(-1 == index)
{
reset_time_slice();
goto start;
}
gAllTask[index].time_slice --;
current_thread_id = index;
swap(&old, &gAllTask[current_thread_id].context);
}
下面,我们就根据任务优先级挑选下一个需要运行的thread了,
int find_next_thread()
{
int index;
for(index = THREAD_MAX_NUMBER -1; index >=0; index --)
{
if(0 != gAllTask[index].time_slice)
break;
}
return index;
}
整个代码的流程也不复杂,大家可以运行、单步调试一把,试试看。
#include <stdio.h>
#include <time.h>
#include <stdlib.h>
#include <signal.h>
#include <assert.h>
#include <string.h>
#include <sys/time.h>
#define UINT32 unsigned int
#define STACK_LENGTH 512
#define THREAD_MAX_NUMBER 10
typedef struct _TASK_INFO
{
UINT32 id;
UINT32* stack;
UINT32 size;
UINT32 context;
UINT32 priority;
UINT32 time_slice;
void (*func)();
}TASK_INFO;
static struct itimerval oldtv;
UINT32 old = 0;
UINT32 count = 0;
UINT32 task_stack[THREAD_MAX_NUMBER][STACK_LENGTH] = {0};
TASK_INFO gAllTask[THREAD_MAX_NUMBER] = {0};
UINT32 current_thread_id = 0;
void set_timer()
{
struct itimerval itv;
itv.it_interval.tv_sec = 1;
itv.it_interval.tv_usec = 0;
itv.it_value.tv_sec = 1;
itv.it_value.tv_usec = 0;
setitimer(ITIMER_REAL, &itv, &oldtv);
}
void swap(UINT32* prev, UINT32* next)
{
__asm("push %%eax\n\t"
"push %%ebx\n\t"
"push %%ecx\n\t"
"push %%edx\n\t"
"push %%esi\n\t"
"push %%edi\n\t"
"push %%ebp\n\t"
"push %%esp\n\t"
"lea 0x8(%%ebp), %%eax\n\t"
"mov (%%eax), %%eax\n\t"
"mov %%esp, (%%eax)\n\t"
"lea 0xc(%%ebp), %%eax\n\t"
"mov (%%eax), %%eax\n\t"
"mov (%%eax), %%esp\n\t"
"pop %%esp\n\t"
"pop %%ebp\n\t"
"pop %%edi\n\t"
"pop %%esi\n\t"
"pop %%edx\n\t"
"pop %%ecx\n\t"
"pop %%ebx\n\t"
"pop %%eax\n\t"
::);
}
void hello()
{
int temp = 0;
while(1) {
printf("id = %d, temp = %d, count = %d in thread!\n",current_thread_id, temp ++, count ++);
swap(&gAllTask[current_thread_id].context, &old);
printf("id = %d, temp = %d, count = %d in thread!\n",current_thread_id, temp ++, count ++);
swap(&gAllTask[current_thread_id].context, &old);
}
}
int find_next_thread()
{
int index;
for(index = THREAD_MAX_NUMBER -1; index >=0; index --)
{
if(0 != gAllTask[index].time_slice)
break;
}
return index;
}
void reset_time_slice ()
{
int index;
for(index = 0; index < THREAD_MAX_NUMBER; index++)
gAllTask[index].time_slice = gAllTask[index].priority + 1;
}
void task_init(int index)
{
UINT32 unit = gAllTask[index].size;
UINT32* pData = gAllTask[index].stack;
memset((void*)pData,(int) 0, unit * sizeof(UINT32));
pData[unit -1] = (UINT32) gAllTask[index].func;
pData[unit -2] = 0;
pData[unit -3] = 0;
pData[unit -4] = 0;
pData[unit -5] = 0;
pData[unit -6] = 0;
pData[unit -7] = 0;
pData[unit -8] = 0;
pData[unit -9] = 0;
pData[unit -10] = (UINT32) &pData[unit - 9];
gAllTask[index].context = (UINT32) &pData[unit -10];
}
void signal_handler(int m)
{
int index;
start:
index = find_next_thread();
if(-1 == index)
{
reset_time_slice();
goto start;
}
gAllTask[index].time_slice --;
current_thread_id = index;
swap(&old, &gAllTask[current_thread_id].context);
}
void set_all_task()
{
int index;
memset(gAllTask, 0, sizeof(gAllTask));
for(index = 0; index < THREAD_MAX_NUMBER; index ++)
{
gAllTask[index].id = index;
gAllTask[index].stack = task_stack[index];
gAllTask[index].size = STACK_LENGTH;
gAllTask[index].context = 0;
gAllTask[index].func = hello;
gAllTask[index].priority = index;
gAllTask[index].time_slice = index + 1;
task_init(index);
}
}
int main()
{
char val;
set_all_task();
set_timer();
signal(SIGALRM, signal_handler);
while(1)
{
scanf("%c", &val);
}
exit(0);
return 1;
}
嵌入式操作系统内核原理和开发(通用优先级调度)相关推荐
- 嵌入式操作系统内核原理和开发
嵌入式操作系统内核原理和开发(开篇) 操作系统是很多人每天必须打交道的东西,因为在你打开电脑的一刹那,随着bios自检结束,你的windows系统已经开始运行了.如果问大家操作系统是什么?可能有的人会 ...
- 嵌入式操作系统内核原理和开发(总结篇)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 很多朋友都喜欢嵌入式操作系统的内容,但是如何实现和仿真这样一个系统一直是困扰我们的难题.现在郑 ...
- 嵌入式操作系统内核原理和开发(改进型优先级调度)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 上面的一篇博客说到了优先级调度,但是那个优先级调度算法比较极端.打个比方说,现在王先生有三个小 ...
- 嵌入式操作系统内核原理和开发(地址空间)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 不管是什么样的嵌入式cpu,它必然有自己的访问地址空间.至于这个具体的访问空间是什么,那cpu ...
- 嵌入式操作系统内核原理和开发(信号量)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 之前因为工作的原因,操作系统这块一直没有继续写下去.一方面是自己没有这方面的经历,另外一方面就 ...
- 嵌入式操作系统内核原理和开发(消息队列)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 消息队列是线程交互的一种方法,任务可以通过消息队列来实现数据的沟通和交换.在嵌入式系统上,这可 ...
- 嵌入式操作系统内核原理和开发(头文件调整)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 很长一段时间,我个人对头文件的功能了解得不是很明白.虽然在平时的开发中,对于头文件也没有犯过什 ...
- 嵌入式操作系统内核原理和开发(基础)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] 在编写我们的操作系统之前,我们需要明确一些事情.比如说,这个系统的运行环境是什么?怎么编译?基 ...
- 嵌入式操作系统内核原理和开发(cpu的那些事)
[ 声明:版权所有,欢迎转载,请勿用于商业用途. 联系信箱:feixiaoxing @163.com] cpu是数字处理系统中的一个重要环节.在我看来,单片机.微处理器.dsp都可以称作是cpu,只 ...
最新文章
- python argparser模块的相关使用
- Web API之基于H5客户端分段上传大文件
- android笔试题整理
- 古剑奇谭二服务器维护,《古剑奇谭二》10月4日例行维护更新公告
- Java中反射主要应用在哪里_Java学习:反射的应用场景和解析方法
- 英特尔处理器接连爆出漏洞,Intel:这次不打算修了
- CentOS6.5部署KVM及实现在线迁移
- 鸿蒙空间最高级,洪荒:我能进化万物
- 用友nccloud 虚拟机
- 百度地图Js之浏览端
- 微信开放平台开发(3) 移动应用微信登录
- 【MobileViT】
- 史上最强!PC时代的20位英雄
- 为什么运放一般要反比例放大?
- 微信开发者工具,出现“当前系统代理不是安全代理,是否信任?”
- Linux驱动学习--linux以太网驱动及硬件结构介绍(结合gmac项目分析)
- unreal 渲染讲的比较好的材料
- java验证码验证码_Java登录页面实时验证用户名密码和动态验证码
- 软件测试之测试主流技能
- [转]ESMTP的三个认证方式: CRAM-MD5 PLAIN和LOGIN