first commit

Author: dr1np

.gitignore

@@ -0,0 +1,4 @@
+*.user
+*.autosave
+*.qrc
+*.user.*

MyOS.pro

@@ -0,0 +1,52 @@
+#-------------------------------------------------
+#
+# Project created by QtCreator 2022-10-08T17:54:44
+#
+#-------------------------------------------------
+
+QT       += core gui
+
+greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
+
+TARGET = MyOS
+TEMPLATE = app
+
+# The following define makes your compiler emit warnings if you use
+# any feature of Qt which has been marked as deprecated (the exact warnings
+# depend on your compiler). Please consult the documentation of the
+# deprecated API in order to know how to port your code away from it.
+DEFINES += QT_DEPRECATED_WARNINGS
+
+# You can also make your code fail to compile if you use deprecated APIs.
+# In order to do so, uncomment the following line.
+# You can also select to disable deprecated APIs only up to a certain version of Qt.
+#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0
+
+CONFIG += c++11
+
+SOURCES += \
+        main.cpp \
+        mainwindow.cpp \
+    pcb.cpp \
+    cpuscheduler.cpp \
+    cpu.cpp \
+    newprocessdialog.cpp
+
+HEADERS += \
+        mainwindow.h \
+    pcb.h \
+    cpuscheduler.h \
+    cpu.h \
+    newprocessdialog.h
+
+FORMS += \
+        mainwindow.ui \
+    newprocessdialog.ui
+
+# Default rules for deployment.
+qnx: target.path = /tmp/$${TARGET}/bin
+else: unix:!android: target.path = /opt/$${TARGET}/bin
+!isEmpty(target.path): INSTALLS += target
+
+RESOURCES += \
+    res.qrc

cpu.cpp

@@ -0,0 +1,22 @@
+#include "cpu.h"
+
+CPU::CPU(QObject *parent) : QObject(parent)
+{
+
+}
+
+void CPU::exec1(PCB &p)
+{
+    p.time--;
+    int dec = 3;
+    if(p.priority - dec >= 100)
+     {
+        p.priority-= dec;
+        p.priority_pre-= dec;
+     }
+    else
+    {
+        p.priority = 100;
+        p.priority_pre = 100;
+    }
+}

cpu.h

@@ -0,0 +1,19 @@
+#ifndef CPU_H
+#define CPU_H
+
+#include <pcb.h>
+#include <QObject>
+
+class CPU : public QObject
+{
+    Q_OBJECT
+public:
+    explicit CPU(QObject *parent = nullptr);
+    void exec1(PCB &p);
+
+signals:
+
+public slots:
+};
+
+#endif // CPU_H

cpuscheduler.cpp

@@ -0,0 +1,115 @@
+#include "cpuscheduler.h"
+
+CPUScheduler::CPUScheduler(QObject *parent) : QObject(parent)
+{
+
+}
+
+void CPUScheduler::newProcess(PCB* newP)
+{
+    if(readyQueue->size() < 6)
+        readyQueue->push(*newP);
+     else
+        jobQueue->push(*newP);
+}
+
+void CPUScheduler::newProcess(string PID,int time,int priority,string father)
+{
+    PCB* newP = new PCB(PID,time,priority,father);
+    if(readyQueue->size() < 6)
+        readyQueue->push(*newP);
+    else
+    {
+        if(father == "")
+            jobQueue->push(*newP);
+        else
+        {
+            queue<PCB>* tempQ = new queue<PCB>;
+            tempQ->push(*newP);
+            while(!jobQueue->empty())
+            {
+                tempQ->push(jobQueue->front());
+                jobQueue->pop();
+            }
+            queue<PCB>* a = jobQueue;
+            jobQueue = tempQ;
+            delete a;
+        }
+
+    }
+}
+
+void CPUScheduler::exec1()
+{    
+    if(readyQueue->empty())
+        return;
+    PCB tempE = readyQueue->top();
+    if(tempE.suspend)
+        return;
+    cpu->exec1(tempE);
+    readyQueue->pop();
+
+    //其余进程优先度增加
+    int inc = 1;
+    int size = (int)readyQueue->size();
+    priority_queue<PCB>* tempQ = new priority_queue<PCB>;
+    for(int i = 0;i < size;i++)
+    {
+        PCB temp2 = readyQueue->top();
+        if(temp2.suspend)
+        {
+            tempQ->push(temp2);
+            readyQueue->pop();
+            continue;
+        }
+        if(temp2.priority + inc <= 140)       
+        {
+            temp2.priority += inc;
+            temp2.priority_pre += inc;
+        }
+        else
+        {
+            temp2.priority = 140;
+            temp2.priority_pre = 140;
+        }
+
+        tempQ->push(temp2);
+        readyQueue->pop();
+    }
+    priority_queue<PCB>* a;
+    a = readyQueue;
+    readyQueue = tempQ;
+    delete a;
+
+    //进程未完成push回 已完成push历史队列
+    if(tempE.time > 0)
+    {
+        readyQueue->push(tempE);
+    }
+    else
+    {
+        //运行完毕队列
+        free(tempE.father);
+        historyQueue->push_back(tempE);
+    }
+}
+
+void CPUScheduler::free(string fatherPID)
+{
+    priority_queue<PCB>* tempQ = new priority_queue<PCB>;
+
+    while(!readyQueue->empty())
+    {
+       PCB tempP = readyQueue->top();
+       if(tempP.PID == fatherPID)
+       {
+           tempP.running_children--;
+           qDebug()<<"father --";
+       }
+       tempQ->push(tempP);
+       readyQueue->pop();
+    }
+    priority_queue<PCB>* a = readyQueue;
+    readyQueue = tempQ;
+    delete a;
+}

cpuscheduler.h

@@ -0,0 +1,32 @@
+#ifndef TEST_H
+#define TEST_H
+
+#include <pcb.h>
+#include <queue>
+#include <cpu.h>
+#include <QObject>
+#include <QDebug>
+
+class CPUScheduler : public QObject
+{
+    Q_OBJECT
+public:
+    explicit CPUScheduler(QObject *parent = nullptr);
+    void newProcess(PCB* newP);
+    void newProcess(string PID,int time,int priority,string father = "");
+    void exec1();
+
+    CPU* cpu = new CPU();
+    queue<PCB>* jobQueue = new queue<PCB>;
+    priority_queue<PCB>* suspendQueue = new priority_queue<PCB>;
+    priority_queue<PCB>* readyQueue = new priority_queue<PCB>;
+    vector<PCB>* historyQueue = new vector<PCB>;
+
+    void free(string fatherPID);
+
+signals:
+
+public slots:
+};
+
+#endif // TEST_H

cpuscheuler.cpp

@@ -0,0 +1,15 @@
+#include "cpuscheuler.h"
+
+
+void CPUScheuler::newProcess(string PID,int time,int priority,pstate state,PCB* father)
+{
+    PCB* newP = new PCB(PID,time,priority,state,father);
+    jobQueue.push(*newP);
+}
+
+void CPUScheuler::exec()
+{
+    PCB temp = readyQueue.top();
+    cpu->exec(temp);
+    readyQueue.pop();
+}

icon.png

@@ -0,0 +1,10 @@
+#include "mainwindow.h"
+#include <QApplication>
+
+int main(int argc, char *argv[])
+{
+    QApplication a(argc, argv);
+    MainWindow w;
+    w.show();
+    return a.exec();
+}