5
我使用java8流。下面是数据结构,我有:java8 for each循环期间的java.util.ConcurrentModificationException
Map< String, List<String>> mmessage = getSomeMessage();
然后我通过地图和列表迭代:
mmessage.entrySet().stream().forEach(entry -> {
entry.getValue().stream().forEach(li -> {
if (lis.indexOf(li) == - 1) {
lis.add(lineItem);
}
});
});
,但得到的并发修改例外:
java.util.ConcurrentModificationException
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1380)
at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:580)
at com.web3.buyer.roomba.RoombaTurn.lambda$received$3(RoombaTurn.java:296)
at java.util.Iterator.forEachRemaining(Iterator.java:116)
at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:580)
at com.web3.buyer.roomba.RoombaTurn.received(RoombaTurn.java:295)
at com.web3.buyer.SystemBus.lambda$publishToTheQueue$0(SystemBus.java:51)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
从我的理解通过迭代map \ list不应该导致这种行为。
什么是'lis',它与mmessage' Map'有什么关系? – Eran
您不能在您正在迭代的列表中添加valies – Jens
@Jens OP不会将值添加到同一个列表中(至少我们还不知道,因为我们不知道什么是'lis')。 – Eran