用java实现操作系统进程调度问题 pcb rq bq

2024-02-07 11:18

本文主要是介绍用java实现操作系统进程调度问题 pcb rq bq,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

用java实现操作系统进程调度问题
pcb.java   main.java readyqueue,java blocked.java

package Process;
/*
进程就绪队列:fifo,实现进程调度,处理器从就绪队列选择进程,
是进程从就绪态转为运行态,
数据结构:队列,(用链式存储实现)
只允许在头部删除,在尾部插入队列:另一种被限制的线性表
数据结构-逻辑结构:线性结构物理结构:顺序,链式队列:使用固定的一端插入元素,固定的一段删除元素只允许在表的前端(front)进行删除操作,只允许在表的后端(rear)进行插入操作队尾:进行插入操作的一段队售:进行删除操作的一端空队列:队列中没有任何的数据元素*/public class readyQueue<T> {private class Node{//节点n内部类,用于表示链式存储队列中的每个节点private T data;//节点的数据private Node next;//保存指向下一个节点的引用public Node(){}//构造函数,初始化public Node(T data,Node next){this.data=data;this.next=next;//构造函数,初始化}}/*就绪队列的属性*/private Node front;//保存就绪队列的头节点,即下一个会被处理机调度的进程,private Node rear;//保存就绪队列的伪结点,即就绪队列中新进来的进程都在这里插入private int size;//保存目前进程就绪队列中的进程数目/*就绪队列的方法*///1创建一个空的进程就绪队列,没有任何进程处于就绪状态public readyQueue(){//构造函数,初始化front=null;rear=null;size=0;}//2创建一个非空的就绪队列,以一个指定的进程来创建进程就绪队列public readyQueue(T element){front=new Node(element,null);rear=front;size=1;}//3返回目前进程就绪队列中进程的个数,,处于就绪状态进程的个数public int getSize(){return size;}//4返回进程就绪队列中的最后一个进程,即处于尾部的进程的数据public T getData(){return rear.data;}//5判断进程就绪队列是否为空public boolean isEmpty(){return size==0;}//6清空进程就绪队列public void clear(){front=null;rear=null;size=0;}//7将进程就绪队列中的所有进程的信息打印处理public String toString(){if(isEmpty())return "[]";else{StringBuilder sb=new StringBuilder("[");Node current=front;for(int i=0;i<size&¤t!=null;i++){sb.append(current.data.toString()+",");current=current.next;}sb.append("]");return  sb.toString();}}//8进程就绪队列从首部移除元素,即处于就绪队列头部的进程由就绪态转为运行态public T removeFromFront(){if(isEmpty()){throw new RuntimeException("就绪队列为空,无法从就绪队列中移除就绪进程,");}else{Node del=front;front=del.next;T value=del.data;del=null;size--;return value;}}//9向就绪队列的尾部插入进程,这些进程可能是timeout的进程,也可能是♥调度来的进程public void addAtRear(T element){if(front==null){front=new Node(element,null);rear=front;}else{Node newNode=new Node(element,null);rear.next=newNode;rear=newNode;}size++;}
}

package Process;
/*
2018/05/23:pcb进程控制块类,操作系统利用进程控制块,实现对进程的调度*/
public class pcb {private int id;//进程标识符private int status;//进程状态(1表示运行态,2表示就绪态,3表示阻塞态)//保护进程现场信息private int ax,bx,cx,dx;//通用寄存器ax,bx,cx,dx的内容private int pc;//程序计数器内容private int psw;//程序状态字内容private int next;//下一个pcb的位置private int execute_time;//进程执行总共需要用的时间private int arrival_time;//进程目前已经占用处理器的时间public int getExecute_time() {return execute_time;}public void setExecute_time(int execute_time) {this.execute_time = execute_time;}public int getArrival_time() {return arrival_time;}public void setArrival_time(int arrival_time) {this.arrival_time = arrival_time;}public int getId() {return id;}public void setId(int id) {this.id = id;}public int getStatus() {return status;}public void setStatus(int status) {this.status = status;}public int getAx() {return ax;}public void setAx(int ax) {this.ax = ax;}public int getBx() {return bx;}public void setBx(int bx) {this.bx = bx;}public int getCx() {return cx;}public void setCx(int cx) {this.cx = cx;}public int getDx() {return dx;}public void setDx(int dx) {this.dx = dx;}public int getPc() {return pc;}public void setPc(int pc) {this.pc = pc;}public int getPsw() {return psw;}public void setPsw(int psw) {this.psw = psw;}public int getNext() {return next;}public void setNext(int next) {this.next = next;}public String toString(){return "进程信息"+"id:"+id+"  status:"+status+"  ax:"+ax+"  bx:"+bx+"  cx:"+cx+"  dx:"+dx+"  pc:"+pc+"  psw:"+psw+"  next:"+next+"  execute_time:"+execute_time+"  arrival_time:"+arrival_time;}
}

package Process;
import java.util.Scanner;
/*
主函数,实现实验功能*/
public class Main {//定义系统参数public static final int pronum=3;//系统中进程总数,,进程总数不固定,任意,就绪队列阻塞队列用链表实现,依次无所谓public static final int time=50;//时间片大小//进程创建函数public boolean create(){return true;}//进程调度函数public boolean scheduling(){return true;}//主进程,系统初始化public static void main(String[] args){//创建进程就绪对列readyQueue<pcb> rq=new readyQueue<pcb>();//创建进程阻塞队列blockedQueue<pcb> bq=new blockedQueue<pcb>();/*执行流程1录入进程,为进程保存pcb信息*/Scanner sc=new Scanner(System.in);System.out.println("进程标识信息:请输入进程编号(进程标识符),最多可以创建10个进程");for(int i=0;i<pronum;i++){pcb p=new pcb();System.out.println("请输入数字零进入系统:");int x=sc.nextInt();System.out.println("请按照相应提示输入进程现场信息:");System.out.println("请输入进程标识符id的信息");int id=sc.nextInt();p.setId(id);//进程状态(1表示运行态,2表示就绪态,3表示阻塞态)int status=2;p.setStatus(status);System.out.println("请输入通用寄存器ax的内容");int ax=sc.nextInt();p.setAx(ax);System.out.println("请输入通用寄存器bx的内容");int bx=sc.nextInt();p.setBx(bx);System.out.println("请输入通用寄存器cx的内容");int cx=sc.nextInt();p.setCx(cx);System.out.println("请输入通用寄存器dx的内容");int dx=sc.nextInt();p.setDx(dx);System.out.println("请输入程序计数器pc的内容");int pc=sc.nextInt();p.setPc(pc);System.out.println("请输入程序状态字psw的内容");int psw=sc.nextInt();p.setPsw(psw);System.out.println("请输入下一个pcb的位置信息");int next=sc.nextInt();p.setNext(next);System.out.println("请输入进程执行所需的总时间");int execute_time=sc.nextInt();p.setExecute_time(execute_time);// System.out.println(p);System.out.println("已经成功为进程建立了进程控制块");System.out.println(p.toString());System.out.println("该进程已进入就绪队列");rq.addAtRear(p);System.out.println("查看就绪队列中现有进程"+rq.toString());}System.out.println("给进程分配cpu");pcb pz=rq.removeFromFront();pz.setArrival_time(pz.getArrival_time()+time);pz.setStatus(3);bq.addAtRear(pz);while(!rq.isEmpty()){pcb p0=rq.removeFromFront();p0.setArrival_time(p0.getArrival_time()+time);p0.setStatus(1);if(p0.getExecute_time()>=p0.getArrival_time()){p0.setStatus(2);rq.addAtRear(p0);}System.out.println("查看就绪队列中现有进程"+rq.toString());}System.out.println("就绪队列中进程执行完毕");System.out.println("查看阻塞队列中现有进程"+bq.toString());System.out.println("将进程从阻塞队列中移除,转入相应的就绪队列中");pcb p0=bq.removeFromFront();System.out.println("查看阻塞队列中现有进程"+bq.toString());p0.setStatus(2);rq.addAtRear(p0);System.out.println("查看就绪队列中现有进程"+rq.toString());while(!rq.isEmpty()){pcb px=rq.removeFromFront();px.setArrival_time(px.getArrival_time()+time);px.setStatus(1);if(px.getExecute_time()>=px.getArrival_time()){px.setStatus(2);rq.addAtRear(px);}System.out.println("查看就绪队列中现有进程"+rq.toString());}System.out.println("查看就绪队列中现有进程"+rq.toString());System.out.println("所有进程执行完毕");}
}

package Process;
/*
进程就绪队列:fifo,实现进程调度,处理器从就绪队列选择进程,
是进程从就绪态转为运行态,
数据结构:队列,(用链式存储实现)
只允许在头部删除,在尾部插入队列:另一种被限制的线性表
数据结构-逻辑结构:线性结构物理结构:顺序,链式队列:使用固定的一端插入元素,固定的一段删除元素只允许在表的前端(front)进行删除操作,只允许在表的后端(rear)进行插入操作队尾:进行插入操作的一段队售:进行删除操作的一端空队列:队列中没有任何的数据元素*/public class blockedQueue<T> {private class Node{//节点n内部类,用于表示链式存储队列中的每个节点private T data;//节点的数据private Node next;//保存指向下一个节点的引用public Node(){}//构造函数,初始化public Node(T data,Node next){this.data=data;this.next=next;//构造函数,初始化}}/*就绪队列的属性*/private Node front;//保存就绪队列的头节点,即下一个会被处理机调度的进程,private Node rear;//保存就绪队列的伪结点,即就绪队列中新进来的进程都在这里插入private int size;//保存目前进程就绪队列中的进程数目/*就绪队列的方法*///1创建一个空的进程就绪队列,没有任何进程处于就绪状态public blockedQueue(){//构造函数,初始化front=null;rear=null;size=0;}//2创建一个非空的就绪队列,以一个指定的进程来创建进程就绪队列public blockedQueue(T element){front=new Node(element,null);rear=front;size=1;}//3返回目前进程就绪队列中进程的个数,,处于就绪状态进程的个数public int getSize(){return size;}//4返回进程就绪队列中的最后一个进程,即处于尾部的进程的数据public T getData(){return rear.data;}//5判断进程就绪队列是否为空public boolean isEmpty(){return size==0;}//6清空进程就绪队列public void clear(){front=null;rear=null;size=0;}//7将进程就绪队列中的所有进程的信息打印处理public String toString(){if(isEmpty())return "[]";else{StringBuilder sb=new StringBuilder("[");Node current=front;for(int i=0;i<size&¤t!=null;i++){sb.append(current.data.toString()+",");current=current.next;}sb.append("]");return  sb.toString();}}//8进程就绪队列从首部移除元素,即处于就绪队列头部的进程由就绪态转为运行态public T removeFromFront(){if(isEmpty()){throw new RuntimeException("就绪队列为空,无法从就绪队列中移除就绪进程,");}else{Node del=front;front=del.next;T value=del.data;del=null;size--;return value;}}//9向就绪队列的尾部插入进程,这些进程可能是timeout的进程,也可能是♥调度来的进程public void addAtRear(T element){if(front==null){front=new Node(element,null);rear=front;}else{Node newNode=new Node(element,null);rear.next=newNode;rear=newNode;}size++;}
}

这篇关于用java实现操作系统进程调度问题 pcb rq bq的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/687540

相关文章

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

Apache Ignite 与 Spring Boot 集成详细指南

《ApacheIgnite与SpringBoot集成详细指南》ApacheIgnite官方指南详解如何通过SpringBootStarter扩展实现自动配置,支持厚/轻客户端模式,简化Ign... 目录 一、背景:为什么需要这个集成? 二、两种集成方式(对应两种客户端模型) 三、方式一:自动配置 Thick

Python实现网格交易策略的过程

《Python实现网格交易策略的过程》本文讲解Python网格交易策略,利用ccxt获取加密货币数据及backtrader回测,通过设定网格节点,低买高卖获利,适合震荡行情,下面跟我一起看看我们的第一... 网格交易是一种经典的量化交易策略,其核心思想是在价格上下预设多个“网格”,当价格触发特定网格时执行买

解决pandas无法读取csv文件数据的问题

《解决pandas无法读取csv文件数据的问题》本文讲述作者用Pandas读取CSV文件时因参数设置不当导致数据错位,通过调整delimiter和on_bad_lines参数最终解决问题,并强调正确参... 目录一、前言二、问题复现1. 问题2. 通过 on_bad_lines=‘warn’ 跳过异常数据3

Spring WebClient从入门到精通

《SpringWebClient从入门到精通》本文详解SpringWebClient非阻塞响应式特性及优势,涵盖核心API、实战应用与性能优化,对比RestTemplate,为微服务通信提供高效解决... 目录一、WebClient 概述1.1 为什么选择 WebClient?1.2 WebClient 与

Java.lang.InterruptedException被中止异常的原因及解决方案

《Java.lang.InterruptedException被中止异常的原因及解决方案》Java.lang.InterruptedException是线程被中断时抛出的异常,用于协作停止执行,常见于... 目录报错问题报错原因解决方法Java.lang.InterruptedException 是 Jav

深入浅出SpringBoot WebSocket构建实时应用全面指南

《深入浅出SpringBootWebSocket构建实时应用全面指南》WebSocket是一种在单个TCP连接上进行全双工通信的协议,这篇文章主要为大家详细介绍了SpringBoot如何集成WebS... 目录前言为什么需要 WebSocketWebSocket 是什么Spring Boot 如何简化 We

java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)

《java中pdf模版填充表单踩坑实战记录(itextPdf、openPdf、pdfbox)》:本文主要介绍java中pdf模版填充表单踩坑的相关资料,OpenPDF、iText、PDFBox是三... 目录准备Pdf模版方法1:itextpdf7填充表单(1)加入依赖(2)代码(3)遇到的问题方法2:pd

解决RocketMQ的幂等性问题

《解决RocketMQ的幂等性问题》重复消费因调用链路长、消息发送超时或消费者故障导致,通过生产者消息查询、Redis缓存及消费者唯一主键可以确保幂等性,避免重复处理,本文主要介绍了解决RocketM... 目录造成重复消费的原因解决方法生产者端消费者端代码实现造成重复消费的原因当系统的调用链路比较长的时