Promise 本身不能直接实现 WebWorker 任务派发，但可通过 postMessage + 唯一 ID + Map 缓存 resolve/reject 封装成可 await 的函数，使 Worker 调用无缝融入 async/await 流程。
Promise 本身不能直接“实现” WebWorker 任务派发，但它可以和 WebWorker 配合，封装异步通信逻辑，让 Worker 调用像调用普通函数一样返回 Promise，从而自然融入 async/await 流程。
核心思路：用 MessageChannel 或 postMessage + Promise 封装通信
WebWorker 是独立线程，主线程与 Worker 之间只能通过 postMessage 异步通信。Promise 的作用是把这种“发送 → 等待响应 → 处理结果”的流程包装成可 await 的形式。
- 每次任务派发时，生成唯一 ID（如递增序号或 Symbol），并用该 ID 关联一个 resolve/reject 函数
- 将任务数据连同 ID 一起 post 到 Worker
- Worker 执行完后，把结果（含相同 ID）发回主线程
- 主线程收到响应后，根据 ID 查找并调用对应的 resolve 或 reject
简易封装示例（主线程）
以下是一个轻量、无依赖的封装方式：
<!-- main.js -->const worker = new Worker('./task-worker.js');
立即学习“Java免费学习笔记（深入）”；
Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。 当用户需要：(1) 编写或审查Java代码 (2) 检查命名/代码规范 (3) 处理异常和日志 (4) 编写单元测试 (5) 安全编码 (6) 数据库设...
const pending = new Map();
let id = 0;
worker.onmessage = ({ data }) => {
const { msgId, result, error } = data;
const handler = pending.get(msgId);
if (handler) {
pending.delete(msgId);
if (error) handler.reject(new Error(error));
else handler.resolve(result);
}
};
function runInWorker(task, payload) {
return new Promise((resolve, reject) => {
const msgId = ++id;
pending.set(msgId, { resolve, reject });
worker.postMessage({ msgId, task, payload });
});
}
之后就可以这样使用：
async function doHeavyWork() {
try {
const result = await runInWorker('sortArray', [5, 2, 9, 1]);
console.log('Sorted:', result); // [1, 2, 5, 9]
} catch (e) {
console.error('Worker failed:', e);
}
}
Worker 端需配合响应（task-worker.js）
Worker 不需要 Promise，只需监听任务、执行、再 post 回带 msgId 的结果：
<!-- task-worker.js -->const handlers = {
sortArray: (arr) => [...arr].sort((a, b) => a - b),
fibonacci: (n) => {
let a = 0, b = 1;
while (n-- > 1) [a, b] = [b, a + b];
return b;
},
};
self.onmessage = ({ data }) => {
const { msgId, task, payload } = data;
try {
const result = handlers[task]?.(payload);
self.postMessage({ msgId, result });
} catch (err) {
self.postMessage({ msgId, error: err.message });
}
};
进阶建议：用 MessageChannel 实现更健壮的双向通道
如果 Worker 需要频繁通信或支持流式响应（如分块处理），推荐用 MessageChannel 创建独立端口，避免 onmessage 冲突：
- 主线程创建
const { port1, port2 } = new MessageChannel() - 将
port2传给 Worker：worker.postMessage({ type: 'init', port: port2 }, [port2]) - Worker 接收后调用
port.start()，之后只通过该 port 收发 - 主线程在
port1.onmessage中处理响应，同样用 ID 匹配 Promise
这种方式隔离性更好，适合复杂 Worker 场景，也便于后续扩展取消机制（AbortSignal）或超时控制。
