数组实现优先级任务队列需按priority升序/降序插入保持稳定排序,抢占逻辑明确触发条件(如新任务priority更高时中断当前任务并重入队),维护current状态与任务上下文。
用数组实现任务调度优先级列表,核心是让高优先级任务排在前面,并在新任务插入或运行中发生抢占时,动态调整顺序。关键不在于复杂数据结构,而在于明确插入逻辑和抢占判断条件。
用数组维护按优先级排序的任务队列
每个任务用对象表示,至少包含 id、priority(数值越小优先级越高,或反之,需统一约定)、data 等字段。数组始终保持按 priority 升序(或降序)排列。
- 插入新任务时,遍历数组找到第一个 priority 不低于(或不大于)它的位置,用
splice(index, 0, task)插入 - 避免每次插入后调用
sort(),那样时间复杂度高且可能破坏同优先级任务的原始顺序(稳定性) - 例如:当前队列是
[{id:1,p:3}, {id:2,p:5}],插入{id:3,p:4},应插在索引 1 处,得到[{id:1,p:3}, {id:3,p:4}, {id:2,p:5}]
定义变量抢占触发条件
抢占不是自动发生的,需要明确定义什么情况下“正在运行的任务”被更高优先级的新任务打断。常见策略有:
- 严格抢占式:只要新任务 priority > 当前运行任务 priority(假设数值越大优先级越高),就立即中断当前任务,将其放回队列合适位置,然后执行新任务
- 非抢占式(协作式):当前任务运行完才从队列取下一个;此时“抢占逻辑”只体现为插入时重排,不中断执行
-
时间片+抢占:当前任务运行固定时间后检查队首任务优先级是否更高,是则切换——这需要配合定时器和状态标记(如
currentTask和isRunning)
处理抢占后的任务归位与状态同步
一旦发生抢占,被中断的任务不能丢弃,要重新入队,且保持优先级语义一致:
- 保存其中断点(如已处理的数据索引、剩余步骤等),作为
task.context字段存入 - 插入时按其原始 priority 比较,不是按“被中断”这个事件提升优先级(除非业务要求,如超时任务加权)
- 需维护一个运行态标识,例如
let current = null,调度器每次取任务前先检查current是否为空或是否该被抢占 - 可增加
task.preemptedCount统计被抢次数,用于后续降级或告警
一个极简可运行示例(JavaScript)
以下是一个非阻塞、手动触发调度的示意,聚焦逻辑而非完整引擎:
let queue = [];
let current = null;
function addTask(task) {
const p = task.priority;
let i = 0;
while (i < queue.length && queue[i].priority <= p) i++; // 升序:小优先级在前
queue.splice(i, 0, task);
}
function preemptIfNeeded(newTask) {
if (current && newTask.priority > current.priority) {
// 抢占:把 current 放回队列,更新其上下文
current.context = current.context || {};
current.context.resumeAt = getCurrentProgress(current);
addTask(current);
current = null;
}
}
function runNext() {
if (queue.length === 0) return;
current = queue.shift(); // 取最高优先级(队首)
execute(current); // 执行函数,内部可调用 runNext() 或 await 后续
}

















