导读:本期聚焦于小伙伴创作的《如何用C++实现多级反馈队列进程调度算法并动态调整优先级和时间片》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《如何用C++实现多级反馈队列进程调度算法并动态调整优先级和时间片》有用,将其分享出去将是对创作者最好的鼓励。

多级反馈队列进程调度算法通过设置多个优先级不同的就绪队列,为每个队列分配不同的时间片,进程在运行时会根据执行情况动态调整优先级和所属队列,兼顾短进程响应速度和长进程运行公平性,是操作系统中非常经典的调度策略。

如何用C++实现多级反馈队列进程调度算法并动态调整优先级和时间片

核心设计思路

实现该算法需要先明确几个核心规则:第一,新进程进入时默认放入最高优先级队列,该队列时间片最短;第二,进程在当前队列时间片内运行完成则直接退出,未用完时间片主动让出CPU则保持原优先级;第三,进程时间片用完仍未完成则降低优先级,放入下一级队列,最低优先级队列采用时间片轮转调度;第四,系统可以周期性提升所有队列中等待进程的优先级,避免长进程饥饿。

关键数据结构定义

首先定义进程结构体和队列相关结构,进程需要记录进程ID、剩余运行时间、已用时间片、当前优先级、状态等属性:

#include <iostream>
#include <queue>
#include <vector>
#include <algorithm>
using namespace std;

// 进程状态枚举
enum ProcessState {
    READY,    // 就绪
    RUNNING,  // 运行
    FINISHED  // 完成
};

// 进程结构体
struct Process {
    int pid;               // 进程ID
    int total_time;        // 总运行时间
    int remain_time;       // 剩余运行时间
    int used_time;         // 当前时间片已用时间
    int priority;          // 当前优先级,数值越大优先级越高
    ProcessState state;    // 进程状态

    Process(int id, int time, int pri = 3) : pid(id), total_time(time), remain_time(time), 
        used_time(0), priority(pri), state(READY) {}
};

然后定义多级队列管理结构,假设设置3个优先级队列,不同队列的时间片长度不同:

// 多级反馈队列管理类
class MFQScheduler {
private:
    vector<queue<Process*>> ready_queues;  // 就绪队列数组,下标越小优先级越高
    vector<int> time_slices;               // 每个队列对应的时间片长度
    int current_queue_idx;                 // 当前调度的队列下标
    int time;                              // 系统运行时间
    vector<Process*> all_processes;        // 所有进程记录,用于最后统计

public:
    // 初始化,设置3个队列,时间片分别为2、4、8
    MFQScheduler() : current_queue_idx(0), time(0) {
        time_slices.push_back(2);
        time_slices.push_back(4);
        time_slices.push_back(8);
        for (int i = 0; i < 3; i++) {
            ready_queues.push_back(queue<Process*>());
        }
    }
};

核心调度逻辑实现

进程入队与优先级调整

新进程加入时默认放入最高优先级队列,时间片用完的进程降低优先级进入下一级队列,同时实现周期提升优先级的逻辑:

// 添加新进程到最高优先级队列
void add_process(Process* proc) {
    proc->priority = ready_queues.size() - 1;  // 最高优先级对应最大下标值
    ready_queues[ready_queues.size() - 1].push(proc);
    all_processes.push_back(proc);
    cout << "进程" << proc->pid << "加入最高优先级队列,剩余运行时间:" << proc->remain_time << endl;
}

// 降低进程优先级,放入下一级队列
void lower_priority(Process* proc) {
    if (proc->priority > 0) {
        proc->priority--;
        ready_queues[proc->priority].push(proc);
        cout << "进程" << proc->pid << "时间片用完,降低优先级到" << proc->priority << "级队列" << endl;
    } else {
        // 已经是最高优先级队列,重新放入队尾,时间片轮转
        ready_queues[0].push(proc);
        cout << "进程" << proc->pid << "在最高优先级队列时间片用完,重新入队" << endl;
    }
}

// 周期性提升所有等待进程的优先级,避免饥饿
void boost_priority() {
    // 每20个时间单位提升一次优先级
    if (time > 0 && time % 20 == 0) {
        // 清空所有就绪队列,将进程重新放入最高优先级队列
        for (int i = 0; i < ready_queues.size(); i++) {
            while (!ready_queues[i].empty()) {
                Process* proc = ready_queues[i].front();
                ready_queues[i].pop();
                proc->priority = ready_queues.size() - 1;
                ready_queues[ready_queues.size() - 1].push(proc);
            }
        }
        cout << "时间" << time << ":执行优先级提升,所有就绪进程回到最高优先级队列" << endl;
    }
}

调度执行主逻辑

调度主逻辑按照优先级从高到低遍历队列,找到第一个有就绪进程的队列,取出队首进程执行一个时间单位,根据执行情况处理后续逻辑:

// 执行一次调度
void schedule() {
    boost_priority();
    // 从高优先级队列到低优先级队列查找就绪进程
    for (int i = ready_queues.size() - 1; i >= 0; i--) {
        if (!ready_queues[i].empty()) {
            Process* current_proc = ready_queues[i].front();
            ready_queues[i].pop();
            current_proc->state = RUNNING;
            current_proc->used_time++;
            current_proc->remain_time--;
            time++;

            cout << "时间" << time << ":调度进程" << current_proc->pid 
                 << "运行,当前队列优先级" << i << ",时间片长度" << time_slices[i] 
                 << ",剩余运行时间" << current_proc->remain_time << endl;

            // 判断进程是否运行完成
            if (current_proc->remain_time == 0) {
                current_proc->state = FINISHED;
                cout << "进程" << current_proc->pid << "运行完成" << endl;
            } else {
                // 判断当前时间片是否用完
                if (current_proc->used_time >= time_slices[i]) {
                    current_proc->used_time = 0;
                    lower_priority(current_proc);
                } else {
                    // 时间片未用完,进程主动让出CPU,保持原优先级入队
                    ready_queues[i].push(current_proc);
                    cout << "进程" << current_proc->pid << "时间片未用完,保持优先级入队" << endl;
                }
            }
            return;
        }
    }
    // 没有就绪进程,时间推进
    time++;
    cout << "时间" << time << ":无就绪进程,空闲" << endl;
}

// 判断所有进程是否都完成
bool all_finished() {
    for (Process* proc : all_processes) {
        if (proc->state != FINISHED) {
            return false;
        }
    }
    return true;
}

完整测试示例

编写测试代码验证调度逻辑的正确性,创建3个不同运行时间的进程,启动调度直到所有进程完成:

int main() {
    MFQScheduler scheduler;
    // 创建3个测试进程,运行时间分别为5、10、15
    Process* p1 = new Process(1, 5);
    Process* p2 = new Process(2, 10);
    Process* p3 = new Process(3, 15);

    scheduler.add_process(p1);
    scheduler.add_process(p2);
    scheduler.add_process(p3);

    // 执行调度直到所有进程完成
    while (!scheduler.all_finished()) {
        scheduler.schedule();
    }

    // 释放内存
    delete p1;
    delete p2;
    delete p3;
    return 0;
}

算法特性分析

该实现的多级反馈队列调度算法具备以下特性:第一,短进程可以在高优先级短队列中快速完成,响应速度快;第二,长进程会逐渐降低优先级到时间片更长的队列,不会因为频繁切换浪费CPU资源;第三,优先级提升机制避免了长进程长期饥饿的问题;第四,优先级和时间片调整逻辑完全可配置,可根据实际需求修改队列数量、时间片长度和优先级提升周期。

C++多级反馈队列进程调度优先级动态调整时间片轮转修改时间:2026-06-23 11:51:56

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。