java中spsc无锁消息队列用环形数组实现，核心是atomiclong管理读写索引、volatile+varhandle保障可见性、位运算优化下标计算，并通过缓存行填充规避伪共享。
在 Java 中用环形数组实现无锁异步消息队列缓冲区，核心在于避免 synchronized 或 Lock，转而依赖 AtomicInteger（或 AtomicLong）管理读写位置，并配合 volatile 字段保障可见性；同时必须正确处理“伪共享”（False Sharing）和“ABA 问题”的实际影响——但对单生产者/单消费者（SPSC）场景，ABA 并不构成威胁，可安全省略版本戳。
环形数组结构设计：固定容量 + 原子索引
使用 T[] buffer 作为底层存储（建议用 Object[] 配合类型擦除 + Unsafe 或 VarHandle 控制可见性），长度设为 2 的幂（如 1024、4096），便于用位运算替代取模提升性能：
-
写入索引（producerIndex）：
AtomicLong，每次成功入队后递增 -
读取索引（consumerIndex）：
AtomicLong，每次成功出队后递增 -
容量 mask = capacity - 1，下标计算统一用
(index & mask)，比% capacity快且无分支
无锁写入逻辑（SPSC 场景）
单生产者无需 CAS 自旋竞争，可直接用 getAndIncrement() 获取序号，再检查是否覆盖未消费数据（即“队列满”判断）：
- 先读
consumerIndex.get()，计算当前可用槽位：producerIndex.get() - consumerIndex.get() - 若未满，用
producerIndex.getAndIncrement()获得本次写入位置pos - 将消息存入
buffer[(int) pos & mask]，注意此处需确保写操作对消费者可见——推荐用VarHandle.setRelease(buffer, index, msg)或UNSAFE.putObjectRelease()
无锁读取逻辑（SPSC 场景）
单消费者同样免 CAS 竞争，流程对称：
- 先读
producerIndex.get()，判断是否有数据：consumerIndex.get() - 若非空，用
consumerIndex.getAndIncrement()获取读位置pos - 从
buffer[(int) pos & mask]读取消息，用VarHandle.getAcquire()保证看到完整写入结果 - 读完可选清空引用（
buffer[slot] = null）防止 GC 堵塞，但需搭配setRelease写入 null
规避伪共享与内存屏障关键点
CPU 缓存行通常 64 字节，若 producerIndex 和 consumerIndex 在同一缓存行，频繁跨核更新会引发无效化风暴：
- 为每个原子字段前后填充 7 个
long字段（共 56 字节），确保各自独占缓存行 - 使用
VarHandle的setRelease/getAcquire替代普通读写，精确控制编译器重排与 CPU 内存序 - 避免在循环内反复调用
get()——应一次读取多次使用，减少 volatile 读开销
不复杂但容易忽略：SPSC 模式下无需复杂状态机或版本号，真正的性能瓶颈往往在内存布局与屏障选择，而非算法逻辑本身。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
