实现异步操作的优先级队列，核心思路是使用一个按优先级排序的数组来暂存任务，并配合一个信号量（semaphore）机制来控制并发执行的数量。具体做法是定义一个类，内部维护一个最小堆或已排序数组用于存储待执行的任务对象，每个任务包含优先级数值和实际的 promise 工厂函数。当调用入队方法时，将任务插入到正确的位置以保持有序；启动调度器后，它不断从队首取出最高优先级的任务执行，并在任务完成后立即尝试执行下一个任务。这样做可以确保高优先级的异步操作总是比低优先级的先完成，同时通过限制并发数避免资源耗尽。
如何设计支持动态插入的优先级队列结构
要支持动态插入且保持优先级顺序，最稳妥的方式是使用一个基于数组的最小堆结构，或者在每次插入时使用二分查找定位位置后插入。这里采用简单的数组排序策略，因为 JavaScript 的 `sort` 方法在处理少量数据时足够高效且代码直观。我们需要定义一个 Task 对象，包含 `priority` 属性和 `executor` 函数。入队时，将新任务推入数组，然后立即对数组进行升序排序，这样索引为 0 的元素始终是优先级最高的任务。这种设计的优点是逻辑简单，缺点是频繁排序在极大规模下可能有性能损耗，但对于大多数异步场景（如网络请求、UI 渲染任务）来说完全够用。关键在于入队操作必须是同步的，以确保顺序确定性，而执行则是异步的。
class PriorityQueue {
constructor(maxConcurrency = 1) {
this.tasks = [];
this.maxConcurrency = maxConcurrency;
this.activeCount = 0;
}
enqueue(priority, executor) {
const task = { priority, executor, id: Math.random() };
this.tasks.push(task);
// 保持数组按优先级升序排列
this.tasks.sort((a, b) => a.priority - b.priority);
this.run();
}
async run() {
while (this.tasks.length > 0 && this.activeCount < this.maxConcurrency) {
const task = this.tasks.shift();
this.activeCount++;
try {
await task.executor();
} catch (e) {
console.error('Task failed', e);
} finally {
this.activeCount--;
// 任务结束后继续尝试运行下一个
this.run();
}
}
}
}
// 使用示例
const pq = new PriorityQueue(2);
pq.enqueue(10, () => fetch('/api/low'));
pq.enqueue(1, () => fetch('/api/high'));
// high 会先于 low 开始执行
上述代码展示了基础结构的实现。`enqueue` 方法接收优先级和执行器。注意 `this.run()` 被递归调用，这构成了一个事件循环式的调度器。每当一个任务完成（无论成功或失败），`finally` 块都会触发下一次 `run` 检查，从而拉取队列中的下一个任务。这种模式确保了只要队列中有任务且未达到并发上限，就会持续消费任务。对于开发者而言，只需关注任务的优先级数值，无需关心底层的调度逻辑。
立即学习“Java免费学习笔记（深入）”；
如何处理任务取消与状态监控
在实际应用中，用户可能会取消某个高优先级任务，或者需要知道当前队列的状态。为了实现这一点，我们需要引入 `AbortController` 或自定义的取消标志。修改后的任务对象应包含一个 `cancel` 方法和一个 `status` 属性。当调用取消方法时，我们标记该任务为已取消，并在执行器中定期检查这个标志。如果任务正在等待执行（即在队列中），我们可以直接从数组中移除它。如果任务正在执行，则通知执行器中止操作。此外，暴露 `size` 属性和 `onStatusChange` 回调可以让外部组件监控队列负载。这种设计使得优先级队列不仅仅是一个执行器，更是一个可管理的资源池。通过分离“排队”和“执行”的逻辑，我们可以灵活地处理取消请求，而不影响其他正在运行的任务。
// 增强版：支持取消和状态
async function enhancedExecutor(pq) {
const controller = new AbortController();
const { signal } = controller;
const task = {
priority: 5,
executor: async () => {
// 模拟长时间操作
await new Promise(resolve => setTimeout(resolve, 1000));
if (signal.aborted) throw new Error('Cancelled');
return 'Done';
},
cancel: () => controller.abort()
};
pq.enqueue(5, task.executor);
// 假设500ms后决定取消
setTimeout(() => {
// 实际场景中需通过ID找到对应task并调用cancel
// 此处简化演示逻辑
console.log('Cancel requested');
}, 500);
}
// 状态监控示例
const monitorPq = new PriorityQueue(1);
monitorPq.onStatusChange = (status) => console.log(status);
// status 可以是 { active: 1, queued: 5 }
在增强版实现中，我们引入了 `AbortController` 来处理异步操作的取消。这在网络请求等支持信号的操作中非常有用。当需要取消任务时，调用 `abort()` 会触发 `signal.aborted` 变为 true，执行器捕获异常并退出。对于队列管理，我们可以添加一个简单的状态报告机制。例如，在 `run` 方法的循环中，定期触发一个事件，携带当前的 `activeCount` 和 `tasks.length`。这样，前端 UI 可以显示“正在处理 1 个，排队 5 个”。这种可观测性对于调试和生产环境监控至关重要。需要注意的是，取消队列中的任务只是将其移除，不会中断正在执行的任务，除非执行器本身支持信号取消。这种分离保证了系统的健壮性，避免因取消操作导致未处理的 Promise 拒绝错误。
当并发数为1时优先级队列的行为表现
当并发数设置为 1 时，优先级队列退化为一个严格的串行执行器，但依然保持优先级的语义。这意味着所有任务必须按优先级顺序依次执行，前一个任务完全结束（包括其内部的异步操作）后，下一个任务才会开始。这种行为类似于单线程的事件循环，但由我们的调度器显式控制顺序。在这种模式下，高优先级任务可以“插队”，即如果低优先级任务正在执行，高优先级任务必须等待其完成；但如果低优先级任务仅在队列中等待，高优先级任务将立即抢占执行权。这对于需要保证关键路径（如支付确认、数据保存）优先完成的场景非常有用。开发者可以利用这一特性，将非关键的日志记录或分析任务设为低优先级，确保核心业务逻辑不受阻塞。
