如何手动实现一个支持“任务优先级队列”与“状态持久化”的 Promise 容器-js教程-PHP中文网

需构建可中断、可恢复、可排序的异步任务管理中心，核心是用最小堆实现优先级队列，仅序列化任务元数据与结果快照以支持持久化，不保存不可序列化的 promise 实例。

如何手动实现一个支持“任务优先级队列”与“状态持久化”的 promise 容器

要手动实现一个支持“任务优先级队列”与“状态持久化”的 Promise 容器，核心是把 Promise 的执行逻辑、优先级调度、以及运行时状态（如待执行任务、已完成结果、错误信息等）统一管理起来，并能序列化/反序列化以支持持久化。它不是简单包装 Promise，而是构建一个可中断、可恢复、可排序的异步任务管理中心。

设计关键点：优先级队列

Promise 本身不带优先级，需在提交任务时显式指定优先级（如数字越小越高），内部用最小堆或有序数组维护待执行队列。推荐使用 最小堆（Min-Heap） 实现 O(log n) 插入和 O(1) 取最高优任务：

每个任务封装为对象：{ priority: number, promiseFn: () => Promise<any>, id: string }</any>
插入时按 priority 堆化；出队始终取堆顶（最小 priority）
避免直接用 Array.sort()，否则每次插入都 O(n log n)，高并发下性能差
可支持动态调整优先级（需提供 updatePriority(id, newPriority)，配合堆的 decrease/increase-key 操作）

实现状态持久化机制

持久化不是保存 Promise 实例（不可序列化），而是保存任务的描述性元数据和执行结果快照：

待执行任务：只存 { id, priority, fnStr: fn.toString(), args: JSON.stringify(args) } —— 注意函数体转字符串 + 参数 JSON 化，运行时再 eval 或通过闭包重建（更安全方式是约定任务注册为命名函数，持久化时只存函数名 + 参数）
已完成任务：存 { id, status: 'fulfilled' | 'rejected', value?: any, reason?: any, timestamp }，value/reason 需可 JSON 序列化（自动过滤函数、undefined、循环引用）
提供 saveToStorage()（写入 localStorage / IndexedDB / 后端 API）和 loadFromStorage()（启动时恢复队列与历史）
注意：已 resolve/reject 的 Promise 无法再次 await，所以“恢复”仅指重建容器状态，不重放 Promise

Promise 容器主体结构示例（精简版）

以下为可运行的核心骨架（无依赖，ES6+）：

class PriorityPromiseContainer {
  constructor() {
    this.heap = []; // 最小堆：[{id, priority, promiseFn, args}]
    this.history = new Map(); // id → {status, value, reason, timestamp}
    this.isRunning = false;
  }
<p>// 最小堆辅助方法（略，标准实现）
_heapPush(task) { /<em> ... </em>/ }
_heapPop() { /<em> ... </em>/ }</p><p>submit(fn, priority = 0, id = Math.random().toString(36).substr(2, 9), ...args) {
const task = { id, priority, promiseFn: () => fn(...args), args };
this._heapPush(task);
this._runNext();
}</p><p>async _runNext() {
if (this.isRunning || this.heap.length === 0) return;
this.isRunning = true;</p><pre class="brush:php;toolbar:false;">const task = this._heapPop();
try {
  const value = await task.promiseFn();
  this.history.set(task.id, {
    status: 'fulfilled',
    value,
    timestamp: Date.now()
  });
} catch (reason) {
  this.history.set(task.id, {
    status: 'rejected',
    reason,
    timestamp: Date.now()
  });
} finally {
  this.isRunning = false;
  this._runNext(); // 自动调度下一个
}

}

saveToStorage(key = 'promise-container') { const data = { heap: this.heap.map(t => ({...t, promiseFn: t.promiseFn.toString()})), history: Object.fromEntries(this.history), timestamp: Date.now() }; localStorage.setItem(key, JSON.stringify(data)); }

loadFromStorage(key = 'promise-container') { const data = localStorage.getItem(key); if (!data) return; const parsed = JSON.parse(data); this.heap = parsed.heap.map(t => ({ ...t, promiseFn: eval((${t.promiseFn})) // ⚠️ 简化示意，生产环境建议函数白名单或模块注册表 })); this.history = new Map(Object.entries(parsed.history)); } }