Java 8 为什么 parallelStream()每次运行的结果都不一样，，

[imcczy]

这是原来的代码：

HashSet<ModuleEntry> result = HashSetFactory.make();
for (Iterator<? extends ModuleEntry> it = M.getEntries(); it.hasNext();) {
    		ModuleEntry entry = (ModuleEntry) it.next();
    		if (entry instanceof DexModuleEntry) {    		
    			result.add(entry);
    		} 
    	}

我试着用了 Java8 的流 API ：

Collection<ModuleEntry> collection = M.getEntrysCollection();
collection.parallelStream().forEach(moduleEntry -> result.add(moduleEntry));

然后每次运行， result 的大小都是不一样的，醉了，，

去掉 parallelStream ，结果又是对的

collection.forEach(moduleEntry -> result.add(moduleEntry));

这个 parallelStream 使用有什么玄学么？

[notreami]

并行计算，可以理解为多线程便利

[sagaxu]

无序

[qiyuey]

并行流，需要线程安全

[imcczy]

@qiyuey #2 确实，没考虑到，我再试试

[phx13ye]

你这个 set synchronize 一下试试看什么结果

[imcczy]

@qiyuey #3
@phx13ye #5 原本是想多线程添加数据，少点处理时间，加上 synchronized 后又只能一个一个添加了，处理时间跟单线程是一样的，摊手

[Michaelssss]

本来 Map.size()这个就不是线程安全的吧。。。我记得是。。

[phx13ye]

@imcczy 我觉得是因为 hashset 线程不安全导致有重复元素添加进去了

[mononite]

collection.parallelStream().collect(Collectors.toSet())
对 parallel stream ， Collectors.toSet()先把输入分成多个部分，每部分生成一个 Set ，最后再把多个 Set 合成一个，性能更好还是更坏，取决于你的数据。