高优先级调度算法的c++代码

高优先级调度算法通常用于实时系统，其中任务按照它们的优先级顺序被执行。在C++中，你可以使用条件变量、互斥锁和优先级队列等工具来实现这个功能。下面是一个简单的基于优先级的抢占式调度的例子，这里使用了`std::priority_queue`和`boost::thread`库：

#include <queue>
#include <mutex>
#include <condition_variable>
#include <boost/thread.hpp>

// 定义任务结构体，包含优先级和执行函数
struct Task {
    int priority;
    std::function<void()> func;

    // 比较函数用于优先级队列
    bool operator<(const Task& other) const { return priority > other.priority; }
};

class Scheduler {
private:
    std::queue<Task> task_queue_;
    std::mutex queue_mutex_;
    std::condition_variable cond_var_;

public:
    void schedule(Task t) {
        std::lock_guard<std::mutex> lock(queue_mutex_);
        task_queue_.push(t);
        cond_var_.notify_one();
    }

    void run() {
        while (true) {
            std::unique_lock<std::mutex> lock(queue_mutex_);
            cond_var_.wait(lock, [this]{ return !task_queue_.empty(); });

            if (!task_queue_.empty()) {
                auto top_task = task_queue_.top();
                task_queue_.pop();
                top_task.func(); // 执行任务
            } else {
                break; // 如果队列为空，退出循环
            }
        }
    }
};

int main() {
    Scheduler scheduler;
    boost::thread scheduler_thread(scheduler.run);

    // 创建一些任务并设置优先级
    scheduler.schedule({5, []{ /* 这里执行低优先级任务 */ }});
    scheduler.schedule({10, []{ /* 这里执行高优先级任务 */ }});
    
    // 等待主线程结束
    scheduler_thread.join();

    return 0;
}

在这个例子中，`Scheduler`类维护一个优先级队列，新任务会被添加到队列，并通过`cond_var_`唤醒正在运行的任务。`run()`函数会不断从队列中取出优先级最高的任务执行。