java - 为什么我会收到并发修改错误？

Question

我有一个名为 getChunks() 的同步方法。这是在整个程序中调用 block 集的唯一方法，但是在遍历它们时(通过调用 getChunks())我得到了一个 concurrentModificationException。这是因为在单独线程中运行的 ChunkManager 类会生成一个新 block 。但它访问 block 的唯一方法是通过 getChunks()...

getChunks() 方法:

public synchronized Set<WorldChunk> getChunks() {
    return chunks;
}

render()方法，异常发生的地方

public void render() {
    for(WorldChunk wc : chunkMap.getChunks()) { // <-- This is the line where the exception occurs
        wc.render();
    }
}

ChunkManager 类

public class ChunkManager implements Runnable {

    private static final int CHUNK_UPDATE_DELAY_MILLIS = 100;

    private ChunkMap chunkMap;

    public ChunkManager(ChunkMap chunkMap) {
        this.chunkMap = chunkMap;
        new Thread(this).start();
    }

    @Override
    public void run() {
        while(true) {
            manageChunks();
        }
    }

    private void manageChunks() {
        int cx = (int) ((Camera.getX() + WorldChunk.CHUNK_WIDTH / 2) / WorldChunk.CHUNK_WIDTH);
        int cz = (int) ((Camera.getZ() + WorldChunk.CHUNK_DEPTH / 2) / WorldChunk.CHUNK_DEPTH);
        int renderDistance = 2;
        for(int icx = cx - renderDistance; icx < cx + renderDistance; icx++) {
            for(int icz = cz - renderDistance; icz < cz + renderDistance; icz++) {
                if(!chunkMap.hasChunk(icx, icz)) {
                    chunkMap.genChunk(icx, icz, false);
                }
            }
        }
        for(WorldChunk wc : chunkMap.getChunks()) {
            if((Math.abs(wc.getX() - Camera.getX()) + Math.abs(wc.getZ() - Camera.getZ())) > WorldChunk.CHUNK_WIDTH + WorldChunk.CHUNK_DEPTH)  {
                wc.unload();
            }
        }
        try {
            Thread.sleep(CHUNK_UPDATE_DELAY_MILLIS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

编辑堆栈跟踪:

Exception in thread "main" java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextEntry(HashMap.java:894)
at java.util.HashMap$KeyIterator.next(HashMap.java:928)
at java.util.AbstractCollection.addAll(AbstractCollection.java:333)
at java.util.HashSet.<init>(HashSet.java:117)
at com.ryxuma.kalidus.world.World.render(World.java:35)
at com.ryxuma.kalidus.Core.renderPerspective(Core.java:35)
at org.heatstroke.Heatstroke$Runner.run(Heatstroke.java:365)
at org.heatstroke.Heatstroke.start(Heatstroke.java:124)
at com.ryxuma.kalidus.Core.main(Core.java:60)

Answer 1

您获取集合引用的操作是线程安全的，但是您对该集合所做的任何操作都不是线程安全的。一个简单的解决方案是要么

• 返回集合的副本
• 在迭代时锁定集合
• 使用像 CopyOnWriteArraySet 这样不会抛出 CME 的集合(更新时可能会更贵)

---

编辑:对于那些感兴趣的人，如果你想要一个 ConcurrentHashSet，你可以使用一个技巧

Set <E> set = Collections.newSetFromMap(new ConcurrentHashMap<E, Boolean>());