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

Question

我有一个名为 getChunks() 的同步方法。这是在整个程序中调用块集的唯一方法，但是当迭代它们时（通过调用 getChunks()）我得到一个并发修改异常。这是因为在单独的线程中运行的 ChunkManager 类会生成一个新的块。但它访问块的唯一方法是通过 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

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

• 返回集合的副本
• 在迭代时锁定集合
• 使用不抛出 CME 的集合，如 CopyOnWriteArraySet （更新后可能会更贵）

---

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

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

Answer 2

你的wc.unload() 方法有什么作用？

如果您在迭代 Set 时尝试添加/删除元素，您可能会收到此错误。

看这里：http://docs.oracle.com/javase/1.5.0/docs/api/java/util/ConcurrentModificationException.html

特别是这部分：

请注意，此异常并不总是表示对象已被不同的线程同时修改。如果单个线程发出一系列违反对象约定的方法调用，则该对象可能会抛出此异常。 例如，如果线程在使用 fail-fast 迭代器迭代集合时直接修改了集合，则迭代器将抛出此异常。

对于我能想到的最简单的解决方案，跟踪所有要删除的元素，并在完成迭代后使用 Set.removeAll() 删除它们。

如果您愿意，请查看java.util.concurrent，您可以在其中找到允许您在迭代时进行修改的集合（不过请留意它们的工作方式，因为这可能不是您所期望的）。