Java 8 ConcurrentModificationException 在进行任何类型的迭代时

Question

试图解决这个问题 2 周，但没有任何成功。 :X

当我进行任何类型的迭代时都会发生这种情况，但主要是在使用#forEach 时。

我没有以任何方式修改列表，也没有修改它的元素，所以这对我来说似乎很尴尬。示例代码：

    Map<Season, List<Team>> map = fetcher.getTeamsIn(ids);

    Set<Team> toCreateTeams = new HashSet<>();
    Set<Team> toUpdateTeams = new HashSet<>();

    map.forEach((k, v) -> {
        toCreateTeams.addAll(v.stream().filter(t -> !persistedTeams.containsKey(t.getId())).collect(Collectors.toSet()));
        toUpdateTeams.addAll(v.stream().filter(t -> {
            Date latestPersistedUpdate = persistedTeams.get(t.getId());
            return latestPersistedUpdate != null && t.getLastUpdated().after(latestPersistedUpdate);
        }).collect(Collectors.toSet()));
    });

地图在#getTeamsIn 中用 new HashMap<>();

实例化

试图在 eclipse 中遇到异常时中断，看看是否有线程在做一些疯狂的事情，但对我来说一切似乎都很正常。在下面的图片中，在迭代 map.

时抛出异常

我也开始出现其他一些非常奇怪的行为，比如永远卡在 lambda 表达式中。在这种情况下，在我看来 Eclipse 停止在表达式中（出于某种未知原因），就好像在该行中设置了某个断点一样。当我暂停执行并恢复有问题的线程时，流程恢复正常（直到下一个 lambda 表达式）或一些疯狂的 ConcurrentModificationException。

对我来说整个事情就像是一些 Eclipse 疯狂的错误，但如果是这样的话，我真的不想重建我的环境。

我正在使用

Java(TM) SE Runtime Environment (build 1.8.0_45-b14)
Java HotSpot(TM) 64-Bit Server VM (build 25.45-b02, mixed mode)

在 Linux 铸币厂。

谢谢！

-- 更新 1 --

明确一点：即使是这个简单的例子也会发生错误：

map.forEach((k, v) -> {
    System.out.println("Test" + k.getId());
});

一些可能很重要的随机信息：异常仅在打印地图的最后一个元素后爆炸！

-- 更新 2 --

关于更新 1 中的随机信息，这真的不重要，因为出于性能原因（至少在 HashMap 和 ArrayList 中），ConcurrentModificationException 仅在迭代结束时通过比较实际大小进行检查具有预期大小的元素数组。

#getTeamsIn 方法的代码：

public Map<Season, List<Team>> getTeamsIn(List<Season> seasons) throws InterruptedException {
    final CountDownLatch latch = new CountDownLatch(seasons.size());
    Map<Season, List<Team>> teamsInSeason = new HashMap<>();
    for (Season s : seasons) {
        httpclient.execute(new HttpGet(String.format(URL, s.getId())),
                new Callback(latch) {

                    @Override
                    public void completed(final HttpResponse response) {
                        super.completed(response);
                        try {
                            teamsInSeason.put(s, new TeamsUnmarshaller().unmarshal(response.getEntity().getContent()));
                        }
                        catch (IllegalStateException | IOException e) {
                            // TODO Auto-generated catch block
                            System.out.println(e);
                        }
                    }

                });
    }
    latch.await();
    return teamsInSeason;
}

Callback class 仅 implements FutureCallback<HttpResponse> 和 countDown() 所有回调方法中的 latch（#cancelled、#completed 和 #failed）。

Answer 1

好的，刚发现问题。我在方法 #getTeamsIn 中重写的 #completed 方法花费的时间太长（感谢 JAXB）到 return。由于 countDown()（在 super.completed(response) 中被调用）在 teamsInSeason.put(s, new TeamsUnmarshaller().unmarshal(response.getEntity().getContent())); 之前，我们遇到了问题。

修复简单而丑陋：

@Override
public void completed(final HttpResponse response) {
    try {
        teamsInSeason.put(s, new TeamsUnmarshaller().unmarshal(response.getEntity().getContent()));
    }
    catch (IllegalStateException | IOException e) {
        // TODO Auto-generated catch block
        System.out.println(e);
    } finally {
        super.completed(response);
    }
}

奇怪的 Eclipse 行为（由于某种未知原因卡在某个假想的断点），如果它持续存在，我认为是另一个主题的问题。

感谢大家的帮助和时间！

Java 8 ConcurrentModificationException 在进行任何类型的迭代时

Java 8 ConcurrentModificationException when doing any kind of iteration

java

foreach

lambda

concurrentmodification

-- 更新 1 --

-- 更新 2 --