您好我在使用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)
该ConcurrentHashMap有一对夫妇的新方法.我有两个问题:
ConcurrentMap?parallelismThreshold意思或做什么?