non-interference requirement on Java 8 streams

by

Well the oracle example is self-explanatory here. First one is this:

List<String> l = new ArrayList<>(Arrays.asList("one", "two"));
 Stream<String> sl = l.stream();
 l.add("three");
 String s = l.collect(Collectors.joining(" "));

If you change l by adding one more elements to it before you call the terminal operation (Collectors.joining) you are fine; but notice that the Stream consists of three elements, not two; at the time you created the Stream via l.stream().

On the other hand doing this:

  List<String> list = new ArrayList<>();
  list.add("test");
  list.forEach(x -> list.add(x));

will throw a ConcurrentModificationException since you can’t change the source.

And now suppose you have an underlying source that can handle concurrent adds:

ConcurrentHashMap<String, Integer> cMap = new ConcurrentHashMap<>();
cMap.put("one", 1);
cMap.forEach((key, value) -> cMap.put(key + key, value + value));
System.out.println(cMap);

What should the output be here? When I run this it is:

 {oneoneoneoneoneoneoneone=8, one=1, oneone=2, oneoneoneone=4}

Changing the key to zx (cMap.put("zx", 1)), the result is now:

{zxzx=2, zx=1}

The result is not consistent.

More Related Contents:

  1. How to convert to Java 8 map grouping by Map [closed]
  2. Java 8 List into Map
  3. Collection to stream to a new collection
  4. How to convert a Java 8 Stream to an Array?
  5. In Java, what are the advantages of streams over loops? [closed]
  6. How to sum a list of integers with java streams?
  7. Java 8 stream’s .min() and .max(): why does this compile?
  8. Why does Stream not implement Iterable?
  9. How can I create a stream from an array?
  10. In Java 8, is there a ByteStream class?
  11. Sum values from specific field of the objects in a list
  12. Files.walk(), calculate total size
  13. Does Stream.forEach respect the encounter order of sequential streams?
  14. Most efficient way to get the last element of a stream
  15. Why does findFirst() throw a NullPointerException if the first element it finds is null?
  16. Sort map by value using lambdas and streams
  17. Java 8 Stream IllegalStateException: Stream has already been operated on or closed
  18. Equivalent of Scala dropWhile
  19. Why does Stream.allMatch() return true for an empty stream?
  20. Modifying Objects within stream in Java8 while iterating
  21. Take every nth element from a Java 8 stream
  22. How to sum values in a Map with a stream?
  23. Static context cannot access non-static in Collectors
  24. What Java 8 Stream.collect equivalents are available in the standard Kotlin library?
  25. Java 8, how can I implement a switch statement using streams?
  26. Does collect operation on Stream close the stream and underlying resources?
  27. Nested Java 8 parallel forEach loop perform poor. Is this behavior expected?
  28. How to get multiple values from an object using a single stream operation?
  29. Java 8 Stream and operation on arrays
  30. What is the difference between intermediate and terminal operations?

Leave a Comment