高级 Worker Threads:可转移对象与共享内存原子操作
不再只是 postMessage 字符串,而是使用 ArrayBuffer 转移 (transferable) 与 SharedArrayBuffer 实现真正的无锁数据交换。 · 难度:入门 · +10XP
可转移对象与原子指令
Worker 之间传递大 Buffer 时默认会拷贝,但通过 transferList 可将 ArrayBuffer 所有权转移(零拷贝)。更近一步,SharedArrayBuffer 允许多线程直接访问同一块内存,配合 Atomics 类进行原子加减、等待/通知,可以构建高性能计数器或生产者-消费者队列。本教程将实现一个多线程并行哈希计算器,每个 Worker 处理文件分片,并通过 SharedArrayBuffer+Atomics 汇总结果。
const { Worker, isMainThread, parentPort, workerData } = require('worker_threads');
if (isMainThread) {
const sab = new SharedArrayBuffer(4);
const view = new Int32Array(sab);
const worker = new Worker(__filename, { workerData: sab });
Atomics.wait(view, 0, 0);
console.log('最终结果', view[0]);
} else {
const sab = workerData;
const view = new Int32Array(sab);
Atomics.add(view, 0, 1);
Atomics.notify(view, 0, 1);
}