今天操作系统实验课我们做了作业调度算法的模拟。网上的调度算法参差不齐，零散杂乱。我在这里进行一个总结，并且分享给大家操作系统的五种常用算法（FCFS,SJF,HRRF,HPF,RR）并且附上代码和结果图
作业调度
作业调度又称高级调度，不涉及处理机的分配，主要任务是按一定的原则从外存上处于后备状态的作业中挑选一个（或多个）作业调入主存，为其分配内存、I/O设备等必要的资源，并建立相应的进程，安排在就绪队列上，以使进程获得竞争处理机的权利。
算法一：先来先服务（FCFS）
基本思想
·遵循先进入后备队列的作业，先进行调度的原则。
·非抢占式算法
特点
·简单，易于编码实现
·优先考虑作业的等待时间，没有考虑作业的执行时间长短、作业的运行特性和作业对资源的要求
算法二：短作业优先（SJF）
基本思想
·根据作业控制块中作业申请时指出的执行时间，选取执行时间最短的作业优先调度；可有抢占或非抢占方式。
·短作业优先调度算法考虑了作业的运行时间而忽略了作业的等待时间。
算法三：高响应比优先（HRRF）
初衷
·FCFS调度算法只片面地考虑了作业的进入时间，短作业优先调度算法考虑了作业的运行时间而忽略了作业的等待时间。
·响应比高者优先调度算法为这两种算法的折中，使长作业不会长时间等待，但每次调度前都要进行响应比计算。
算法四：优先权高者优先（HPF）
基本思想
·系统根据作业的优先权进行作业调度，每次选取优先权高的作业优先调度。作业的优先权通常用一个整数表示，也叫做优先数。优先数的大小与优先权的关系由系统或者用户来规定,本实验采用优先权值越小，优先权越高。
·优先权高者优先调度算法综合考虑了作业执行时间和等待时间的长短、作业的缓急度、作业对外部设备的使用情况等因素。
算法五：时间片轮转（RR）
基本思想
·系统将所有的就绪进程按先来先服务的原则，排成一个队列，每次调度时，把CPU分配给队首进程，并令其执行一个时间片。时间片结束之后，将该进程加到就绪队列队尾；然后再把处理机分配给就绪队列中新的首进程。
优点
·系统能在给定的时间内响应所有用户请求。
完整代码
有些代码有点重复，可以写个函数调用。在这里不进行优化，易于大家理解。
实验二-job.txt里的内容为
作业ID 到达时间 执行时间 优先权
1 800 50 0
2 815 30 1
3 830 25 2
4 835 20 2
5 845 15 2
6 700 10 1
7 820 5 0
#include<stdio.h>
#include<stdlib.h>
#include<conio.h>
#include<time.h>
#include<memory.h>
#include<algorithm>
#include<vector>
#include<queue>
#define getpch(type) (type*)malloc(sizeof(type))
#define inf 0x3f3f3f
using namespace std;
//定义作业信息结构
typedef struct node{int number; //作业号int reach_time; //作业抵达时间int need_time; //作业的执行时间int privilege; //作业优先权float excellent; //响应比int start_time; //作业开始时间int wait_time; //等待时间int tr_time; //周转时间double wtr_time; //带权周转时间int run_time; //作业累计已执行时间bool visited; //作业是否被访问过int finish_time; //作业完成时间 bool reached; //作业是否抵达
}job;//停顿几秒
void _sleep(int n){clock_t goal;goal = (clock_t)n * CLOCKS_PER_SEC + clock();while(goal>clock());
}//按任意键继续
char _keygo(){char c;printf("按任意键继续.......\n");c = getch();return c;
}//数据设置区域const int MAX_NUM = 10;//最大作业数量
const int MAX_LINE=1024;//一行的size
int num = 0;//实际作业数量
job jobs[MAX_NUM];//作业
//就绪队列
int ready[MAX_NUM];
//记录排序使用哪个数值作为排序对象
int order[MAX_NUM];
void initial_jobs() { //初始化所有作业信息 for(int i=0;i<MAX_NUM;i++){jobs[i].excellent=0;jobs[i].need_time=0;jobs[i].number=0;jobs[i].privilege=0;jobs[i].reach_time=0;jobs[i].run_time=0;jobs[i].start_time=0;jobs[i].tr_time=0;jobs[i].visited=false;jobs[i].wait_time=0;jobs[i].wtr_time=0;jobs[i].finish_time=0;jobs[i].reached=false;} }
void read_Jobdata(){ //读取数据文件 FILE *fp;fp = fopen("job.txt","r");if(fp == NULL){ //如果文件不存在，则退出 printf("fail to open the file!\n");exit(0);}char buffer[100];printf("start reading...\n");fgets(buffer,MAX_LINE,fp);num++;while (1) {if (!feof(fp)){fscanf(fp, "%d%d%d%d", &jobs[num].number, &jobs[num].reach_time, &jobs[num].need_time, &jobs[num].privilege);num++;continue;fgetc(fp);}else{break;}} num--; printf("read data success!\n");printf("作业的数量为: %d\n",num);printf("%s\n",buffer);for(int j=1;j<=num;j++){printf("%d\t%d\t\t%d\t\t%d\n",jobs[j].number,jobs[j].reach_time,jobs[j].need_time,jobs[j].privilege);}fclose(fp);
}
void initial_jobs_again()
{for(int i=1;i<=num;i++){jobs[i].finish_time=0;jobs[i].excellent=0;jobs[i].tr_time=0;jobs[i].wtr_time=0;jobs[i].wait_time=0;jobs[i].visited=false;}
}//调度函数//先来先服务算法
void FCFS(){int i,j,temp;double sum1=0; //总的等待时间 double sum2=0; //总的周转时间 double sum3=0; //总的带权周转时间 for(i = 1;i <= num; i++){order[i] = jobs[i].reach_time;ready[i] = i;}//冒泡排序for(i = 1; i <= num; i++){//按照到达时间大小排序for(j = 1; j <= num-i; j++){if(order[j] > order[j+1]){temp = order[j];order[j] = order[j+1];order[j+1] = temp;temp = ready[j];ready[j] = ready[j+1];ready[j+1] = temp;} }}for(i = 1; i <= num; i++){printf("第%d个作业",ready[i]);printf("到达时间 --%d,服务时间--%d\n",jobs[ready[i]].reach_time,jobs[ready[i]].need_time);printf("本作业正在运行...........\n");_sleep(1);printf("运行完毕\n");if(i==1){jobs[ready[i]].finish_time=jobs[ready[i]].reach_time+jobs[ready[i]].need_time;jobs[ready[i]].wait_time=0;} else{if(jobs[ready[i-1]].finish_time>jobs[ready[i]].reach_time){ //如果上一个作业的完成时间大于下一个作业的到达时间，则下一个作业的开始时间从上一个的完成时间开始 jobs[ready[i]].finish_time=jobs[ready[i-1]].finish_time+jobs[ready[i]].need_time;jobs[ready[i]].wait_time=jobs[ready[i-1]].finish_time-jobs[ready[i]].reach_time;} else{jobs[ready[i]].finish_time=jobs[ready[i]].need_time+jobs[ready[i]].reach_time;jobs[ready[i]].wait_time=0;}}jobs[ready[i]].tr_time=jobs[ready[i]].finish_time-jobs[ready[i]].reach_time;jobs[ready[i]].wtr_time=double(jobs[ready[i]].tr_time)/jobs[ready[i]].need_time;printf("等待时间: %d 周转时间: %d 带权周转时间: %0.2f\n",jobs[ready[i]].wait_time,jobs[ready[i]].tr_time,jobs[ready[i]].wtr_time);sum1+=jobs[ready[i]].wait_time;sum2+=jobs[ready[i]].tr_time;sum3+=jobs[ready[i]].wtr_time; }printf("--------所有作业调度完毕------\n");printf("平均等待时间: %.2f 平均周转时间: %.2f 平均带权周转时间: %.2f",sum1/num,sum2/num,sum3/num);initial_jobs_again();
}
int findNextSJF(job j[MAX_NUM], int length,int time ) {// p是已经到达且拥有最短运行时间的进程的下标// q是没有到达的进程中拥有最早到达时间的进程的下标int i, p, q;int minNeedTime, minReachTime,minTime;p = q = -1; minTime = minNeedTime = minReachTime = inf;for( i = 1; i <= length; i++ ) {if(!j[i].visited){ // 第一情况if( j[i].reach_time<=time && j[i].need_time<=minNeedTime ){ p = i; minNeedTime = j[i].need_time; }// 第二种情况else if( j[i].reach_time>time && j[i].reach_time<=minReachTime ){if(j[i].need_time<minTime){ q = i; minReachTime = j[i].reach_time; minTime = j[i].need_time; }}} }// p为-1时,代表在lastTime时刻还没进程到达,此时选择下一个最早到达的进程qif( p != -1 ) return p;return q;
}//短作业优先算法
void SJF(){int i,j;double sum1=0; //总的等待时间 double sum2=0; //总的周转时间 double sum3=0; //总的带权周转时间 int finish=inf; //当前完成时间for(i=1;i<=num;i++){finish=min(finish,jobs[i].reach_time);}printf("短作业优先算法: \n");for(i=1;i<=num;i++){int index=findNextSJF(jobs,num,finish);printf("第%d个作业",index);printf("到达时间 --%d,服务时间--%d\n",jobs[index].reach_time,jobs[index].need_time);printf("本作业正在运行...........\n");_sleep(1);printf("运行完毕\n");if(jobs[index].reach_time<=finish){jobs[index].wait_time=finish-jobs[index].reach_time;jobs[index].start_time=finish;}else{jobs[index].start_time=jobs[index].reach_time;jobs[index].wait_time=0;}jobs[index].finish_time=jobs[index].start_time+jobs[index].need_time;jobs[index].tr_time=jobs[index].finish_time-jobs[index].reach_time;jobs[index].wtr_time=(double)jobs[index].tr_time/jobs[index].need_time;jobs[index].visited=true;sum1+=jobs[index].wait_time;sum2+=jobs[index].tr_time;sum3+=jobs[index].wtr_time; finish=jobs[index].finish_time;printf("等待时间: %d 周转时间: %d 带权周转时间: %0.2f\n",jobs[index].wait_time,jobs[index].tr_time,jobs[index].wtr_time);}printf("--------所有作业调度完毕------\n");printf("平均等待时间: %.2f 平均周转时间: %.2f 平均带权周转时间: %.2f",sum1/num,sum2/num,sum3/num);initial_jobs_again();
}
int findNextHRRF(int pre)
{int current=1,i,j; //优先权=(等待时间+要求服务时间)/要求服务时间for(i=1;i<=num;i++){if(!jobs[i].visited){ jobs[i].wait_time= jobs[pre].finish_time-jobs[i].reach_time; //等待时间=上一个进程的完成时间-到达时间jobs[i].excellent=(float)(jobs[i].wait_time+jobs[i].need_time)/jobs[i].need_time;}}for(i=1;i<=num;i++){if(!jobs[i].visited){current=i; //找到第一个还没完成的作业break;}}for(j=i;j<=num;j++) //和后面的作业比较{if(!jobs[j].visited) //还没完成（运行）{if(jobs[current].reach_time<jobs[pre].finish_time) //如果进程在上一个进程完成之前到达{if(jobs[j].excellent>jobs[current].excellent)current=j; //找出到达时间在上一个进程完成之前，优先权高的进程}else //如果进程是在上一个进程完成之后到达{if(jobs[j].reach_time<jobs[current].reach_time)current=j; //找出比较早到达的一个else if(jobs[j].reach_time==jobs[current].reach_time&&jobs[j].excellent>jobs[current].excellent) //如果同时到达current=j; //找出服务时间比较短的一个}}}return current; //返回当前进程
}
//高相应比优先
void HRRF(){int i,j;double sum1=0; //总的等待时间 double sum2=0; //总的周转时间 double sum3=0; //总的带权周转时间 printf("高响应比优先调度算法: \n");int pre=1;jobs[1].finish_time=0;for(i=1;i<=num;i++){int index=findNextHRRF(pre); printf("第%d个作业",index);printf("到达时间 --%d,服务时间--%d\n",jobs[index].reach_time,jobs[index].need_time);printf("本作业正在运行...........\n");_sleep(1);printf("运行完毕\n");if(i==1){jobs[index].start_time=jobs[index].reach_time;jobs[index].finish_time=jobs[index].start_time+jobs[index].need_time;jobs[index].tr_time=jobs[index].need_time;jobs[index].wtr_time=1.00;jobs[index].wait_time=0;}else{if(jobs[index].reach_time>jobs[pre].finish_time){jobs[index].wait_time=0;jobs[index].start_time=jobs[index].reach_time;}else{jobs[index].start_time= jobs[pre].finish_time;jobs[index].wait_time= jobs[pre].finish_time-jobs[index].reach_time;} jobs[index].finish_time=jobs[index].start_time+jobs[index].need_time;jobs[index].tr_time=jobs[index].finish_time-jobs[index].reach_time;jobs[index].wtr_time=(double)jobs[index].tr_time/jobs[index].need_time;}jobs[index].visited=true;pre=index;sum1+=jobs[index].wait_time;sum2+=jobs[index].tr_time;sum3+=jobs[index].wtr_time; printf("等待时间: %d 周转时间: %d 带权周转时间: %0.2f\n",jobs[index].wait_time,jobs[index].tr_time,jobs[index].wtr_time);}printf("--------所有作业调度完毕------\n");printf("平均等待时间: %.2f 平均周转时间: %.2f 平均带权周转时间: %.2f",sum1/num,sum2/num,sum3/num); initial_jobs_again();
}
//按照先来先服务并使用时间片轮转
vector<job> jobList; //jobList向量 int time_unit = 10;//时间片长度
void initial_job_List(){ //给向量初始化 for(int i=1;i<=num;i++) {jobList.push_back(jobs[i]);}
}
bool cmp(job a,job b)
{return a.reach_time<b.reach_time;
}
void RR(){double sum1=0; //总的等待时间 double sum2=0; //总的周转时间 double sum3=0; //总的带权周转时间 initial_job_List();queue<job>Ready; //就绪队列 sort(jobList.begin(),jobList.end(),cmp);int begin =(*jobList.begin()).reach_time;Ready.push(*jobList.begin());jobList.erase(jobList.begin());while(!jobList.empty()||!Ready.empty()){while(!jobList.empty()&&begin>=(*jobList.begin()).reach_time){ //有新作业到达，加入就绪队列Ready.push(*jobList.begin());jobList.erase(jobList.begin()); }if(Ready.front().finish_time + time_unit < Ready.front().need_time){ //时间片用完没运行完,加入队尾printf("%d 号作业执行了 %d\n",Ready.front().number,time_unit); Ready.front().finish_time += time_unit;begin += time_unit;while(!jobList.empty()&&begin>=(*jobList.begin()).reach_time){ //有新作业到达，加入就绪队列Ready.push(*jobList.begin());jobList.erase(jobList.begin()); }Ready.push(Ready.front());Ready.pop(); _sleep(1);}else{ //作业运行完 if(Ready.front().need_time - Ready.front().finish_time<time_unit){time_unit-=Ready.front().need_time - Ready.front().finish_time;}else{time_unit=10;}printf("%d 号作业执行了 %d\n",Ready.front().number,time_unit);begin += time_unit;Ready.front().finish_time = begin;Ready.front().wait_time = Ready.front().finish_time-Ready.front().reach_time-Ready.front().need_time;Ready.front().tr_time = Ready.front().finish_time - Ready.front().reach_time;Ready.front().wtr_time = (double)Ready.front().tr_time / Ready.front().need_time;sum1+=Ready.front().wait_time;sum2+=Ready.front().tr_time;sum3+=Ready.front().wtr_time;printf("执行完的作业是 %d 号作业，等待时间是 %d ,周转时间是 %d ,带权周转时间是 %.2f\n",Ready.front().number,Ready.front().wait_time,Ready.front().tr_time,Ready.front().wtr_time);//从就绪队列中移除作业Ready.pop();if(Ready.empty()&&!jobList.empty()){sort(jobList.begin(),jobList.end(),cmp);printf("找到当前最早的作业是: %d\n",(*jobList.begin()).number);begin = (*jobList.begin()).reach_time;} if(time_unit<10){time_unit=10;}_sleep(1); }}printf("--------所有作业调度完毕------\n");printf("平均等待时间: %.2f 平均周转时间: %.2f 平均带权周转时间: %.2f",sum1/num,sum2/num,sum3/num); initial_jobs_again();
}
int findNextHPF(job j[MAX_NUM], int length,int time ) {//优先值越低 表示优先权越高 // p是已经到达且拥有最高优先权的进程的下标 // q是没有到达的进程中拥有最早到达时间的进程的下标int i, p, q;int minReachTime,minPrivilege1;p = q = -1; minPrivilege1 = minReachTime = inf;for( i = 1; i <= length; i++ ) {if(!j[i].visited){ // 第一情况if( j[i].reach_time<=time && j[i].privilege<=minPrivilege1 ){ if(j[i].privilege==j[p].privilege){ //如果优先权一致 则按最早抵达时间 if(j[i].reach_time<j[p].reach_time){p=i;}}else{p = i;minPrivilege1 = j[i].privilege; }}// 第二种情况else if(j[i].reach_time>time && j[i].reach_time<=minReachTime ){q = i; minReachTime = j[i].reach_time; }} }// p为-1时,代表在time时刻还没进程到达,此时选择下一个最早到达的进程qif( p != -1 ) return p;return q;
}
//优先权高者优先
void HPF(){int i,j;double sum1=0; //总的等待时间 double sum2=0; //总的周转时间 double sum3=0; //总的带权周转时间 int finish=inf; //当前完成时间for(i=1;i<=num;i++){finish=min(finish,jobs[i].reach_time);}printf("优先权高者优先服务(非抢占式): \n");for(i=1;i<=num;i++){int index=findNextHPF(jobs,num,finish);printf("第%d个作业",index);printf("到达时间 --%d,服务时间--%d\n",jobs[index].reach_time,jobs[index].need_time);printf("本作业正在运行...........\n");_sleep(1);printf("运行完毕\n");if(jobs[index].reach_time<=finish){jobs[index].wait_time=finish-jobs[index].reach_time;jobs[index].start_time=finish;}else{jobs[index].start_time=jobs[index].reach_time;jobs[index].wait_time=0;}jobs[index].finish_time=jobs[index].start_time+jobs[index].need_time;jobs[index].tr_time=jobs[index].finish_time-jobs[index].reach_time;jobs[index].wtr_time=(double)jobs[index].tr_time/jobs[index].need_time;jobs[index].visited=true;sum1+=jobs[index].wait_time;sum2+=jobs[index].tr_time;sum3+=jobs[index].wtr_time; finish=jobs[index].finish_time;printf("等待时间: %d 周转时间: %d 带权周转时间: %0.2f\n",jobs[index].wait_time,jobs[index].tr_time,jobs[index].wtr_time);}printf("--------所有作业调度完毕------\n");printf("平均等待时间: %.2f 平均周转时间: %.2f 平均带权周转时间: %.2f",sum1/num,sum2/num,sum3/num); initial_jobs_again();
}/主函数
int main(){system("color 3f"); //改变颜色 initial_jobs(); //初始化所有作业信息 read_Jobdata(); //读取数据文件 int choice = 1;while(choice != 0){printf("\n请选择其中一种调度算法:\n");printf("(1)先来先服务FCFS\n");printf("(2)短作业优先SJF\n");printf("(3)高相应比优先HRRF\n");printf("(4)优先权高者优先HPF\n");printf("(5)时间片轮转RR\n");printf("(0)退出\n");printf("请输入一个数字：");scanf("%d",&choice);switch (choice){case 1:FCFS();break;case 2:SJF();break;case 3:HRRF();break;case 4:HPF();break;case 5:RR();break;case 0:printf("退出程序\n");break;}}_keygo();
}实验结果
| 算法 | 作业 | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 平均 |
| FCFS | 完成时间 | 850 | 880 | 910 | 930 | 945 | 710 | 885 |
|
| 等待时间 | 0 | 35 | 55 | 50 | 75 | 0 | 60 | 44.29 | |
| 周转时间 | 50 | 65 | 80 | 95 | 100 | 10 | 65 | 66.43 | |
| 带权周转时间 | 1.00 | 2.17 | 3.20 | 4.75 | 6.67 | 1.00 | 13.00 | 4.54 | |
| SJF | 完成时间 | 850 | 945 | 915 | 890 | 870 | 710 | 855 |
|
| 等待时间 | 0 | 100 | 60 | 35 | 10 | 0 | 30 | 33.57 | |
| 周转时间 | 50 | 130 | 85 | 55 | 25 | 10 | 35 | 55.71 | |
| 带权周转时间 | 1.00 | 4.33 | 3.40 | 2.75 | 1.67 | 1.00 | 7.00 | 3.02 | |
| HRRF | 完成时间 | 850 | 885 | 945 | 930 | 900 | 710 | 855 |
|
| 等待时间 | 0 | 40 | 90 | 65 | 40 | 0 | 30 | 37.86 | |
| 周转时间 | 50 | 70 | 115 | 85 | 55 | 10 | 35 | 60.00 | |
| 带权周转时间 | 1.00 | 2.33 | 4.60 | 4.25 | 3.67 | 1.00 | 7.00 | 3.41 | |
| HPF | 完成时间 | 850 | 885 | 910 | 930 | 945 | 710 | 855 |
|
| 等待时间 | 0 | 40 | 55 | 75 | 85 | 0 | 30 | 40.71 | |
| 周转时间 | 50 | 70 | 80 | 95 | 100 | 10 | 35 | 62.86 | |
| 带权周转时间 | 1.00 | 2.33 | 3.20 | 4.75 | 6.67 | 1.00 | 7.00 | 3.71 | |
| RR | 完成时间 | 940 | 915 | 945 | 925 | 930 | 710 | 835 |
|
| 等待时间 | 90 | 70 | 90 | 70 | 70 | 0 | 10 | 57.14 | |
| 周转时间 | 140 | 100 | 115 | 90 | 85 | 10 | 15 | 79.29 | |
| 带权周转时间 | 2.80 | 3.33 | 4.60 | 4.50 | 5.67 | 1.00 | 3.00 | 3.56 |
菜单界面
FCFS
SJF
HRRF
HPF
RR
