SCAU操作系统实验报告源码 题目：调度算法

package OS; import java.awt.*; import java.awt.event.*; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.HashSet; import java.util.Set; import javax.swing.*; import javax.swing.table.DefaultTableModel; /** 主界面 */ public class Main extends JFrame { private JTextField numTextField;//进程个数 private JPanel mainPanel; private JButton createButton;//创建进程按钮 private JButton clearButton;//清空进程按钮 private JButton startButton;//开始 public static DefaultTableModel tableModel; public JTable processTable; private int inputNumber = 0; private JPanel processListJPanel; public Object[][] object; public ArrayList<PCB> arraylist = new ArrayList<PCB>();//保存创建的进程信息 public static boolean startTime = true; // 控制总时间的运行 private JLabel startLabel; private JLabel timeLabel; private boolean firstRun = true; private Runnable proc; private Set<Integer> set = new HashSet<Integer>();//保存进程名称 private Thread p1 = new Thread(); private JComboBox comboBox; /** * 界面初始化 * @param args * @throws Exception */ public static void main(String[] args) throws Exception { JFrame frame = new Main(); frame.setTitle("单处理器系统的进程调度"); frame.setSize(800, 600); frame.setLocationRelativeTo(null);//居中 frame.setVisible(true); } public Main() throws Exception { JPanel centerFrame = new JPanel(new GridLayout(1, 2, 10, 10)); mainPanel = new JPanel(new FlowLayout(FlowLayout.LEFT, 25, 5)); // 需要选择的条目 String[] listData = new String[]{"时间片轮转", "优先数", "最短进程优先", "最短剩余时间优先"}; comboBox = new JComboBox<String>(listData);// 创建一个下拉列表框 //行数，居中 numTextField = new JTextField(8); numTextField.setHorizontalAlignment(SwingConstants.CENTER); createButton = new JButton("创建进程"); clearButton = new JButton("清空"); startButton = new JButton("开始"); //监听事件 numTextField.addKeyListener(new InputNumListener()); buttonListener buttonListener = new buttonListener(); createButton.addActionListener(buttonListener); clearButton.addActionListener(buttonListener); startButton.addActionListener(buttonListener); startLabel = new JLabel(); timeLabel = new JLabel(); startLabel.setText("运行时间："); mainPanel.add(comboBox); mainPanel.add(numTextField); mainPanel.add(createButton); mainPanel.add(clearButton); mainPanel.add(startButton); mainPanel.add(startLabel); mainPanel.add(timeLabel); this.add(mainPanel, BorderLayout.NORTH); processListJPanel = new JPanel(new BorderLayout(10, 10)); //创建表格 tableModel = new DefaultTableModel(); tableModel.addColumn("进程"); tableModel.addColumn("进程状态"); tableModel.addColumn("优先级"); tableModel.addColumn("服务时间"); tableModel.addColumn("剩余服务时间"); processTable = new JTable(tableModel); processTable.getColumnModel().getColumn(0).setPreferredWidth(80); processTable.getColumnModel().getColumn(1).setPreferredWidth(80); processTable.getColumnModel().getColumn(2).setPreferredWidth(80); processTable.getColumnModel().getColumn(3).setPreferredWidth(80); processTable.getColumnModel().getColumn(4).setPreferredWidth(80); JScrollPane scrollPane = new JScrollPane(processTable); processListJPanel.add(scrollPane); centerFrame.add(processListJPanel); this.add(centerFrame, BorderLayout.CENTER); } private class InputNumListener implements KeyListener { @Override public void keyTyped(KeyEvent e) { } @Override public void keyPressed(KeyEvent e) { } @Override public void keyReleased(KeyEvent e) { String text = numTextField.getText(); inputNumber = Integer.parseInt(text); } } private class buttonListener implements ActionListener { @Override public void actionPerformed(ActionEvent e) { if (e.getSource() == createButton) { if (numTextField.getText().trim().length() == 0) { JOptionPane.showMessageDialog(null, "请输入进程个数！", "系统提示", JOptionPane.INFORMATION_MESSAGE); return; } createProcess(inputNumber); } else if (e.getSource() == startButton) { if (arraylist.size() == 0) { JOptionPane.showMessageDialog(null, "请点击创建进程！", "系统提示", JOptionPane.INFORMATION_MESSAGE); return; } if (firstRun) { firstRun = false; //开始计时 Runnable time = new TimeRecord(timeLabel); Thread thread = new Thread(time); thread.start(); } //"时间片轮转" if (comboBox.getSelectedIndex()==0) { proc = new RR(processTable, arraylist); p1 = new Thread(proc); p1.start(); // "优先数" } else if (comboBox.getSelectedIndex()==1) { System.out.println("1111"); proc = new Priority(processTable, arraylist); p1 = new Thread(proc); p1.start(); //"最短进程优先" } else if (comboBox.getSelectedIndex()==2) { proc = new SPN(processTable, arraylist); p1 = new Thread(proc); p1.start(); //"最短剩余时间优先" } else if (comboBox.getSelectedIndex()==3) { proc = new SRT(processTable, arraylist); p1 = new Thread(proc); p1.start(); } }else if (e.getSource() == clearButton) { clearRow(); } } } /** * 创建随机进程 * @param number */ void createProcess(int number) { object = new Object[number + 1][5]; int count1 = number; int[] processArray = new int[count1 + 1]; int processName = 0; // 进程名称 int i = 1, count = 0; while (count < count1) { //1-100随机数 processName = 1 + (int) (Math.random() * 100); if (!set.contains(processName)) { set.add(processName); processArray[i++] = processName; } count++; } for (i = 1; i <= count1; i++) { int processPri = (int) (Math.random() * 5); // 优先级 int processTime = 1 + (int) (Math.random() * 5); // 所需时间 PCB pcb = new PCB(processArray[i], 1, processPri, processTime, processTime); // "进程", "进程状态", "优先级", "服务时间","剩余服务时间" object[i] = new Object[] { pcb.name, "就绪态", pcb.priority, pcb.total, pcb.time}; tableModel.addRow(object[i]);//向状态区添加一个进度条 arraylist.add(pcb); if (!firstRun) { //RR if (comboBox.getSelectedIndex()==0) { ((RR) proc).size = arraylist.size(); //Priority } else if (comboBox.getSelectedIndex()==1) { proc = new Priority(processTable, arraylist); p1.stop(); p1 = new Thread(proc); p1.start(); //SPN } else if (comboBox.getSelectedIndex()==3) { ((SPN) proc).runInterupt = true; ((SPN) proc).map.put(pcb.name, arraylist.size() - 1); Collections.sort(arraylist, new Comparator<Object>() { @Override public int compare(Object o1, Object o2) { return ((PCB) o1).time - (((PCB) o2).time); } }); SPN.runNum = 0; ((SPN) proc).size = ((SPN) proc).arraylistTemp.size(); //SRT } else if (comboBox.getSelectedIndex()==3) { ((SRT) proc).map.put(pcb.name, arraylist.size() - 1); Collections.sort(arraylist, new Comparator<Object>() { @Override public int compare(Object o1, Object o2) { return ((PCB) o1).time - (((PCB) o2).time); } }); SRT.runNum = 0; ((SRT) proc).size = ((SRT) proc).arraylistTemp .size(); } } } } private void clearRow() { DefaultTableModel defaultTableModel = (DefaultTableModel) processTable.getModel(); defaultTableModel.setRowCount(0); defaultTableModel.fireTableDataChanged(); arraylist = new ArrayList<PCB>(); Main.startTime = true; firstRun = true; if (p1.isAlive()) { p1.stop(); } //结束进程 if (Thread.currentThread().isAlive()) { Thread.currentThread().stop(); } timeLabel.setText("0"); } }