JS如何实现无锁队列？CAS操作原理

大杰酱_5244

发布时间：2025-08-21 10:18:02

936人浏览过

来源于php中文网

原创

javascript中实现无锁队列仅在web workers与sharedarraybuffer的多线程共享内存场景下有意义，其核心依赖atomics.compareexchange()提供的cas原子操作来避免传统锁的使用；在单线程主线程或node.js事件循环中，由于执行是顺序的，无需无锁结构；而在多worker环境下，可通过维护共享的head和tail指针并结合循环缓冲区，利用cas操作实现入队和出队的原子性更新，尽管面临aba问题、内存模型复杂性和调试困难等挑战，实际应用中更常见的是用atomics同步简单状态而非构建完整无锁队列，因此只有在高频大量数据共享、需细粒度并发控制或避免复制开销的高性能场景（如图像处理、科学计算）下才应考虑使用sharedarraybuffer与atomics，而在大多数情况下postmessage等消息传递机制仍是更安全、简洁的选择。

JS如何实现无锁队列？CAS操作原理

JavaScript实现无锁队列？这听起来有点反直觉，毕竟JavaScript在浏览器主线程和Node.js中通常被认为是单线程的。但当我们谈论“无锁”时，尤其是在现代并发编程的语境下，我们更多是指利用像

Atomics

这样的原子操作，在

SharedArrayBuffer

上构建并发结构，以避免传统锁带来的开销和潜在死锁。核心思想是利用CAS（Compare-And-Swap）操作的原子性来确保数据的一致性，即便在多线程（Web Workers）共享内存的场景下。

解决方案

在JavaScript中实现真正意义上的“无锁”队列，尤其是在传统浏览器主线程环境下，几乎是不可能的，因为JS的执行模型本身就是单线程事件循环。任何对共享数据的修改，如果发生在同一个线程内，无需锁机制也能保证原子性，因为操作是顺序执行的。

然而，当引入Web Workers和

SharedArrayBuffer

时，情况就变得复杂且有趣了。

SharedArrayBuffer

允许不同的Web Worker共享同一块内存，这时就可能出现数据竞争。为了在这种共享内存环境中实现并发安全的数据结构，

Atomics

对象应运而生，它提供了一系列原子操作，其中就包括了CAS操作的JavaScript版本：

Atomics.compareExchange()

。

一个无锁队列的核心在于，它不使用互斥锁来保护队列的头尾指针或数据元素，而是通过原子操作（如CAS）来乐观地更新状态。当一个线程（Worker）尝试入队或出队时，它会读取当前的状态（例如队列的尾指针），计算出新的状态，然后尝试使用CAS操作来更新这个状态。如果CAS成功，说明在此期间没有其他线程修改过该状态，操作完成。如果失败，说明有其他线程抢先修改了状态，当前线程会重试。

概念上，一个极简的基于

SharedArrayBuffer

和

Atomics

的“无锁”队列可能需要维护：

一个存储队列元素的
```
SharedArrayBuffer
```
（或其视图）。
两个原子性管理的索引：
```
head
```
（头指针）和
```
tail
```
（尾指针），它们也存储在
```
SharedArrayBuffer
```
中，并通过
```
Atomics
```
操作。

入队操作（EnQueue）：

读取当前的
```
tail
```
索引。

计算新的

tail

索引（例如

newTail = (currentTail + 1) % capacity

）。

尝试使用

Atomics.compareExchange()

将旧的

tail

更新为

newTail

。

Atomics.compareExchange(tailBuffer, 0, currentTail, newTail)

如果CAS成功，将数据写入
```
newTail
```
指向的位置。
如果CAS失败，说明
```
tail
```
已被其他Worker修改，需要重试整个过程。

出队操作（DeQueue）：

读取当前的
```
head
```
索引。
检查队列是否为空（
```
head == tail
```
）。
计算新的
```
head
```
索引。
尝试使用
```
Atomics.compareExchange()
```
将旧的
```
head
```
更新为
```
newHead
```
。
如果CAS成功，从
```
head
```
指向的位置读取数据。
如果CAS失败，重试。

这只是一个非常简化的模型，实际的无锁队列实现要复杂得多，需要处理内存分配、ABA问题、假共享等一系列挑战。在JavaScript中，由于没有直接的指针操作和底层内存管理能力，构建一个生产级的通用无锁队列库，其复杂度和实用性都远不如C++等语言。更多时候，我们利用

Atomics

来同步一些关键的共享状态变量，而不是完整的数据结构。

JavaScript中实现“无锁”队列的现实边界与挑战

在JavaScript中，谈论“无锁”队列，我们首先要明确它的语境。主流的JavaScript运行时，无论是浏览器主线程还是Node.js的事件循环，都是单线程的。这意味着在同一个执行上下文里，你不需要担心多个线程同时修改同一块内存导致的数据竞争，因为代码总是按顺序执行的。在这种情况下，传统的锁机制是多余的。

然而，当Web Workers进入视野，情况就变了。Web Workers是独立的执行线程，它们可以并行运行。默认情况下，Worker之间通过

postMessage

传递消息，这涉及数据的序列化和反序列化，对于大量或频繁的数据交换，会带来显著的性能开销。

SharedArrayBuffer

的出现就是为了解决这个问题，它允许多个Worker直接共享同一块内存区域。

一旦内存共享，数据竞争就成了实实在在的问题。比如，两个Worker同时尝试修改

SharedArrayBuffer

中的同一个计数器。如果没有原子操作的保护，最终的结果可能是错误的。

Atomics

API正是为此而生，它提供了一系列原子读、写、修改操作，确保对共享内存的访问是不可中断的。

但即便有了

Atomics

，在JavaScript中构建一个健壮、高性能的无锁队列依然面临巨大挑战：

复杂性爆炸：无锁数据结构的设计和实现本身就非常复杂，需要对内存模型、并发原语有深刻理解。JavaScript的抽象层次相对较高，缺乏直接的内存管理能力（如C++的指针），这使得构建底层无锁结构变得更加间接和困难。
ABA问题：这是CAS操作固有的一个经典问题。如果一个值从A变为B，然后又变回A，CAS操作会认为没有发生变化而成功，但实际上数据可能已经被修改过。在C/C++中，通常通过引入版本号或双字CAS来解决，但在JavaScript中实现这些需要额外的技巧和开销。
性能考量：虽然无锁旨在减少锁的开销，但
```
Atomics
```
操作本身也不是没有成本的。频繁的原子操作，尤其是在竞争激烈的情况下，可能会导致CPU缓存行失效，反而降低性能。而且，JavaScript的运行时优化器可能无法像C++编译器那样对原子操作进行深度优化。
调试困难：并发问题本身就臭名昭著地难以调试，无锁数据结构更是其中的佼佼者。竞争条件、死循环、活锁等问题，在JavaScript这种高级语言环境中，往往更难追踪和复现。

总的来说，在JavaScript中，我们更多地是利用

Atomics

来同步一些简单的共享状态（如计数器、标志位），而不是去构建完整的复杂无锁数据结构。对于大多数并发场景，基于

postMessage

的消息传递模型，或者结合

Atomics.wait()

Atomics.notify()

实现的简单锁/信号量机制，往往是更实用、更易于维护的选择。

CAS操作的底层原理与原子性保障

CAS，即Compare-And-Swap（比较并交换），是现代多核处理器提供的一种基本原子指令。它是实现无锁（lock-free）算法和数据结构的核心基石。

page-agent 浏览器控制（CDP）

使用 page-agent CLI（CDP）控制浏览器；CLI只能通过 GitHub Release 的 .tgz 安装，npm 官方包暂未发布。

下载

CAS操作的原理可以概括为三步：

读取：获取内存中某个位置的当前值（V）。
比较：将读取到的值V与一个“期望值”（A）进行比较。
交换：如果V等于A，那么就将该内存位置的值更新为新的“更新值”（B）。如果V不等于A，则不进行任何操作。

关键在于，这整个“读取-比较-交换”的过程是原子性的。这意味着处理器保证在执行CAS指令的期间，没有其他处理器或线程能够修改该内存位置的值。无论是在单核还是多核系统中，CAS操作都能保证其不可中断性。

举个例子，假设你有一个共享计数器，当前值为10。两个线程同时想把它加1。

线程A：读取计数器为10（V=10），期望值为10（A=10），想更新为11（B=11）。
线程B：几乎同时读取计数器为10（V=10），期望值为10（A=10），想更新为11（B=11）。

假设线程A的CAS操作先执行并成功：计数器从10变为11。当线程B的CAS操作执行时，它读取到的当前值是11（V=11），但它的期望值仍然是10（A=10）。此时V不等于A，CAS操作失败。线程B会发现它的更新尝试没有成功，通常会选择重试：重新读取计数器（现在是11），计算新的更新值（12），然后再次尝试CAS。

与传统的锁机制（如互斥锁）相比，CAS的优势在于：

非阻塞性：当一个线程尝试更新失败时，它不会被阻塞，而是可以选择重试或执行其他操作，从而避免了死锁和活锁的风险。
乐观并发：它假定冲突不常发生，只有在真正发生冲突时才进行重试，这在低竞争环境下通常比锁的开销更小。

在JavaScript中，

Atomics.compareExchange(typedArray, index, expectedValue, replacementValue)

就是对CAS操作的直接封装。它尝试将

typedArray

中

index

位置的值从

expectedValue

原子性地更新为

replacementValue

。如果成功，它会返回

expectedValue

（即操作前的值）；如果失败，它会返回当前实际的值（不等于

expectedValue

）。这使得开发者可以在JS层面利用底层硬件的原子性能力来构建并发安全的逻辑。

什么时候应该考虑在JavaScript中使用Atomics和SharedArrayBuffer构建并发结构？

在JavaScript中，利用

Atomics

和

SharedArrayBuffer

构建并发数据结构，通常是出于对极致性能的追求，或者在特定场景下，标准的消息传递（

postMessage

）模型无法满足需求。它不是一个普遍适用的解决方案，而是一个针对特定高性能计算场景的“高级工具”。

你应该考虑使用它们的情况包括：

Web Workers之间存在大量或高频的数据共享：当你的应用需要在多个Web Worker之间交换大量数据，并且
```
postMessage
```
带来的序列化/反序列化开销变得不可接受时，
```
SharedArrayBuffer
```
能提供零拷贝的数据共享，显著提升性能。例如，复杂的图像处理、大数据分析、物理模拟或机器学习推理等。
需要细粒度的并发控制：如果你需要在多个Worker之间同步访问和修改共享状态，并且希望避免传统锁带来的上下文切换和调度开销，
```
Atomics
```
可以提供更细粒度的原子操作。这对于实现高性能的并发算法（如无锁队列、并发哈希表）至关重要，尽管在JS中实现这些非常复杂。
避免数据复制的开销：
```
postMessage
```
在传输数据时，对于非
```
Transferable
```
对象会进行深拷贝。如果数据量巨大，这会消耗大量CPU和内存。
```
SharedArrayBuffer
```
允许Worker直接读写同一块内存，避免了复制，尤其适合处理大数组或二进制数据。
实现某些特定的同步原语：
```
Atomics.wait()
```
和
```
Atomics.notify()
```
提供了类似于操作系统信号量的能力，允许Worker在共享内存上等待某个条件达成，或者唤醒等待的Worker。这对于实现自定义的线程池、任务调度器或者复杂的生产者-消费者模型非常有用。

然而，在以下情况，你可能不应该考虑使用它们：

简单的Worker间通信：如果Worker之间只是传递少量消息或独立任务，
```
postMessage
```
模型已经足够简单高效。引入
```
SharedArrayBuffer
```
和
```
Atomics
```
会显著增加代码的复杂性。
主线程操作：
```
SharedArrayBuffer
```
和
```
Atomics
```
主要用于Web Workers之间的并发。在浏览器主线程，由于其单线程事件循环特性，通常不需要这些复杂的并发原语。
对并发编程不熟悉：无锁编程和并发数据结构是计算机科学中非常复杂且容易出错的领域。如果你对内存模型、原子性、竞争条件、死锁、活锁、ABA问题等概念不熟悉，贸然使用
```
Atomics
```
可能会引入难以发现和调试的bug。
追求代码简洁性和可维护性：
```
Atomics
```
代码通常比基于消息传递的代码更难理解、编写和调试。如果性能不是瓶颈，优先选择更简洁、更易于维护的解决方案。