public class OSRR {
    public static void main(String[] args) {
        new RR();
    }
}

class RR {
    private Queue<RRBean> PCBQueue;
    private LinkedList<RRBean> ReadyQueue;
    private Queue<RRBean> CompleteQueue;
    // 定义时间片的长度
    private static final int SLICETIME = 4;
    // 定义总的运行时间
    private int time;

    RR() {
        time = 0;
        InitQueue();
        InitBean();
        StartProcess();
        showResult();
    }

    private void StartProcess() {
        System.out.println("PCB进程数" + PCBQueue.size());
        StringBuilder sb = new StringBuilder();
        sb.append("运行过程：");
        while (true) {
            // 是否所有进程运行完
            if (PCBQueue.size() == 0 && ReadyQueue.size() == 0) {
                // 如果所有进程都运行完了，就终止程序
                break;
            }
            // 是否有新的进程进入系统
            for (RRBean r : PCBQueue) {
                // 新的进程进入就绪队列
                if (r.arrive_time <= time) {
                    ReadyQueue.addFirst(r);
                    PCBQueue.remove(r);
                    break;
                }
            }

            // 就绪队列不为空的时候
            if (ReadyQueue.size() != 0) {
                // 取出一个进程运行
                RRBean r = ReadyQueue.poll();
                r.run_time += SLICETIME;
                int temp = time;
                // 如果时间片用完之后，
                if (r.run_time >= r.time) {
                    time += r.time - r.run_time + SLICETIME;
                    r.endTime = time;
                    // 该进程已经完成了
                    CompleteQueue.offer(r);
                } else {
                    time += SLICETIME;
                    // 该进程没有完成
                    ReadyQueue.offer(r);
                }
                System.out.println("进程号：" + r.id +
                        "，本次开始时间：" + temp + "，本次结束时间：" + time);
                sb.append(r.id);
                sb.append("->");
            } else {
                ++time;
            }
        }
        sb.delete(sb.length() - 2, sb.length());
        System.out.println(sb.toString());
    }

    private void showResult() {
        System.out.println("××××××××最后的结果：××××××××");
        for (RRBean rrBean : CompleteQueue) {
            System.out.println("进程号：" + rrBean.id + "，周转时间为：" +
                    (rrBean.endTime - rrBean.arrive_time) + "，平均周转时间：" +
                    (float) (rrBean.endTime - rrBean.arrive_time) / rrBean.time);
        }
    }


    private void InitQueue() {
        PCBQueue = new LinkedList<>();
        ReadyQueue = new LinkedList<>();
        CompleteQueue = new LinkedList<>();
    }

    private void InitBean() {
        File file = new File("./src/Schedule/rr1.txt");
        BufferedReader br = null;
        String read;
        try {
            System.out.println("进程ID\t到达时间\t估计运行时间\t优先级");
            br = new BufferedReader(new FileReader(file));
            while ((read = br.readLine()) != null) {
                RRBean rrBean = new RRBean();
                rrBean.init(read);
                PCBQueue.offer(rrBean);
            }
        } catch (FileNotFoundException e) {
            e.printStackTrace();
            System.out.println("文件不存在");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (br != null) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

class RRBean {
    //进程号
    int id;
    //进程状态  0-Ready,  1-Run,  2-Finish
    int status;
    //进程到达时间
    int arrive_time;
    //估计运行时间
    int time;
    //已运行时间
    int run_time;
    //等待时间
    int wait_time;
    //优先级
    int priority;
    // 结束时间
    int endTime;

    void init(String initString) {
        List<String> num = new ArrayList<>();
        Pattern pattern = Pattern.compile("-*\\d+(\\.\\d+)?");
        Matcher matcher = pattern.matcher(initString);
        while (matcher.find()) {
            num.add(matcher.group());
        }
        StringBuilder sb = new StringBuilder();
        for (String string : num) {
            sb.append(string);
            sb.append("\t\t");
        }
        System.out.println(sb.toString());
        this.id = Integer.parseInt(num.get(0));
        this.arrive_time = Integer.parseInt(num.get(1));
        this.time = Integer.parseInt(num.get(2));
        this.priority = Integer.parseInt(num.get(3));
        this.status = 0;
        this.run_time = 0;
        this.wait_time = 0;
    }
}