進(jìn)程調(diào)度模擬程序

2019-11-17 04:59:46

字體：大中小

供稿：網(wǎng)友

   我們課程設(shè)計(jì)，我選擇了一個(gè)進(jìn)程調(diào)度模擬，希望大家給看看，多提意見，好久沒來(lái)發(fā)帖子了。
#include<iostream.h>
#include<stdlib.h>
#include<time.h>
#include<stdio.h>
#include<string.h>const int MAXCOMMANDLEN =50;         /////////////////////////////////////////////////////////////////////////////////////
//
//         PROCESS
//
/////////////////////////////////////////////////////////////////////////////////////
class Process                          //進(jìn)程類
{
friend class CPU;
protected:
static int init_ID;     //隨機(jī)進(jìn)程ID
    int ID;        //進(jìn)程ID
char runText[MAXCOMMANDLEN];  //進(jìn)程指令數(shù)組
int ip;        //進(jìn)程指令指針，保存進(jìn)程指令執(zhí)行到的具體位置
bool ISuseSource;     //此進(jìn)程是否使用資源，ture:使用中 false : 未使用
bool ISblocked;      //此進(jìn)程是否被阻塞 ture:阻塞 false :未阻塞
int unitTime;      //進(jìn)程單位被cpu執(zhí)行時(shí)間, 默認(rèn) 1
int blockTime;      //進(jìn)程被阻塞時(shí)間
public:
static void RandID();    //隨機(jī)生成進(jìn)程ID
Process();
int getID();
int getIP();
void setIP(int);
void Runed();      //進(jìn)程被cpu執(zhí)行
int getUnittime();     //得到進(jìn)程單位執(zhí)行時(shí)間
int getBlcoktime();     //得到進(jìn)程阻塞時(shí)間
void setBlocktime(int);    //設(shè)置進(jìn)程阻塞時(shí)間
void setUnittime(int);    //設(shè)置進(jìn)程單位執(zhí)行時(shí)間
char getResult(int);    //得到進(jìn)程執(zhí)行結(jié)果
char* getRuntext();     //得到進(jìn)程執(zhí)行的指令
void setBlockstate(bool);   //設(shè)置阻塞狀態(tài)
bool getBlockstate();
bool getISusesource();    //得到資源的狀態(tài) 使用未使用
void setISusesource(bool);   //設(shè)置資源的使用狀態(tài)
};int Process::init_ID;void Process::RandID()
{
srand( (unsigned)time( NULL ) );
init_ID=rand();
}
Process::Process()
{
ID=init_ID++;
int commandLen;
IP=0; cout<<"Please input the text which process runed by CPU [#command#] :>/ ";
cin>>runText;
if( (commandLen=strlen(runText) ) > MAXCOMMANDLEN )
  exit(0);

runText[commandLen]='#';     // 指令結(jié)束標(biāo)志 '#'
runText[commandLen+1]='';
ISuseSource=false;
ISblocked=false;
unitTime=1;
blockTime=0;
}
void Process::Runed()

int Process::getID()
{
return ID;
}int Process::getIP()
{
return IP;
}void Process::setIP(int ip)
bool Process::getISusesource()
{
return ISuseSource;
}void Process::setISusesource(bool s)
char* Process::getRuntext()
{
return runText;
}int Process::getUnittime()
{
return unitTime;
}
int Process::getBlcoktime()
{
return blockTime;
}void Process::setBlocktime(int BT)
void Process::setUnittime(int UT)
void Process::setBlockstate(bool state)
bool Process::getBlockstate()
{
return ISblocked;
}char Process::getResult(int k)
{
  return runText[k];
}/////////////////////////////////////////////////////////////////////////////////////
//
//         SOURCE
//
/////////////////////////////////////////////////////////////////////////////////////class Source        //資源類
{
protected:
int ID;         //資源 ID
bool state;        //資源狀態(tài) true : 未被進(jìn)程占有 false : 已被占有
int pro_ID;        //使用資源的進(jìn)程id
Process *pro;       //使用資源的進(jìn)程指針
int time;        //進(jìn)程使用資源的時(shí)間
public:
Source(int);
bool getState();      //得到進(jìn)程狀態(tài)
void setState(bool);     //設(shè)置進(jìn)程狀態(tài)
void setTime(int);      //設(shè)置進(jìn)程使用資源的時(shí)間
void setPro(Process *);     //設(shè)置使用該資源的進(jìn)程
int getID();       //得到資源id
int getPorID();       //得到使用資源的進(jìn)程id
void setProID(int);      //設(shè)置使用資源的進(jìn)程id
void runned();       //資源被cpu調(diào)用
};Source::Source(int id)
void Source::setProID(int id)
void Source::setTime(int t)
void Source::setState(bool s)
bool Source::getState()
{
return state;
}void Source::setPro(Process *p)
void Source::runned()
{
if(time>0)
{
  cout<<"( Source :"<<ID<<")";

  time--;
}
if(time<=0)          //進(jìn)程使用完資源釋放資源，使用資源的時(shí)間到
{
  pro->setISusesource(false);
  int ip=pro->getIP();
  pro->setIP(++ip);
  Source::setState(true);
  cout<<endl<<"The process "<<pro->getID()<<" relase the source!"<<endl;
  pro=NULL;
}
}/////////////////////////////////////////////////////////////////////////////////////
//
//         CPU
//
/////////////////////////////////////////////////////////////////////////////////////typedef strUCt Block     //阻塞隊(duì)列結(jié)構(gòu)
{
Process *p_BlockProcess;   //被阻塞的進(jìn)程隊(duì)列
int index;       //被阻塞的進(jìn)程在就緒隊(duì)列中的索引（位置）
}Block;class CPU
{
protected:
Process *p_Process;     //進(jìn)程隊(duì)列
Process **pp_Process;    //進(jìn)程就緒隊(duì)列
Block *blockQueue ;    //進(jìn)程阻塞隊(duì)列
Source *p_Source;     //資源指針
int numOfprocess;     //進(jìn)程數(shù)量
int numOfblock;      //被阻塞的進(jìn)程數(shù)
int PC;        //程序計(jì)數(shù)器
int allTime;      //cpu運(yùn)行的總時(shí)間
public :
CPU(int);
void Run();       //cpu運(yùn)行進(jìn)程
bool _IC(Process&);     //虛擬IC,進(jìn)行進(jìn)程指令翻譯
void useSource(Process&);   //進(jìn)程申請(qǐng)資源
void blockProcess(Process&);        //阻塞進(jìn)程
void releaseBlockPro();    //釋放阻塞進(jìn)程
int getAlltime();     //得到進(jìn)程運(yùn)行的總時(shí)間
void displayPro();     //顯示進(jìn)程的基本信息，id,指令,運(yùn)行時(shí)間等
void blockTimeADD();    //阻塞時(shí)間加1
};CPU::CPU(int num)
{
  p_Source=new Source(379857);
  numOfprocess=num;
  numOfblock=0;
  allTime=0;
  p_Process=new Process[numOfprocess];
  pp_Process=new Process*[numOfprocess];
  blockQueue=new Block[numOfprocess];
  for(int i=0;i<numOfprocess;i++)

}int CPU::getAlltime()
{
return allTime;
}void CPU::displayPro()
{
for(int i=0;i<numOfprocess;i++)
{
  cout<<" Process ID : "<<p_Process[i].getID()<<endl;

  cout<<"   text of runned :"<<p_Process[i].getRuntext()<<endl;
}
}void CPU::Run()
{
int numPro=numOfprocess; do
{
  for(int num=0;num < numOfprocess;num++)
  {
   if(!pp_Process[num])      //假如該指針為空，說(shuō)明該進(jìn)程不在就緒隊(duì)列中
    continue;   for(int t=0;t<p_Process[num].getUnittime();t++)
   {
    PC=p_Process[num].getIP();
    if(_IC(p_Process[num]))
    {
     if(t==0)
      cout<<"the process ["<<p_Process[num].getID()<<"] runed : ";
     if(!p_Process[num].getISusesource())

     else
     {
       p_Source->runned();
       if( p_Source->getState() && numOfblock>0 )     //釋放阻塞進(jìn)程

     }
    }
    else
    {
     if(!p_Process[num].getBlockstate())
     {
      numPro--;
         pp_Process[num]=NULL;
      continue;
     }
     break;
    }
    allTime++;
    if(numOfblock>0)
     blockTimeADD();
   }//end for t...
   if( p_Process[num].getUnittime() )
    p_Process[num].setUnittime(1);
   cout<<endl;
  }//end for num... }while(numPro);
}bool CPU::_IC(Process &p)
{
//對(duì)進(jìn)程中的指令進(jìn)行翻譯
char resultRunned;

resultRunned=p.getResult(PC);
if(resultRunned=='#')
  return false;
else
{
  if(resultRunned==' )      //申請(qǐng)資源指令
  {
   PC++;
   p.setIP(PC);
   resultRunned=p.getResult(PC);
   if( resultRunned >='1' && resultRunned <='9' )
   {
    if(p_Source->getState())
    {
     //資源未被使用則使用資源
     useSource(p);

     cout<<"The process "<<p.getID()<<" take up the source!"<<endl;
    }
    else
    {
     //資源已被使用則阻塞進(jìn)程
     blockProcess(p);
     cout<<"The process "<<p.getID()<<" is blocked !"<<endl;
     return false;     }
   }
   else
   {
    //' 后跟的不是數(shù)字，則語(yǔ)法錯(cuò)誤
    cout<<"The process ["<<p.getID()<<"] runned fail ! It has been stopped! "<<endl;
    return false;
   }
  } }
  return true;
}void CPU::blockTimeADD()
{
for(int i=0;i<numOfblock;i++)
{
  int BT=blockQueue[i].p_BlockProcess->getBlcoktime();
  blockQueue[i].p_BlockProcess->setBlocktime(++BT);
}
}void CPU::useSource(Process& p)
{
p.setISusesource(true);
p_Source->setState(false);
p_Source->setProID(p.getID());
p_Source->setTime(p.getResult(PC)-'0');
p_Source->setPro(&p);}void CPU::blockProcess(Process& p)
{
int tempIndex=numOfprocess-( Process::init_ID-p.getID() );
blockQueue[numOfblock].p_BlockProcess=&p;
blockQueue[numOfblock].index=tempIndex;
numOfblock++;
int ip=p.getIP();
p.setIP(--ip);
p.setBlockstate(true);
p.setBlocktime(1);
p.setUnittime(0);
pp_Process[tempIndex]=NULL;}void CPU::releaseBlockPro()
{
//釋放阻塞隊(duì)列的第一個(gè)進(jìn)程，因?yàn)樗枞麜r(shí)間最長(zhǎng)
pp_Process[blockQueue[0].index]=blockQueue[0].p_BlockProcess;
blockQueue[0].index=-1;
blockQueue[0].p_BlockProcess->setBlockstate(false);
blockQueue[0].p_BlockProcess->setUnittime( blockQueue[0].p_BlockProcess->getBlcoktime() );
blockQueue[0].p_BlockProcess->setBlockstate(0);
blockQueue[0].p_BlockProcess=NULL;
numOfblock--;

//阻塞隊(duì)列中的其他進(jìn)程向前移動(dòng)一個(gè)位置
for(int i=0;i<numOfblock;i++)

}
/////////////////////////////////////////////////////////////////////////////////////
//
//        The main progress
//
/////////////////////////////////////////////////////////////////////////////////////
void main()
{
int num;
cout<<" ********************************************************"<<endl
  <<endl;
cout<<"              The virtual CPU    the process runned           "<<endl

  <<endl;
cout<<" *******************************************************"<<endl
  <<endl;

cout<<"initialize the information of processes "<<endl; cout<<"Please input the number of process [#command#] >/ "; try

catch(int)
{
  cout<<"You input the numbers of process is error !"<<endl;
  exit(1);
} Process::RandID();   // 隨機(jī)生成第一個(gè)進(jìn)程的ID,以后生成的進(jìn)程ID順序加1
CPU virtualCPU(num);

cout<<"Pocesses runed by CPU "<<endl;
virtualCPU.Run();

cout<<"Processes runned over ! "<<endl;
cout<<" ********************************************************"<<endl
  <<endl;
cout<<" The time which processes runned by CPU : "<<virtualCPU.getAlltime()<<endl
  <<endl;
virtualCPU.displayPro();
cout<<" *******************************************************"<<endl
  <<endl;
}這里沒有任何的API調(diào)用只是模擬，我給進(jìn)程設(shè)定了自己的語(yǔ)法，輸入一般的字符cpu調(diào)用時(shí)只是正常輸出，假如碰到' 表示該進(jìn)程要調(diào)用系統(tǒng)資源后面必須跟一個(gè)數(shù)字表示占有的時(shí)間，假如資源閑置則占有資源否則阻塞，等資源釋放在占有資源。進(jìn)程的調(diào)用算法我采用的是時(shí)間片輪轉(zhuǎn)算法并有所改進(jìn)，當(dāng)某個(gè)進(jìn)程從阻塞隊(duì)列釋放后，他將把以前因?yàn)榈却Y源而被浪費(fèi)的時(shí)間補(bǔ)回來(lái)。
希望大家多提意見

上一篇：Visual C++ 實(shí)現(xiàn)數(shù)字化圖像的分割

下一篇：C #中的幾個(gè)線程同步對(duì)象方法