cpudd.java

java实现的CPU调度算法。。算法比较通俗

c.tcpuinfo.setText("挂起队列中没有找到你想要解挂的名字为"+name+"的进程！");
}
else{
Temp = new Pcb(name,Compare_b.GetTime(),Compare_b.GetPriority());
Temp.SetState("就绪");
Insert(Temp);
InitMemory(Temp);// init the momery;
c.tcpuinfo.setText("已经将名称为"+name+"的进程解挂并放入就绪队列中！");
Compare_f.next = Compare_b.next;
k--;
} 
}
}
public static void InitMem(){
MemTable = new memory(); 
MemTable.Setmem_beg(0);
MemTable.Setmem_size(100);
MemTable.Setmem_state(0);
} 
public boolean InitMemory(Pcb temp){
memory mem_temp,last,now;
last = MemTable; 
mem_temp = new memory(temp.GetName(),temp.Getmem_size()); 
boolean flag = true; 
if(mem_temp.Getmem_size() > 100 ){
c.tcpuinfo.setText(mem_temp.GetPcd_name()+"is too big");
flag = false;
}
if(MemTable == null){ 
return flag;
}

if(mem_temp.Getmem_size() + nowsize > 100){
c.tcpuinfo.setText("memory has been full please wait");
flag = false;
} 

if(MemTable.Getmem_state() == 0){// if the first is empty;
if(MemTable.Getmem_size() > mem_temp.Getmem_size()){
mem_temp.next = MemTable;
mem_temp.Setmem_beg( last.Getmem_beg() );
mem_temp.Setmem_state(1);
MemTable.Setmem_beg(mem_temp.Getmem_beg() + mem_temp.Getmem_size());
MemTable.Setmem_size( MemTable.Getmem_size()-mem_temp.Getmem_size() ); 
MemTable = mem_temp;
nowsize += mem_temp.Getmem_size();
return flag;
}
if (MemTable.Getmem_size() == mem_temp.Getmem_size()){
// MemTable.SetPcd_name(mem_temp.GetPcd_name());
mem_temp = MemTable;
mem_temp.Setmem_state(1);
mem_temp.next = MemTable; 
nowsize += mem_temp.Getmem_size();
return flag;
}
}
// begin obtain the other;
if(last != null){
now = last.next; 
while(now != null){// search the teble for sutible memory;
if(now.Getmem_state() == 0){// if the first is empty;
if(now.Getmem_size() > mem_temp.Getmem_size()){
mem_temp.next = now;
mem_temp.Setmem_beg( now.Getmem_beg() );
mem_temp.Setmem_state(1);
now.Setmem_beg(mem_temp.Getmem_beg() + mem_temp.Getmem_size());
now.Setmem_size( now.Getmem_size()-mem_temp.Getmem_size() );
last.next = mem_temp;
nowsize += mem_temp.Getmem_size(); 
return flag;
}
else if (now.Getmem_size() == mem_temp.Getmem_size()){
now.SetPcd_name(mem_temp.GetPcd_name());
mem_temp = now;
mem_temp.Setmem_state(1);
last.next = mem_temp;
nowsize += mem_temp.Getmem_size(); 
return flag;
}
}
last = now;
// if(last != null){
now = now.next; 
// }
}
}
return flag;
}


public void ReleaseMem(Pcb Temp){ 
memory mem_temp,last,now;
mem_temp = new memory(Temp.GetName(),Temp.Getmem_size());
if(MemTable == null){
c.tcpuinfo.setText("无内存可释放");
// return false;
}
last = MemTable;
now = last.next;
if (MemTable.GetPcd_name() == mem_temp.GetPcd_name()){//如果第一个就是要释放的分区;
MemTable.Setmem_state(0);
MemTable.SetPcd_name(null);
if(now != null && now.Getmem_state() == 0 ){//如果后邻接分区也是空闲的;
MemTable.Setmem_size(MemTable.Getmem_size() + now.Getmem_size());
MemTable.SetPcd_name(null);
nowsize -= mem_temp.Getmem_size();
MemTable.next = null;
// return true;
} 
}
while (now != null){//在链表中寻找要释放的分区;
if(now.GetPcd_name() == mem_temp.GetPcd_name()){//找到;
nowsize -= mem_temp.Getmem_size();
now.Setmem_state(0);
if(now.next != null && now.next.Getmem_state() == 0){//查看后面相邻结点是否有空闲;
last.next = now.next;
now.next.Setmem_beg(now.Getmem_beg());
now.next.Setmem_size(now.Getmem_size() + now.next.Getmem_size());
now = last.next;
now.SetPcd_name(null);
} 
if(last.Getmem_state() == 0){//查看前面相邻结点是否有空闲;
last.next = now.next;
last.Setmem_size(last.Getmem_size() + now.Getmem_size());
last.SetPcd_name(null);
now = last.next;
// now.SetPcd_name(null);
} 
}
last = now;
now = now.next; 
} 
}


public void Schedule(){
c.tcpuinfo.setText("对进程进行一轮调度！");
Pcb Temp;
Temp = ReadyHead;
while(Temp != null){
Temp.SubTime();
if(Temp.GetTime() == 0){
c.tcpuinfo.setText("就绪队列中名为"+Temp.GetName()+"的进程已经运行完！");
Delete(Temp);
n--;
if(WaitHead != null){
c.tcpuinfo.setText("从后备队列中添加新进程到就绪队列中！");
Insert();
n++;
}
}
if(Temp.GetPriority() != 0){
Temp.SubPriority();
}
Temp = Temp.next;
}
}
//输出ＲＥＡＤＹ队列信息;
public void PrintCpuinfo_ready(){ 
Pcb Temp;
int row = 0;
Temp = ReadyHead; 
c.Lready.removeAll();
while(Temp != null && row < 6){
String str = " " + "name:" + Temp.GetName() + "time" + Temp.GetTime() + "priority" + Temp.GetPriority();

c.Lready.add(str);
Temp = Temp.next;
row++;
}
}
//output the wait;
public void PrintCpuinfo_wait(){
Pcb Temp;
int row = 0;
Temp = WaitHead; 
c.Lwaiting.removeAll();
PrintCpuinfo_ready();
while(Temp != null && row < 6){
String str = " " + "name:" + Temp.GetName() + "time" + Temp.GetTime() + "priority" + Temp.GetPriority();
//System.out.println(str);
c.Lwaiting.add(str);
Temp = Temp.next;
row++; 
}
}
//out put the memory;
public void PrintMemoryinfo(){
memory Temp,Temp1; 
Temp = MemTable;
Temp1 = MemTable;
c.L_memory_gra.removeAll();
c.L_memory_table.removeAll();
while(Temp != null /*&& Temp.Getmem_state() == 1*/){
String str = " " + "name:" + Temp.GetPcd_name() + "begin" + Temp.Getmem_beg() + "size" + Temp.Getmem_size(); 
//if(Temp.Getmem_state() == 1){
c.L_memory_gra.add(str);
//}
Temp = Temp.next; 
} 
while(Temp1 != null/* && Temp1.Getmem_state() == 0*/){
String str1 = "begin" + Temp1.Getmem_beg() + "size" + Temp1.Getmem_size() + "状态" +Temp1.Getmem_state(); 
if(Temp1.Getmem_state() == 0){
c.L_memory_table.add(str1);
}
Temp1 = Temp1.next; 
}
}
public void PrintCpuinfo_all(){
Pcb Temp;
int row = 0;
Temp = SuspendHead;
c.Lready.removeAll();
c.Lwaiting.removeAll();
PrintCpuinfo_ready();
PrintCpuinfo_wait();
while(Temp != null && row < 6){
String str = " " + "name:" + Temp.GetName() + "time" + Temp.GetTime() + "priority" + Temp.GetPriority();
//System.out.println(str);
c.Lsuspend.add(str);
Temp = Temp.next;
row++; 
}
}
//删除ＲＥＡＤＹ中被替换的结点;
public void Delete(Pcb Temp){
ReleaseMem(Temp);
Pcb Compare_f;
Pcb Compare_b;
Compare_b = ReadyHead;
Compare_f = ReadyHead;
if(ReadyHead == Temp){
ReadyHead = ReadyHead.next;
}
else{
while(Compare_b != null && Compare_b != Temp){
Compare_f = Compare_b;
Compare_b = Compare_b.next;
}
Compare_f.next = Compare_b.next;
}
//System.out.println(Temp.GetName());
}
//插入新结点;
public void Insert(){
Pcb Temp;
Temp = WaitHead;
Temp.SetState("就绪");
WaitHead = WaitHead.next;
Pcb Compare_f;
Pcb Compare_b;
Compare_b = ReadyHead;
Compare_f = ReadyHead;
if(Temp.GetPriority() > ReadyHead.GetPriority() ){
Temp.next = ReadyHead;
ReadyHead = Temp;
}
else{
while(Compare_b != null && Compare_b.GetPriority() >= Temp.GetPriority() ){
Compare_f = Compare_b;
Compare_b =Compare_b.next;
}
Compare_f.next = Temp;
Temp.next = Compare_b;
}
String str = " " + "name:" + Temp.GetName() + "time" + Temp.GetTime() + "priority" + Temp.GetPriority();
System.out.println(str);
m--;
}
//插入新结点；
public void Insert(Pcb Temp){
Pcb R_Temp;
Pcb Min;
Pcb Compare_f;
Pcb Compare_b;
Pcb comp;
Compare_b=ReadyHead;
Compare_f=ReadyHead;
R_Temp=ReadyHead;
Min=ReadyHead; 
if(n>=5){
while(R_Temp != null){
if(Min.GetPriority() > R_Temp.GetPriority())
Min=R_Temp;
R_Temp=R_Temp.next;
}
comp=new Pcb(Min.GetName(),Min.GetTime(),Min.GetPriority());
n--;
// String str = "comp" + "name:" + comp.GetName() + "time" + comp.GetTime() + "priority" + comp.GetPriority();
BuildWaitingQueue(comp.GetName(),comp.GetTime(),comp.GetPriority());
m++;
Delete(Min);
} 

if(Temp.GetPriority() > ReadyHead.GetPriority()){
Temp.next = ReadyHead;
ReadyHead = Temp;
n++;
}

else{
while(Compare_b != null && Compare_b.GetPriority() >= Temp.GetPriority()){
Compare_f=Compare_b;
Compare_b=Compare_b.next;
}
Compare_f.next=Temp;
Temp.next = Compare_b;
n++;
}
}
String GetSuspendName(){
int index = c.Lready.getSelectedIndex();
String a = c.Lready.getItem(index);
c.Lready.remove(index);
System.out.println(a);
String b = a.substring(6, 8);
System.out.println(b);
return b;
}
String GetReleaseSuspendName(){
int index = c.Lsuspend.getSelectedIndex();
String a = c.Lsuspend.getItem(index);
c.Lsuspend.remove(index);
System.out.println(a);
String b = a.substring(6, 8);
System.out.println(b);
return b;
}

public void actionPerformed(ActionEvent e){
if(e.getSource() == c.Bgetp_r){
String name;
int time;
int priority;
int size;
name = c.tp_name.getText().trim();
String t = c.tp_time.getText().trim();
String p = c.tp_priority.getText().trim();
String s = c.tp_memory_size.getText().trim();
c.tp_name.setText("");
c.tp_time.setText("");
c.tp_priority.setText("");
c.tp_memory_size.setText("");
time = Integer.parseInt(t);
priority = Integer.parseInt(p);
size = Integer.parseInt(s);
if(ReadyNum < 6){
Pcb Temp = new Pcb(name, time, priority, "就绪", size);
boolean flag = InitMemory(Temp);
if(flag == true){
BuildReadyQueue(name,time,priority,"就绪",size);
PrintCpuinfo_ready();
PrintMemoryinfo();
ReadyNum++;
}
else
c.tcpuinfo.setText("内存满");
}
else{
if(WaitNum < 6){
BuildWaitingQueue(name,time,priority);
PrintCpuinfo_wait();
WaitNum++;
}
} 
}
if(e.getSource() == c.BCpuscheduler){
Schedule();
PrintCpuinfo_wait();
PrintMemoryinfo();
}
if(e.getSource() == c.BgetP_s){ 
String name = GetSuspendName();
BuilidSuspendQueue(name);
PrintCpuinfo_all();
PrintMemoryinfo();
}
if(e.getSource() == c.Bgetp_s_r){
String name = GetReleaseSuspendName();
GetSuspendToReady(name);
PrintCpuinfo_all();
PrintMemoryinfo();
}
}

public static void main(String arg[]){
InitMem();
c.display();
}
}