奇怪的Java并发修改异常示例

Question

我是 Java 8 的新手，希望了解这两种情况之间的区别。我知道一旦一个流被操作和消耗，那么流就不能再次被重用，它会给出一个错误。场景 1：List<String> title = Arrays.asList("Java8", "In", "Action");        Stream<String> s = title.stream();        s.forEach(System.out::println);        s.forEach(System.out::println); // THIS WILL GIVE ERROR - streams has been already operated and closed.当我运行这个时，我得到以下错误......这是公平的。Java8InActionException in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed    at java.util.stream.AbstractPipeline.sourceStageSpliterator(Unknown Source)    at java.util.stream.ReferencePipeline$Head.forEach(Unknown Source)    at com.test.Java8InAction.CH4.TraversableOnlyOnce.main(TraversableOnlyOnce.java:12)场景 2：// Filtering unique elementsList<Integer> numbers = Arrays.asList(1, 2, 1, 3, 3, 2, 4);numbers.stream().forEach(System.out::println);numbers.stream().filter(n -> n % 2 == 0).distinct().forEach(System.out::println);numbers.stream().filter(n -> n % 2 == 0).forEach(System.out::println);这里我也操作了stream，关闭了终端操作，那为什么没有报错呢？

Answer 1

List.remove()ConcurrentModificationException当它从列表中删除倒数第二个元素时不会抛出。

引用此Java Bug (JDK-4902078)。

当集合框架被添加到平台时，每次迭代检查一次而不是两次的共同修改被认为太昂贵了；检查是在 Iterator.next 而不是 Iterator.hasNext 上进行的。专家审稿人认为这已经足够了。他们不知道它未能检测到一个重要的情况：如果在迭代中最后一次调用 hasNext 之前立即从列表中删除了一个元素，则该调用将返回 false 并且迭代终止，默默地忽略列表中的最后一个元素。

Answer 2

有两种方法用于迭代集合：枚举和迭代器。

第一个允许在迭代期间修改集合（慢速失败），第二个不允许（快速失败）。在 for-each 循环中，您使用的是迭代器，因此在迭代期间对集合的任何修改都会导致异常。

您有 3 个选择来解决这个问题：

改用迭代器：

Iterator<String> bookIt = listOfBooks.iterator();

while(bookIt.hasNext()){

   String book = bookIt.next();

   if (book.contains("Java")) {

       bookIt.remove();

   }

}

创建一个仅包含可接受元素的新列表（过滤掉不需要的元素）：

 List<String> booksWithNoCode =  listOfBooks.stream()

 .filter(book-> !book.contains("Code"))

 .collect(toList())

使用Collection.removeIf()，您将从列表中删除所有符合给定条件的元素。

listOfBooks.removeIf(book-> book.contains("Code"))

您可以在这篇文章和这里找到更多信息。