sch_17-11.zip_进程调度

#include<stdio.h> #include<stdlib.h> #include<sys/types.h> #include<unistd.h> #include<pthread.h> #include<time.h> //#include<iostream> #define Thread_Num 5 //int threadnum; //using namespace std; pthread_mutex_t Device_mutex ; //Virtual PCB of threads struct VirtualPCB { int tid; int priority; int finishtime; int runtime; int arrivetime; int visited; int tempruntime; }TCB[Thread_Num]; //Function to initial virtual PCB void t_init() { int n; srand(time(NULL)); for(n =0;n<Thread_Num;n++) { TCB[n].tid = n + 1;//用线程创建序号作为虚拟进程id //用随机数随机产生虚拟PCB的值 // TCB[n].priority = 1 + rand()%19; //TCB[n].priority = n+1; printf("input arrivetime runtime priority\n"); // TCB[n].runtime = 1 + rand()%19; //TCB[n].runtime = n+1; scanf("%d%d%d",&TCB[n].arrivetime,&TCB[n].runtime,&TCB[n].priority); //scanf("%d",&TCB[n].arrivetime); // TCB[n].arrivetime = 0;//模拟时，默认进程按创建顺序依次在0时刻到达 TCB[n].finishtime = 0; TCB[n].visited =0; TCB[n].tempruntime = TCB[n].runtime; } } //Threads run function void *t_print(void *arg) { int n = *(int *)arg;//get argument while(1) { pthread_mutex_lock(&Device_mutex); printf("Thread_%-2d: ",n); printf("tid:%-2d arrivetime:%-2d runtime:%-2d priority:%-2d \n",TCB[n-1].tid,TCB[n-1].arrivetime,TCB[n-1].runtime,TCB[n-1].priority); pthread_mutex_unlock(&Device_mutex); sleep(1); break; } //printf("Error %d\n",n); pthread_exit(0); } //First come first service schedule function void FCFS() { printf("-----------FCFS:\n"); int i,j; //int start = 0; float nowtime = 0; float avwait = 0; float awwait=0; for(j=0;j<Thread_Num;j++) { if(TCB[j].visited==0){ TCB[j].finishtime = nowtime + TCB[j].runtime; printf("Thread: %-2d Arrivetime: %-3d finishtime: %-2d\n",TCB[j].tid,TCB[j].arrivetime,TCB[j].finishtime); nowtime=nowtime + TCB[j].runtime; TCB[j].visited=1; } avwait = avwait+(TCB[j].finishtime-TCB[j].arrivetime); awwait=awwait+(TCB[j].finishtime-TCB[j].arrivetime)/(float)TCB[j].runtime; } avwait = avwait / (float)Thread_Num; awwait = awwait / (float)Thread_Num; printf("Average waitting time : %f\n",avwait); printf("Average waitting time with weight : %f\n",awwait); } //Shortest job first schedule function void SJF() { } void Priority() { } void HRRN() { } //Main thread execute function to create 20 children threads void *Children() { int ret[Thread_Num]; // t_init(); pthread_t tid[Thread_Num]; pthread_mutex_init(&Device_mutex,NULL); int i,j; for(i=0;i<Thread_Num;i++) { int k =i+1; ret[i] = pthread_create(&tid[i],NULL,&t_print, &k); if(ret[i] == 0) { sleep(1); } else{ printf("Thread_%-2d failed!\n",i+1); } } for(j=0;j<Thread_Num;j++) pthread_join (tid[i], NULL); pthread_mutex_destroy(&Device_mutex); pthread_exit(0); } int main() { int ret1; int c; t_init(); // printf("please input the thread number\n"); // scanf("%d",&Thread_Num); pthread_t tid1;//Declare main thread ret1 = pthread_create(&tid1,NULL,&Children,NULL);//Create main thread if(ret1 == 0) { printf("Main Thread ok!\n"); sleep(Thread_Num); } else{ printf("Thread failed!\n"); } FCFS(); SJF(); Priority(); HRRN(); return 0; }