小编Ben*_*ünz的帖子

Java 8 Streams中的并行性和Flatmap

您好我在使用flatmap时有关于并行性的问题请考虑以下示例

    IntStream.of(-1, 1).parallel().flatMap(i->IntStream.range(0,1000).parallel()).forEach(System.out::println);
Run Code Online (Sandbox Code Playgroud)

我是否将内部标志设置为并行是否重要?如果我离开或不离开,结果看起来非常相似.为什么代码(ReferencePipeline)会对映射进行顺序化?我对这条线感到困惑:

result.sequential().forEach(downstream);
Run Code Online (Sandbox Code Playgroud)

http://grepcode.com/file/repository.grepcode.com/java/root/jdk/openjdk/8-b132/java/util/stream/ReferencePipeline.java#ReferencePipeline.flatMap%28java.util.function.Function% 29

java parallel-processing java-8 java-stream

14
推荐指数
1
解决办法
3163
查看次数

ConcurrentHashMap parallelismThreshold

ConcurrentHashMap有一对夫妇的新方法.我有两个问题:

  1. 他们为什么不宣布ConcurrentMap
  2. 究竟是什么parallelismThreshold意思或做什么?

java parallel-processing concurrenthashmap java-8

7
推荐指数
2
解决办法
2225
查看次数