基于Java原子对象的无锁线程安全缓冲区异常排查求助

云原生阿岚

2026-8-21

问题排查与解决方案

核心原因分析

你遇到的ConcurrentModificationException和空数组返回问题，本质是并发场景下非线程安全集合的修改/迭代冲突，或复合操作缺乏原子性导致的，具体拆解为以下几点：

底层集合非线程安全
如果你的缓冲区用了ArrayList这类非线程安全集合存储数据，哪怕用原子变量（比如AtomicInteger）控制索引，多个线程同时执行add、remove或迭代操作时，集合内部的modCount（修改计数器）会出现并发不一致，触发迭代时的ConcurrentModificationException。比如在addData里判断缓冲区是否已满、返回旧数据时遍历集合，都可能和其他线程的修改动作冲突。
复合操作无原子性保障
原子变量的单个操作（比如get()、incrementAndGet()）是原子的，但多个原子操作组合的逻辑不是。举个典型反例：
```
if (size.get() < capacity) {
    list.add(data);
    size.incrementAndGet();
}
```
这里的“判断大小→添加元素→更新计数”是三步独立操作，多个线程可能同时进入if块，导致集合大小超标，或添加元素时和其他线程的修改动作撞车，抛出异常。
返回数据时的并发快照问题
如果addData需要返回旧的缓冲区数据（比如满了之后替换），直接调用list.toArray()这类方法时，若其他线程正在修改集合，会导致快照生成不完整，返回空数组或触发异常。

针对性解决方案

方案1：替换为线程安全集合

如果缓冲区是队列/列表结构，直接用JDK自带的线程安全集合：

读多写少场景用CopyOnWriteArrayList：它通过写时复制避免并发修改冲突，迭代操作永远基于快照，不会抛异常；
队列场景用ConcurrentLinkedQueue：天生支持无阻塞并发操作，适合FIFO缓冲区。

方案2：原子引用+CAS实现无阻塞状态替换

如果要严格保持无阻塞特性，用AtomicReference存储整个缓冲区的不可变状态，每次修改通过CAS原子替换整个状态：

private final AtomicReference<byte[][]> bufferRef = new AtomicReference<>(new byte[10][]);
private final AtomicInteger size = new AtomicInteger(0);

public byte[][] addData(byte[] data) {
    while (true) {
        byte[][] currentBuffer = bufferRef.get();
        int currentSize = size.get();
        
        if (currentSize >= currentBuffer.length) {
            // 缓冲区满：生成新缓冲区，CAS替换后返回旧数据
            byte[][] newBuffer = new byte[10][];
            newBuffer[0] = data;
            if (bufferRef.compareAndSet(currentBuffer, newBuffer)) {
                size.set(1);
                return currentBuffer;
            }
        } else {
            // 缓冲区未满：复制旧数据+添加新元素，CAS替换
            byte[][] newBuffer = Arrays.copyOf(currentBuffer, currentBuffer.length);
            newBuffer[currentSize] = data;
            if (bufferRef.compareAndSet(currentBuffer, newBuffer)) {
                size.incrementAndGet();
                return null;
            }
        }
        // CAS失败则循环重试，直到成功
    }
}

这种方式把整个缓冲区的修改变成原子操作，彻底避免并发冲突。

方案3：规避并发迭代风险

如果必须使用非线程安全集合，在迭代或生成快照时要确保原子性（但这会失去无阻塞特性，仅作兜底）：

public byte[][] addData(byte[] data) {
    synchronized (list) {
        // 所有修改、迭代操作都在同步块内执行
        if (list.size() >= capacity) {
            byte[][] oldData = list.toArray(new byte[0][]);
            list.clear();
            list.add(data);
            return oldData;
        } else {
            list.add(data);
            return null;
        }
    }
}

排查验证步骤

先检查缓冲区的底层存储对象，确认是否为非线程安全集合（如ArrayList）；
跟踪addData中所有涉及集合修改、迭代的代码段，看是否存在未被原子化的复合操作；
测试时打印缓冲区的实时状态（比如修改前后的modCount、大小），定位异常触发时的并发时序。

内容的提问来源于stack exchange，提问作者choel