sharedarraybuffer 与 atomics 可实现跨 worker 无锁队列,关键用 compareexchange 原子更新读写指针,配合环形缓冲区设计(头部元数据+数据区),需启用跨域隔离策略并注意内存对齐与传输方式。

SharedArrayBuffer 与 Atomics 可以实现跨 Worker 的高效、无锁队列,关键在于用原子操作管理共享内存中的读写指针,避免互斥锁开销。但需注意浏览器启用限制(需跨域隔离)和内存对齐等细节。
共享内存布局设计
队列底层使用 SharedArrayBuffer 分配连续内存,结构通常包含:
- 头部元数据区:存放读指针(head)、写指针(tail)、容量(capacity),各占 1 个 Int32Array 元素(4 字节)
- 数据区:紧随其后,按固定大小槽位(slot)排列,每个槽位存储一个值(如 32 位整数)或通过偏移引用复杂结构
例如容量为 1024 的环形队列,总长度 = 3(元数据)+ 1024(数据)= 1027 个 Int32 元素,对应 new SharedArrayBuffer(1027 * 4)。
无锁入队与出队逻辑
核心是用 Atomics.compareExchange 原子地更新指针,并配合 Atomics.load 和 Atomics.store 读写数据:
-
入队(enqueue):读取当前 tail → 计算待写位置(取模)→
compareExchange(tail, old, old + 1)尝试推进 → 成功则写入数据;失败则重试 -
出队(dequeue):读取当前 head → 计算待读位置 →
compareExchange(head, old, old + 1)尝试推进 → 成功则读取并返回值;失败则重试
环形判断用 (index & (capacity - 1))(要求 capacity 是 2 的幂),比取模更快且原子安全。
内存可见性与竞争处理
Atomics 操作默认具有顺序一致性(sequentially consistent),但需注意:
- 写入数据后、更新 tail 前,必须确保数据已落内存——
Atomics.store写数据本身即具内存序语义,无需额外 fence - 读取数据前、读取 head 后,直接
Atomics.load对应槽位即可,Atomics 调用天然保证最新值 - 空/满状态需双指针协同判断:当
tail === head表示空;(tail + 1) & mask === head表示满(预留一个槽位避免歧义)
Worker 间初始化与通信
主线程创建 SharedArrayBuffer 后,需通过 postMessage(..., [buffer]) 传输给 Worker(不能直接传递引用):
- 主线程:
const sab = new SharedArrayBuffer(4096); const ia = new Int32Array(sab);,再worker.postMessage({ cmd: 'init', buffer: sab }, [sab]) - Worker 收到后,用相同视图重建:
const ia = new Int32Array(event.data.buffer); - 务必在服务端启用
cross-origin-opener-policy: same-origin与cross-origin-embedder-policy: require-corp,否则 SharedArrayBuffer 被禁用
不复杂但容易忽略。











